@opentelemetry/otlp-transformer
Advanced tools
Comparing version 0.30.0 to 0.31.0
@@ -1,2 +0,2 @@ | ||
import { ScopeMetrics, MetricData, ResourceMetrics } from '@opentelemetry/sdk-metrics-base'; | ||
import { MetricData, ResourceMetrics, ScopeMetrics } from '@opentelemetry/sdk-metrics-base'; | ||
import { IMetric, IResourceMetrics, IScopeMetrics } from './types'; | ||
@@ -3,0 +3,0 @@ export declare function toResourceMetrics(resourceMetrics: ResourceMetrics): IResourceMetrics; |
@@ -18,3 +18,3 @@ /* | ||
import { hrTimeToNanoseconds } from '@opentelemetry/core'; | ||
import { AggregationTemporality, DataPointType, InstrumentType } from '@opentelemetry/sdk-metrics-base'; | ||
import { AggregationTemporality, DataPointType } from '@opentelemetry/sdk-metrics-base'; | ||
import { toAttributes } from '../common/internal'; | ||
@@ -51,21 +51,16 @@ export function toResourceMetrics(resourceMetrics) { | ||
var aggregationTemporality = toAggregationTemporality(metricData.aggregationTemporality); | ||
if (metricData.dataPointType === DataPointType.SINGULAR) { | ||
var dataPoints = toSingularDataPoints(metricData); | ||
var isMonotonic = metricData.descriptor.type === InstrumentType.COUNTER || | ||
metricData.descriptor.type === InstrumentType.OBSERVABLE_COUNTER; | ||
if (isSum(metricData)) { | ||
out.sum = { | ||
aggregationTemporality: aggregationTemporality, | ||
isMonotonic: isMonotonic, | ||
dataPoints: dataPoints | ||
}; | ||
} | ||
else { | ||
// Instrument is a gauge. | ||
out.gauge = { | ||
dataPoints: dataPoints | ||
}; | ||
} | ||
if (metricData.dataPointType === DataPointType.SUM) { | ||
out.sum = { | ||
aggregationTemporality: aggregationTemporality, | ||
isMonotonic: metricData.isMonotonic, | ||
dataPoints: toSingularDataPoints(metricData) | ||
}; | ||
} | ||
else if (isHistogram(metricData)) { | ||
else if (metricData.dataPointType === DataPointType.GAUGE) { | ||
// Instrument is a gauge. | ||
out.gauge = { | ||
dataPoints: toSingularDataPoints(metricData) | ||
}; | ||
} | ||
else if (metricData.dataPointType === DataPointType.HISTOGRAM) { | ||
out.histogram = { | ||
@@ -106,4 +101,4 @@ aggregationTemporality: aggregationTemporality, | ||
sum: histogram.sum, | ||
min: histogram.hasMinMax ? histogram.min : undefined, | ||
max: histogram.hasMinMax ? histogram.max : undefined, | ||
min: histogram.min, | ||
max: histogram.max, | ||
startTimeUnixNano: hrTimeToNanoseconds(dataPoint.startTime), | ||
@@ -114,11 +109,2 @@ timeUnixNano: hrTimeToNanoseconds(dataPoint.endTime), | ||
} | ||
function isSum(metric) { | ||
return (metric.descriptor.type === InstrumentType.COUNTER || | ||
metric.descriptor.type === InstrumentType.UP_DOWN_COUNTER || | ||
metric.descriptor.type === InstrumentType.OBSERVABLE_COUNTER || | ||
metric.descriptor.type === InstrumentType.OBSERVABLE_UP_DOWN_COUNTER); | ||
} | ||
function isHistogram(metric) { | ||
return metric.dataPointType === DataPointType.HISTOGRAM; | ||
} | ||
function toAggregationTemporality(temporality) { | ||
@@ -125,0 +111,0 @@ if (temporality === AggregationTemporality.DELTA) { |
@@ -1,2 +0,2 @@ | ||
import { ScopeMetrics, MetricData, ResourceMetrics } from '@opentelemetry/sdk-metrics-base'; | ||
import { MetricData, ResourceMetrics, ScopeMetrics } from '@opentelemetry/sdk-metrics-base'; | ||
import { IMetric, IResourceMetrics, IScopeMetrics } from './types'; | ||
@@ -3,0 +3,0 @@ export declare function toResourceMetrics(resourceMetrics: ResourceMetrics): IResourceMetrics; |
@@ -18,3 +18,3 @@ /* | ||
import { hrTimeToNanoseconds } from '@opentelemetry/core'; | ||
import { AggregationTemporality, DataPointType, InstrumentType } from '@opentelemetry/sdk-metrics-base'; | ||
import { AggregationTemporality, DataPointType } from '@opentelemetry/sdk-metrics-base'; | ||
import { toAttributes } from '../common/internal'; | ||
@@ -51,21 +51,16 @@ export function toResourceMetrics(resourceMetrics) { | ||
const aggregationTemporality = toAggregationTemporality(metricData.aggregationTemporality); | ||
if (metricData.dataPointType === DataPointType.SINGULAR) { | ||
const dataPoints = toSingularDataPoints(metricData); | ||
const isMonotonic = metricData.descriptor.type === InstrumentType.COUNTER || | ||
metricData.descriptor.type === InstrumentType.OBSERVABLE_COUNTER; | ||
if (isSum(metricData)) { | ||
out.sum = { | ||
aggregationTemporality, | ||
isMonotonic, | ||
dataPoints | ||
}; | ||
} | ||
else { | ||
// Instrument is a gauge. | ||
out.gauge = { | ||
dataPoints | ||
}; | ||
} | ||
if (metricData.dataPointType === DataPointType.SUM) { | ||
out.sum = { | ||
aggregationTemporality, | ||
isMonotonic: metricData.isMonotonic, | ||
dataPoints: toSingularDataPoints(metricData) | ||
}; | ||
} | ||
else if (isHistogram(metricData)) { | ||
else if (metricData.dataPointType === DataPointType.GAUGE) { | ||
// Instrument is a gauge. | ||
out.gauge = { | ||
dataPoints: toSingularDataPoints(metricData) | ||
}; | ||
} | ||
else if (metricData.dataPointType === DataPointType.HISTOGRAM) { | ||
out.histogram = { | ||
@@ -106,4 +101,4 @@ aggregationTemporality, | ||
sum: histogram.sum, | ||
min: histogram.hasMinMax ? histogram.min : undefined, | ||
max: histogram.hasMinMax ? histogram.max : undefined, | ||
min: histogram.min, | ||
max: histogram.max, | ||
startTimeUnixNano: hrTimeToNanoseconds(dataPoint.startTime), | ||
@@ -114,11 +109,2 @@ timeUnixNano: hrTimeToNanoseconds(dataPoint.endTime), | ||
} | ||
function isSum(metric) { | ||
return (metric.descriptor.type === InstrumentType.COUNTER || | ||
metric.descriptor.type === InstrumentType.UP_DOWN_COUNTER || | ||
metric.descriptor.type === InstrumentType.OBSERVABLE_COUNTER || | ||
metric.descriptor.type === InstrumentType.OBSERVABLE_UP_DOWN_COUNTER); | ||
} | ||
function isHistogram(metric) { | ||
return metric.dataPointType === DataPointType.HISTOGRAM; | ||
} | ||
function toAggregationTemporality(temporality) { | ||
@@ -125,0 +111,0 @@ if (temporality === AggregationTemporality.DELTA) { |
@@ -1,2 +0,2 @@ | ||
import { ScopeMetrics, MetricData, ResourceMetrics } from '@opentelemetry/sdk-metrics-base'; | ||
import { MetricData, ResourceMetrics, ScopeMetrics } from '@opentelemetry/sdk-metrics-base'; | ||
import { IMetric, IResourceMetrics, IScopeMetrics } from './types'; | ||
@@ -3,0 +3,0 @@ export declare function toResourceMetrics(resourceMetrics: ResourceMetrics): IResourceMetrics; |
@@ -55,21 +55,16 @@ "use strict"; | ||
const aggregationTemporality = toAggregationTemporality(metricData.aggregationTemporality); | ||
if (metricData.dataPointType === sdk_metrics_base_1.DataPointType.SINGULAR) { | ||
const dataPoints = toSingularDataPoints(metricData); | ||
const isMonotonic = metricData.descriptor.type === sdk_metrics_base_1.InstrumentType.COUNTER || | ||
metricData.descriptor.type === sdk_metrics_base_1.InstrumentType.OBSERVABLE_COUNTER; | ||
if (isSum(metricData)) { | ||
out.sum = { | ||
aggregationTemporality, | ||
isMonotonic, | ||
dataPoints | ||
}; | ||
} | ||
else { | ||
// Instrument is a gauge. | ||
out.gauge = { | ||
dataPoints | ||
}; | ||
} | ||
if (metricData.dataPointType === sdk_metrics_base_1.DataPointType.SUM) { | ||
out.sum = { | ||
aggregationTemporality, | ||
isMonotonic: metricData.isMonotonic, | ||
dataPoints: toSingularDataPoints(metricData) | ||
}; | ||
} | ||
else if (isHistogram(metricData)) { | ||
else if (metricData.dataPointType === sdk_metrics_base_1.DataPointType.GAUGE) { | ||
// Instrument is a gauge. | ||
out.gauge = { | ||
dataPoints: toSingularDataPoints(metricData) | ||
}; | ||
} | ||
else if (metricData.dataPointType === sdk_metrics_base_1.DataPointType.HISTOGRAM) { | ||
out.histogram = { | ||
@@ -111,4 +106,4 @@ aggregationTemporality, | ||
sum: histogram.sum, | ||
min: histogram.hasMinMax ? histogram.min : undefined, | ||
max: histogram.hasMinMax ? histogram.max : undefined, | ||
min: histogram.min, | ||
max: histogram.max, | ||
startTimeUnixNano: (0, core_1.hrTimeToNanoseconds)(dataPoint.startTime), | ||
@@ -119,11 +114,2 @@ timeUnixNano: (0, core_1.hrTimeToNanoseconds)(dataPoint.endTime), | ||
} | ||
function isSum(metric) { | ||
return (metric.descriptor.type === sdk_metrics_base_1.InstrumentType.COUNTER || | ||
metric.descriptor.type === sdk_metrics_base_1.InstrumentType.UP_DOWN_COUNTER || | ||
metric.descriptor.type === sdk_metrics_base_1.InstrumentType.OBSERVABLE_COUNTER || | ||
metric.descriptor.type === sdk_metrics_base_1.InstrumentType.OBSERVABLE_UP_DOWN_COUNTER); | ||
} | ||
function isHistogram(metric) { | ||
return metric.dataPointType === sdk_metrics_base_1.DataPointType.HISTOGRAM; | ||
} | ||
function toAggregationTemporality(temporality) { | ||
@@ -130,0 +116,0 @@ if (temporality === sdk_metrics_base_1.AggregationTemporality.DELTA) { |
@@ -7,3 +7,3 @@ { | ||
}, | ||
"version": "0.30.0", | ||
"version": "0.31.0", | ||
"description": "Transform OpenTelemetry SDK data into OTLP", | ||
@@ -81,9 +81,10 @@ "module": "build/esm/index.js", | ||
"dependencies": { | ||
"@opentelemetry/api-metrics": "0.30.0", | ||
"@opentelemetry/core": "1.4.0", | ||
"@opentelemetry/resources": "1.4.0", | ||
"@opentelemetry/sdk-metrics-base": "0.30.0", | ||
"@opentelemetry/sdk-trace-base": "1.4.0" | ||
"@opentelemetry/api-metrics": "0.31.0", | ||
"@opentelemetry/core": "1.5.0", | ||
"@opentelemetry/resources": "1.5.0", | ||
"@opentelemetry/sdk-metrics-base": "0.31.0", | ||
"@opentelemetry/sdk-trace-base": "1.5.0" | ||
}, | ||
"gitHead": "e39ab883b18636238ef0fd741df4ce5ed53e8d04" | ||
"homepage": "https://github.com/open-telemetry/opentelemetry-js/tree/main/experimental/packages/otlp-transformer", | ||
"gitHead": "776656b6e0cd0fc49a52b734702bc77110e483f1" | ||
} |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
No website
QualityPackage does not have a website.
Found 1 instance in 1 package
1
249843
2593
+ Added@opentelemetry/api-metrics@0.31.0(transitive)
+ Added@opentelemetry/core@1.5.0(transitive)
+ Added@opentelemetry/resources@1.5.0(transitive)
+ Added@opentelemetry/sdk-metrics-base@0.31.0(transitive)
+ Added@opentelemetry/sdk-trace-base@1.5.0(transitive)
+ Added@opentelemetry/semantic-conventions@1.5.0(transitive)
- Removed@opentelemetry/api-metrics@0.30.0(transitive)
- Removed@opentelemetry/core@1.4.0(transitive)
- Removed@opentelemetry/resources@1.4.0(transitive)
- Removed@opentelemetry/sdk-metrics-base@0.30.0(transitive)
- Removed@opentelemetry/sdk-trace-base@1.4.0(transitive)
- Removed@opentelemetry/semantic-conventions@1.4.0(transitive)
Updated@opentelemetry/core@1.5.0