@opentelemetry/sdk-metrics - npm Package Compare versions

Comparing version 1.15.2 to 1.16.0

build/esm/export/MetricReader.d.ts

@@ -20,2 +20,9 @@ import { AggregationTemporality } from './AggregationTemporality';
     aggregationTemporalitySelector?: AggregationTemporalitySelector;
+    /**
+     * **Note, this option is experimental**. Additional MetricProducers to use as a source of
+     * aggregated metric data in addition to the SDK's metric data. The resource returned by
+     * these MetricProducers is ignored; the SDK's resource will be used instead.
+     * @experimental
+     */
+    metricProducers?: MetricProducer[];
 }
@@ -28,3 +35,4 @@ /**
     private _shutdown;
-    private _metricProducer?;
+    private _metricProducers;
+    private _sdkMetricProducer?;
     private readonly _aggregationTemporalitySelector;
@@ -34,4 +42,9 @@ private readonly _aggregationSelector;
     /**
-     * Set the {@link MetricProducer} used by this instance.
+     * Set the {@link MetricProducer} used by this instance. **This should only be called by the
+     * SDK and should be considered internal.**
      *
+     * To add additional {@link MetricProducer}s to a {@link MetricReader}, pass them to the
+     * constructor as {@link MetricReaderOptions.metricProducers}.
+     *
+     * @internal
      * @param metricProducer
@@ -38,0 +51,0 @@ */

build/esm/export/MetricReader.js

@@ -52,4 +52,29 @@ /*
 };
+var __read = (this && this.__read) || function (o, n) {
+    var m = typeof Symbol === "function" && o[Symbol.iterator];
+    if (!m) return o;
+    var i = m.call(o), r, ar = [], e;
+    try {
+        while ((n === void 0 || n-- > 0) && !(r = i.next()).done) ar.push(r.value);
+    }
+    catch (error) { e = { error: error }; }
+    finally {
+        try {
+            if (r && !r.done && (m = i["return"])) m.call(i);
+        }
+        finally { if (e) throw e.error; }
+    }
+    return ar;
+};
+var __spreadArray = (this && this.__spreadArray) || function (to, from, pack) {
+    if (pack || arguments.length === 2) for (var i = 0, l = from.length, ar; i < l; i++) {
+        if (ar || !(i in from)) {
+            if (!ar) ar = Array.prototype.slice.call(from, 0, i);
+            ar[i] = from[i];
+        }
+    }
+    return to.concat(ar || Array.prototype.slice.call(from));
+};
 import * as api from '@opentelemetry/api';
-import { callWithTimeout } from '../utils';
+import { FlatMap, callWithTimeout } from '../utils';
 import { DEFAULT_AGGREGATION_SELECTOR, DEFAULT_AGGREGATION_TEMPORALITY_SELECTOR, } from './AggregationSelector';
@@ -62,3 +87,3 @@ /**
     function MetricReader(options) {
-        var _a, _b;
+        var _a, _b, _c;
         // Tracks the shutdown state.
@@ -71,13 +96,19 @@ // TODO: use BindOncePromise here once a new version of @opentelemetry/core is available.
             (_b = options === null || options === void 0 ? void 0 : options.aggregationTemporalitySelector) !== null && _b !== void 0 ? _b : DEFAULT_AGGREGATION_TEMPORALITY_SELECTOR;
+        this._metricProducers = (_c = options === null || options === void 0 ? void 0 : options.metricProducers) !== null && _c !== void 0 ? _c : [];
     }
     /**
-     * Set the {@link MetricProducer} used by this instance.
+     * Set the {@link MetricProducer} used by this instance. **This should only be called by the
+     * SDK and should be considered internal.**
      *
+     * To add additional {@link MetricProducer}s to a {@link MetricReader}, pass them to the
+     * constructor as {@link MetricReaderOptions.metricProducers}.
+     *
+     * @internal
      * @param metricProducer
      */
     MetricReader.prototype.setMetricProducer = function (metricProducer) {
-        if (this._metricProducer) {
+        if (this._sdkMetricProducer) {
             throw new Error('MetricReader can not be bound to a MeterProvider again.');
         }
-        this._metricProducer = metricProducer;
+        this._sdkMetricProducer = metricProducer;
         this.onInitialized();
@@ -111,13 +142,35 @@ };
         return __awaiter(this, void 0, void 0, function () {
-            return __generator(this, function (_a) {
-                if (this._metricProducer === undefined) {
-                    throw new Error('MetricReader is not bound to a MetricProducer');
+            var _a, sdkCollectionResults, additionalCollectionResults, errors, resource, scopeMetrics;
+            return __generator(this, function (_b) {
+                switch (_b.label) {
+                    case 0:
+                        if (this._sdkMetricProducer === undefined) {
+                            throw new Error('MetricReader is not bound to a MetricProducer');
+                        }
+                        // Subsequent invocations to collect are not allowed. SDKs SHOULD return some failure for these calls.
+                        if (this._shutdown) {
+                            throw new Error('MetricReader is shutdown');
+                        }
+                        return [4 /*yield*/, Promise.all(__spreadArray([
+                                this._sdkMetricProducer.collect({
+                                    timeoutMillis: options === null || options === void 0 ? void 0 : options.timeoutMillis,
+                                })
+                            ], __read(this._metricProducers.map(function (producer) {
+                                return producer.collect({
+                                    timeoutMillis: options === null || options === void 0 ? void 0 : options.timeoutMillis,
+                                });
+                            })), false))];
+                    case 1:
+                        _a = __read.apply(void 0, [_b.sent()]), sdkCollectionResults = _a[0], additionalCollectionResults = _a.slice(1);
+                        errors = sdkCollectionResults.errors.concat(FlatMap(additionalCollectionResults, function (result) { return result.errors; }));
+                        resource = sdkCollectionResults.resourceMetrics.resource;
+                        scopeMetrics = sdkCollectionResults.resourceMetrics.scopeMetrics.concat(FlatMap(additionalCollectionResults, function (result) { return result.resourceMetrics.scopeMetrics; }));
+                        return [2 /*return*/, {
+                                resourceMetrics: {
+                                    resource: resource,
+                                    scopeMetrics: scopeMetrics,
+                                },
+                                errors: errors,
+                            }];
                 }
-                // Subsequent invocations to collect are not allowed. SDKs SHOULD return some failure for these calls.
-                if (this._shutdown) {
-                    throw new Error('MetricReader is shutdown');
-                }
-                return [2 /*return*/, this._metricProducer.collect({
-                        timeoutMillis: options === null || options === void 0 ? void 0 : options.timeoutMillis,
-                    })];
             });
@@ -124,0 +177,0 @@ });

build/esm/export/PeriodicExportingMetricReader.d.ts

 import { MetricReader } from './MetricReader';
 import { PushMetricExporter } from './MetricExporter';
+import { MetricProducer } from './MetricProducer';
 export declare type PeriodicExportingMetricReaderOptions = {
@@ -17,2 +18,9 @@ /**
     exportTimeoutMillis?: number;
+    /**
+     * **Note, this option is experimental**. Additional MetricProducers to use as a source of
+     * aggregated metric data in addition to the SDK's metric data. The resource returned by
+     * these MetricProducers is ignored; the SDK's resource will be used instead.
+     * @experimental
+     */
+    metricProducers?: MetricProducer[];
 };
@@ -19,0 +27,0 @@ /**

build/esm/export/PeriodicExportingMetricReader.js

@@ -108,2 +108,3 @@ /*
             aggregationTemporalitySelector: (_b = options.exporter.selectAggregationTemporality) === null || _b === void 0 ? void 0 : _b.bind(options.exporter),
+            metricProducers: options.metricProducers,
         }) || this;
@@ -110,0 +111,0 @@ if (options.exportIntervalMillis !== undefined &&

build/esm/index.d.ts

@@ -10,2 +10,3 @@ export { Sum, LastValue, Histogram, ExponentialHistogram, } from './aggregator/types';
 export { ConsoleMetricExporter } from './export/ConsoleMetricExporter';
+export { MetricCollectOptions, MetricProducer } from './export/MetricProducer';
 export { InstrumentDescriptor, InstrumentType } from './InstrumentDescriptor';
@@ -12,0 +13,0 @@ export { MeterProvider, MeterProviderOptions } from './MeterProvider';

build/esm/InstrumentDescriptor.d.ts

@@ -27,2 +27,3 @@ import { MetricOptions, ValueType } from '@opentelemetry/api';
 export declare function isDescriptorCompatibleWith(descriptor: InstrumentDescriptor, otherDescriptor: InstrumentDescriptor): boolean;
+export declare function isValidName(name: string): boolean;
 //# sourceMappingURL=InstrumentDescriptor.d.ts.map

build/esm/InstrumentDescriptor.js

@@ -16,3 +16,4 @@ /*
  */
-import { ValueType } from '@opentelemetry/api';
+import { ValueType, diag } from '@opentelemetry/api';
+import { equalsCaseInsensitive } from './utils';
 /**
@@ -32,2 +33,5 @@ * Supported types of metric instruments.
     var _a, _b, _c;
+    if (!isValidName(name)) {
+        diag.warn("Invalid metric name: \"" + name + "\". The metric name should be a ASCII string with a length no greater than 255 characters.");
+    }
     return {
@@ -52,3 +56,4 @@ name: name,
 export function isDescriptorCompatibleWith(descriptor, otherDescriptor) {
-    return (descriptor.name === otherDescriptor.name &&
+    // Names are case-insensitive strings.
+    return (equalsCaseInsensitive(descriptor.name, otherDescriptor.name) &&
         descriptor.unit === otherDescriptor.unit &&
@@ -58,2 +63,8 @@ descriptor.type === otherDescriptor.type &&
 }
+// ASCII string with a length no greater than 255 characters.
+// NB: the first character counted separately from the rest.
+var NAME_REGEXP = /^[a-z][a-z0-9_.-]{0,254}$/i;
+export function isValidName(name) {
+    return name.match(NAME_REGEXP) != null;
+}
 //# sourceMappingURL=InstrumentDescriptor.js.map

build/esm/utils.d.ts

@@ -57,2 +57,3 @@ import { MetricAttributes } from '@opentelemetry/api';
 export declare function binarySearchLB(arr: number[], value: number): number;
+export declare function equalsCaseInsensitive(lhs: string, rhs: string): boolean;
 //# sourceMappingURL=utils.d.ts.map

build/esm/utils.js

@@ -259,2 +259,5 @@ /*
 }
+export function equalsCaseInsensitive(lhs, rhs) {
+    return lhs.toLowerCase() === rhs.toLowerCase();
+}
 //# sourceMappingURL=utils.js.map

build/esm/version.d.ts

@@ -1,2 +0,2 @@
-export declare const VERSION = "1.15.2";
+export declare const VERSION = "1.16.0";
 //# sourceMappingURL=version.d.ts.map

build/esm/version.js

@@ -17,3 +17,3 @@ /*
 // this is autogenerated file, see scripts/version-update.js
-export var VERSION = '1.15.2';
+export var VERSION = '1.16.0';
 //# sourceMappingURL=version.js.map

build/esnext/export/MetricReader.d.ts

@@ -20,2 +20,9 @@ import { AggregationTemporality } from './AggregationTemporality';
     aggregationTemporalitySelector?: AggregationTemporalitySelector;
+    /**
+     * **Note, this option is experimental**. Additional MetricProducers to use as a source of
+     * aggregated metric data in addition to the SDK's metric data. The resource returned by
+     * these MetricProducers is ignored; the SDK's resource will be used instead.
+     * @experimental
+     */
+    metricProducers?: MetricProducer[];
 }
@@ -28,3 +35,4 @@ /**
     private _shutdown;
-    private _metricProducer?;
+    private _metricProducers;
+    private _sdkMetricProducer?;
     private readonly _aggregationTemporalitySelector;
@@ -34,4 +42,9 @@ private readonly _aggregationSelector;
     /**
-     * Set the {@link MetricProducer} used by this instance.
+     * Set the {@link MetricProducer} used by this instance. **This should only be called by the
+     * SDK and should be considered internal.**
      *
+     * To add additional {@link MetricProducer}s to a {@link MetricReader}, pass them to the
+     * constructor as {@link MetricReaderOptions.metricProducers}.
+     *
+     * @internal
      * @param metricProducer
@@ -38,0 +51,0 @@ */

build/esnext/export/MetricReader.js

@@ -17,3 +17,3 @@ /*
 import * as api from '@opentelemetry/api';
-import { callWithTimeout } from '../utils';
+import { FlatMap, callWithTimeout } from '../utils';
 import { DEFAULT_AGGREGATION_SELECTOR, DEFAULT_AGGREGATION_TEMPORALITY_SELECTOR, } from './AggregationSelector';
@@ -26,3 +26,3 @@ /**
     constructor(options) {
-        var _a, _b;
+        var _a, _b, _c;
         // Tracks the shutdown state.
@@ -35,13 +35,19 @@ // TODO: use BindOncePromise here once a new version of @opentelemetry/core is available.
             (_b = options === null || options === void 0 ? void 0 : options.aggregationTemporalitySelector) !== null && _b !== void 0 ? _b : DEFAULT_AGGREGATION_TEMPORALITY_SELECTOR;
+        this._metricProducers = (_c = options === null || options === void 0 ? void 0 : options.metricProducers) !== null && _c !== void 0 ? _c : [];
     }
     /**
-     * Set the {@link MetricProducer} used by this instance.
+     * Set the {@link MetricProducer} used by this instance. **This should only be called by the
+     * SDK and should be considered internal.**
      *
+     * To add additional {@link MetricProducer}s to a {@link MetricReader}, pass them to the
+     * constructor as {@link MetricReaderOptions.metricProducers}.
+     *
+     * @internal
      * @param metricProducer
      */
     setMetricProducer(metricProducer) {
-        if (this._metricProducer) {
+        if (this._sdkMetricProducer) {
             throw new Error('MetricReader can not be bound to a MeterProvider again.');
         }
-        this._metricProducer = metricProducer;
+        this._sdkMetricProducer = metricProducer;
         this.onInitialized();
@@ -74,3 +80,3 @@ }
     async collect(options) {
-        if (this._metricProducer === undefined) {
+        if (this._sdkMetricProducer === undefined) {
             throw new Error('MetricReader is not bound to a MetricProducer');
@@ -82,5 +88,21 @@ }
         }
-        return this._metricProducer.collect({
-            timeoutMillis: options === null || options === void 0 ? void 0 : options.timeoutMillis,
-        });
+        const [sdkCollectionResults, ...additionalCollectionResults] = await Promise.all([
+            this._sdkMetricProducer.collect({
+                timeoutMillis: options === null || options === void 0 ? void 0 : options.timeoutMillis,
+            }),
+            ...this._metricProducers.map(producer => producer.collect({
+                timeoutMillis: options === null || options === void 0 ? void 0 : options.timeoutMillis,
+            })),
+        ]);
+        // Merge the results, keeping the SDK's Resource
+        const errors = sdkCollectionResults.errors.concat(FlatMap(additionalCollectionResults, result => result.errors));
+        const resource = sdkCollectionResults.resourceMetrics.resource;
+        const scopeMetrics = sdkCollectionResults.resourceMetrics.scopeMetrics.concat(FlatMap(additionalCollectionResults, result => result.resourceMetrics.scopeMetrics));
+        return {
+            resourceMetrics: {
+                resource,
+                scopeMetrics,
+            },
+            errors,
+        };
     }
@@ -87,0 +109,0 @@ /**

build/esnext/export/PeriodicExportingMetricReader.d.ts

 import { MetricReader } from './MetricReader';
 import { PushMetricExporter } from './MetricExporter';
+import { MetricProducer } from './MetricProducer';
 export declare type PeriodicExportingMetricReaderOptions = {
@@ -17,2 +18,9 @@ /**
     exportTimeoutMillis?: number;
+    /**
+     * **Note, this option is experimental**. Additional MetricProducers to use as a source of
+     * aggregated metric data in addition to the SDK's metric data. The resource returned by
+     * these MetricProducers is ignored; the SDK's resource will be used instead.
+     * @experimental
+     */
+    metricProducers?: MetricProducer[];
 };
@@ -19,0 +27,0 @@ /**

build/esnext/export/PeriodicExportingMetricReader.js

@@ -31,2 +31,3 @@ /*
             aggregationTemporalitySelector: (_b = options.exporter.selectAggregationTemporality) === null || _b === void 0 ? void 0 : _b.bind(options.exporter),
+            metricProducers: options.metricProducers,
         });
@@ -33,0 +34,0 @@ if (options.exportIntervalMillis !== undefined &&

build/esnext/index.d.ts

@@ -10,2 +10,3 @@ export { Sum, LastValue, Histogram, ExponentialHistogram, } from './aggregator/types';
 export { ConsoleMetricExporter } from './export/ConsoleMetricExporter';
+export { MetricCollectOptions, MetricProducer } from './export/MetricProducer';
 export { InstrumentDescriptor, InstrumentType } from './InstrumentDescriptor';
@@ -12,0 +13,0 @@ export { MeterProvider, MeterProviderOptions } from './MeterProvider';

build/esnext/InstrumentDescriptor.d.ts

@@ -27,2 +27,3 @@ import { MetricOptions, ValueType } from '@opentelemetry/api';
 export declare function isDescriptorCompatibleWith(descriptor: InstrumentDescriptor, otherDescriptor: InstrumentDescriptor): boolean;
+export declare function isValidName(name: string): boolean;
 //# sourceMappingURL=InstrumentDescriptor.d.ts.map

build/esnext/InstrumentDescriptor.js

@@ -16,3 +16,4 @@ /*
  */
-import { ValueType } from '@opentelemetry/api';
+import { ValueType, diag } from '@opentelemetry/api';
+import { equalsCaseInsensitive } from './utils';
 /**
@@ -32,2 +33,5 @@ * Supported types of metric instruments.
     var _a, _b, _c;
+    if (!isValidName(name)) {
+        diag.warn(`Invalid metric name: "${name}". The metric name should be a ASCII string with a length no greater than 255 characters.`);
+    }
     return {
@@ -52,3 +56,4 @@ name,
 export function isDescriptorCompatibleWith(descriptor, otherDescriptor) {
-    return (descriptor.name === otherDescriptor.name &&
+    // Names are case-insensitive strings.
+    return (equalsCaseInsensitive(descriptor.name, otherDescriptor.name) &&
         descriptor.unit === otherDescriptor.unit &&
@@ -58,2 +63,8 @@ descriptor.type === otherDescriptor.type &&
 }
+// ASCII string with a length no greater than 255 characters.
+// NB: the first character counted separately from the rest.
+const NAME_REGEXP = /^[a-z][a-z0-9_.-]{0,254}$/i;
+export function isValidName(name) {
+    return name.match(NAME_REGEXP) != null;
+}
 //# sourceMappingURL=InstrumentDescriptor.js.map

build/esnext/utils.d.ts

@@ -57,2 +57,3 @@ import { MetricAttributes } from '@opentelemetry/api';
 export declare function binarySearchLB(arr: number[], value: number): number;
+export declare function equalsCaseInsensitive(lhs: string, rhs: string): boolean;
 //# sourceMappingURL=utils.d.ts.map

build/esnext/utils.js

@@ -144,2 +144,5 @@ /*
 }
+export function equalsCaseInsensitive(lhs, rhs) {
+    return lhs.toLowerCase() === rhs.toLowerCase();
+}
 //# sourceMappingURL=utils.js.map

build/esnext/version.d.ts

@@ -1,2 +0,2 @@
-export declare const VERSION = "1.15.2";
+export declare const VERSION = "1.16.0";
 //# sourceMappingURL=version.d.ts.map

build/esnext/version.js

@@ -17,3 +17,3 @@ /*
 // this is autogenerated file, see scripts/version-update.js
-export const VERSION = '1.15.2';
+export const VERSION = '1.16.0';
 //# sourceMappingURL=version.js.map

build/src/export/MetricReader.d.ts

@@ -20,2 +20,9 @@ import { AggregationTemporality } from './AggregationTemporality';
     aggregationTemporalitySelector?: AggregationTemporalitySelector;
+    /**
+     * **Note, this option is experimental**. Additional MetricProducers to use as a source of
+     * aggregated metric data in addition to the SDK's metric data. The resource returned by
+     * these MetricProducers is ignored; the SDK's resource will be used instead.
+     * @experimental
+     */
+    metricProducers?: MetricProducer[];
 }
@@ -28,3 +35,4 @@ /**
     private _shutdown;
-    private _metricProducer?;
+    private _metricProducers;
+    private _sdkMetricProducer?;
     private readonly _aggregationTemporalitySelector;
@@ -34,4 +42,9 @@ private readonly _aggregationSelector;
     /**
-     * Set the {@link MetricProducer} used by this instance.
+     * Set the {@link MetricProducer} used by this instance. **This should only be called by the
+     * SDK and should be considered internal.**
      *
+     * To add additional {@link MetricProducer}s to a {@link MetricReader}, pass them to the
+     * constructor as {@link MetricReaderOptions.metricProducers}.
+     *
+     * @internal
      * @param metricProducer
@@ -38,0 +51,0 @@ */

build/src/export/MetricReader.js

@@ -28,3 +28,3 @@ "use strict";
     constructor(options) {
-        var _a, _b;
+        var _a, _b, _c;
         // Tracks the shutdown state.
@@ -37,13 +37,19 @@ // TODO: use BindOncePromise here once a new version of @opentelemetry/core is available.
             (_b = options === null || options === void 0 ? void 0 : options.aggregationTemporalitySelector) !== null && _b !== void 0 ? _b : AggregationSelector_1.DEFAULT_AGGREGATION_TEMPORALITY_SELECTOR;
+        this._metricProducers = (_c = options === null || options === void 0 ? void 0 : options.metricProducers) !== null && _c !== void 0 ? _c : [];
     }
     /**
-     * Set the {@link MetricProducer} used by this instance.
+     * Set the {@link MetricProducer} used by this instance. **This should only be called by the
+     * SDK and should be considered internal.**
      *
+     * To add additional {@link MetricProducer}s to a {@link MetricReader}, pass them to the
+     * constructor as {@link MetricReaderOptions.metricProducers}.
+     *
+     * @internal
      * @param metricProducer
      */
     setMetricProducer(metricProducer) {
-        if (this._metricProducer) {
+        if (this._sdkMetricProducer) {
             throw new Error('MetricReader can not be bound to a MeterProvider again.');
         }
-        this._metricProducer = metricProducer;
+        this._sdkMetricProducer = metricProducer;
         this.onInitialized();
@@ -76,3 +82,3 @@ }
     async collect(options) {
-        if (this._metricProducer === undefined) {
+        if (this._sdkMetricProducer === undefined) {
             throw new Error('MetricReader is not bound to a MetricProducer');
@@ -84,5 +90,21 @@ }
         }
-        return this._metricProducer.collect({
-            timeoutMillis: options === null || options === void 0 ? void 0 : options.timeoutMillis,
-        });
+        const [sdkCollectionResults, ...additionalCollectionResults] = await Promise.all([
+            this._sdkMetricProducer.collect({
+                timeoutMillis: options === null || options === void 0 ? void 0 : options.timeoutMillis,
+            }),
+            ...this._metricProducers.map(producer => producer.collect({
+                timeoutMillis: options === null || options === void 0 ? void 0 : options.timeoutMillis,
+            })),
+        ]);
+        // Merge the results, keeping the SDK's Resource
+        const errors = sdkCollectionResults.errors.concat((0, utils_1.FlatMap)(additionalCollectionResults, result => result.errors));
+        const resource = sdkCollectionResults.resourceMetrics.resource;
+        const scopeMetrics = sdkCollectionResults.resourceMetrics.scopeMetrics.concat((0, utils_1.FlatMap)(additionalCollectionResults, result => result.resourceMetrics.scopeMetrics));
+        return {
+            resourceMetrics: {
+                resource,
+                scopeMetrics,
+            },
+            errors,
+        };
     }
@@ -89,0 +111,0 @@ /**

build/src/export/PeriodicExportingMetricReader.d.ts

 import { MetricReader } from './MetricReader';
 import { PushMetricExporter } from './MetricExporter';
+import { MetricProducer } from './MetricProducer';
 export declare type PeriodicExportingMetricReaderOptions = {
@@ -17,2 +18,9 @@ /**
     exportTimeoutMillis?: number;
+    /**
+     * **Note, this option is experimental**. Additional MetricProducers to use as a source of
+     * aggregated metric data in addition to the SDK's metric data. The resource returned by
+     * these MetricProducers is ignored; the SDK's resource will be used instead.
+     * @experimental
+     */
+    metricProducers?: MetricProducer[];
 };
@@ -19,0 +27,0 @@ /**

build/src/export/PeriodicExportingMetricReader.js

@@ -34,2 +34,3 @@ "use strict";
             aggregationTemporalitySelector: (_b = options.exporter.selectAggregationTemporality) === null || _b === void 0 ? void 0 : _b.bind(options.exporter),
+            metricProducers: options.metricProducers,
         });
@@ -36,0 +37,0 @@ if (options.exportIntervalMillis !== undefined &&

build/src/index.d.ts

@@ -10,2 +10,3 @@ export { Sum, LastValue, Histogram, ExponentialHistogram, } from './aggregator/types';
 export { ConsoleMetricExporter } from './export/ConsoleMetricExporter';
+export { MetricCollectOptions, MetricProducer } from './export/MetricProducer';
 export { InstrumentDescriptor, InstrumentType } from './InstrumentDescriptor';
@@ -12,0 +13,0 @@ export { MeterProvider, MeterProviderOptions } from './MeterProvider';

build/src/InstrumentDescriptor.d.ts

@@ -27,2 +27,3 @@ import { MetricOptions, ValueType } from '@opentelemetry/api';
 export declare function isDescriptorCompatibleWith(descriptor: InstrumentDescriptor, otherDescriptor: InstrumentDescriptor): boolean;
+export declare function isValidName(name: string): boolean;
 //# sourceMappingURL=InstrumentDescriptor.d.ts.map

build/src/InstrumentDescriptor.js

@@ -18,4 +18,5 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.isDescriptorCompatibleWith = exports.createInstrumentDescriptorWithView = exports.createInstrumentDescriptor = exports.InstrumentType = void 0;
+exports.isValidName = exports.isDescriptorCompatibleWith = exports.createInstrumentDescriptorWithView = exports.createInstrumentDescriptor = exports.InstrumentType = void 0;
 const api_1 = require("@opentelemetry/api");
+const utils_1 = require("./utils");
 /**
@@ -35,2 +36,5 @@ * Supported types of metric instruments.
     var _a, _b, _c;
+    if (!isValidName(name)) {
+        api_1.diag.warn(`Invalid metric name: "${name}". The metric name should be a ASCII string with a length no greater than 255 characters.`);
+    }
     return {
@@ -57,3 +61,4 @@ name,
 function isDescriptorCompatibleWith(descriptor, otherDescriptor) {
-    return (descriptor.name === otherDescriptor.name &&
+    // Names are case-insensitive strings.
+    return ((0, utils_1.equalsCaseInsensitive)(descriptor.name, otherDescriptor.name) &&
         descriptor.unit === otherDescriptor.unit &&
@@ -64,2 +69,9 @@ descriptor.type === otherDescriptor.type &&
 exports.isDescriptorCompatibleWith = isDescriptorCompatibleWith;
+// ASCII string with a length no greater than 255 characters.
+// NB: the first character counted separately from the rest.
+const NAME_REGEXP = /^[a-z][a-z0-9_.-]{0,254}$/i;
+function isValidName(name) {
+    return name.match(NAME_REGEXP) != null;
+}
+exports.isValidName = isValidName;
 //# sourceMappingURL=InstrumentDescriptor.js.map

build/src/utils.d.ts

@@ -57,2 +57,3 @@ import { MetricAttributes } from '@opentelemetry/api';
 export declare function binarySearchLB(arr: number[], value: number): number;
+export declare function equalsCaseInsensitive(lhs: string, rhs: string): boolean;
 //# sourceMappingURL=utils.d.ts.map

build/src/utils.js

@@ -18,3 +18,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.binarySearchLB = exports.setEquals = exports.FlatMap = exports.isPromiseAllSettledRejectionResult = exports.PromiseAllSettled = exports.callWithTimeout = exports.TimeoutError = exports.instrumentationScopeId = exports.hashAttributes = exports.isNotNullish = void 0;
+exports.equalsCaseInsensitive = exports.binarySearchLB = exports.setEquals = exports.FlatMap = exports.isPromiseAllSettledRejectionResult = exports.PromiseAllSettled = exports.callWithTimeout = exports.TimeoutError = exports.instrumentationScopeId = exports.hashAttributes = exports.isNotNullish = void 0;
 function isNotNullish(item) {
@@ -158,2 +158,6 @@ return item !== undefined && item !== null;
 exports.binarySearchLB = binarySearchLB;
+function equalsCaseInsensitive(lhs, rhs) {
+    return lhs.toLowerCase() === rhs.toLowerCase();
+}
+exports.equalsCaseInsensitive = equalsCaseInsensitive;
 //# sourceMappingURL=utils.js.map

build/src/version.d.ts

@@ -1,2 +0,2 @@
-export declare const VERSION = "1.15.2";
+export declare const VERSION = "1.16.0";
 //# sourceMappingURL=version.d.ts.map

build/src/version.js

@@ -20,3 +20,3 @@ "use strict";
 // this is autogenerated file, see scripts/version-update.js
-exports.VERSION = '1.15.2';
+exports.VERSION = '1.16.0';
 //# sourceMappingURL=version.js.map

package.json

 {
   "name": "@opentelemetry/sdk-metrics",
-  "version": "1.15.2",
+  "version": "1.16.0",
   "description": "OpenTelemetry metrics SDK",
@@ -57,4 +57,4 @@ "main": "build/src/index.js",
   "devDependencies": {
-    "@babel/core": "7.22.10",
-    "@opentelemetry/api": ">=1.3.0 <1.5.0",
+    "@babel/core": "7.22.17",
+    "@opentelemetry/api": ">=1.3.0 <1.6.0",
     "@types/lodash.merge": "4.6.7",
@@ -73,3 +73,3 @@ "@types/mocha": "10.0.1",
     "karma-webpack": "4.0.2",
-    "lerna": "7.1.4",
+    "lerna": "7.1.5",
     "mocha": "10.2.0",
@@ -86,7 +86,7 @@ "nyc": "15.1.0",
   "peerDependencies": {
-    "@opentelemetry/api": ">=1.3.0 <1.5.0"
+    "@opentelemetry/api": ">=1.3.0 <1.6.0"
   },
   "dependencies": {
-    "@opentelemetry/core": "1.15.2",
-    "@opentelemetry/resources": "1.15.2",
+    "@opentelemetry/core": "1.16.0",
+    "@opentelemetry/resources": "1.16.0",
     "lodash.merge": "^4.6.2"
@@ -96,3 +96,3 @@ },
   "sideEffects": false,
-  "gitHead": "48fb15862e801b742059a3e39dbcc8ef4c10b2e2"
+  "gitHead": "5fcd8cf136e2235903dde3df9ba03ced594f0e95"
 }

No alert changes

Improved metrics

Total package byte prevSize

1872545

increased by1.32%

Lines of code

21466

increased by1.02%

Dependency changes

• + Added@opentelemetry/api@1.5.0(transitive)

• + Added@opentelemetry/core@1.16.0(transitive)

• + Added@opentelemetry/resources@1.16.0(transitive)

• + Added@opentelemetry/semantic-conventions@1.16.0(transitive)

• - Removed@opentelemetry/api@1.4.1(transitive)

• - Removed@opentelemetry/core@1.15.2(transitive)

• - Removed@opentelemetry/resources@1.15.2(transitive)

• - Removed@opentelemetry/semantic-conventions@1.15.2(transitive)

• Updated@opentelemetry/core@1.16.0

• Updated@opentelemetry/resources@1.16.0