Socket
Socket
Sign inDemoInstall

@opentelemetry/sdk-metrics

Package Overview
Dependencies
Maintainers
2
Versions
29
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@opentelemetry/sdk-metrics - npm Package Compare versions

Comparing version 0.33.0 to 1.8.0

3

build/esm/aggregator/types.d.ts

@@ -1,3 +0,2 @@

import { HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { HrTime, MetricAttributes } from '@opentelemetry/api';
import { AggregationTemporality } from '../export/AggregationTemporality';

@@ -4,0 +3,0 @@ import { MetricData } from '../export/MetricData';

3

build/esm/exemplar/AlignedHistogramBucketExemplarReservoir.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { FixedSizeExemplarReservoirBase } from './ExemplarReservoir';

@@ -4,0 +3,0 @@ /**

3

build/esm/exemplar/AlwaysSampleExemplarFilter.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { ExemplarFilter } from './ExemplarFilter';

@@ -4,0 +3,0 @@ export declare class AlwaysSampleExemplarFilter implements ExemplarFilter {

3

build/esm/exemplar/Exemplar.d.ts

@@ -1,3 +0,2 @@

import { HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { HrTime, MetricAttributes } from '@opentelemetry/api';
/**

@@ -4,0 +3,0 @@ * A representation of an exemplar, which is a sample input measurement.

3

build/esm/exemplar/ExemplarFilter.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
/**

@@ -4,0 +3,0 @@ * This interface represents a ExemplarFilter. Exemplar filters are

3

build/esm/exemplar/ExemplarReservoir.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { Exemplar } from './Exemplar';

@@ -4,0 +3,0 @@ /**

3

build/esm/exemplar/NeverSampleExemplarFilter.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { ExemplarFilter } from './ExemplarFilter';

@@ -4,0 +3,0 @@ export declare class NeverSampleExemplarFilter implements ExemplarFilter {

3

build/esm/exemplar/SimpleFixedSizeExemplarReservoir.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { FixedSizeExemplarReservoirBase } from './ExemplarReservoir';

@@ -4,0 +3,0 @@ /**

3

build/esm/exemplar/WithTraceExemplarFilter.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { ExemplarFilter } from './ExemplarFilter';

@@ -4,0 +3,0 @@ export declare class WithTraceExemplarFilter implements ExemplarFilter {

3

build/esm/export/MetricData.d.ts

@@ -1,3 +0,2 @@

import { HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { HrTime, MetricAttributes } from '@opentelemetry/api';
import { InstrumentationScope } from '@opentelemetry/core';

@@ -4,0 +3,0 @@ import { Resource } from '@opentelemetry/resources';

23

build/esm/export/PeriodicExportingMetricReader.js

@@ -93,3 +93,3 @@ /*

import * as api from '@opentelemetry/api';
import { ExportResultCode, globalErrorHandler, unrefTimer } from '@opentelemetry/core';
import { internal, ExportResultCode, globalErrorHandler, unrefTimer } from '@opentelemetry/core';
import { MetricReader } from './MetricReader';

@@ -127,5 +127,4 @@ import { callWithTimeout, TimeoutError } from '../utils';

return __awaiter(this, void 0, void 0, function () {
var _a, resourceMetrics, errors;
var _a, resourceMetrics, errors, result;
var _b;
var _this = this;
return __generator(this, function (_c) {

@@ -139,13 +138,9 @@ switch (_c.label) {

}
return [2 /*return*/, new Promise(function (resolve, reject) {
_this._exporter.export(resourceMetrics, function (result) {
var _a;
if (result.code !== ExportResultCode.SUCCESS) {
reject((_a = result.error) !== null && _a !== void 0 ? _a : new Error("PeriodicExportingMetricReader: metrics export failed (error " + result.error + ")"));
}
else {
resolve();
}
});
})];
return [4 /*yield*/, internal._export(this._exporter, resourceMetrics)];
case 2:
result = _c.sent();
if (result.code !== ExportResultCode.SUCCESS) {
throw new Error("PeriodicExportingMetricReader: metrics export failed (error " + result.error + ")");
}
return [2 /*return*/];
}

@@ -152,0 +147,0 @@ });

2

build/esm/InstrumentDescriptor.d.ts

@@ -1,2 +0,2 @@

import { MetricOptions, ValueType } from '@opentelemetry/api-metrics';
import { MetricOptions, ValueType } from '@opentelemetry/api';
import { View } from './view/View';

@@ -3,0 +3,0 @@ /**

2

build/esm/InstrumentDescriptor.js

@@ -16,3 +16,3 @@ /*

*/
import { ValueType } from '@opentelemetry/api-metrics';
import { ValueType } from '@opentelemetry/api';
/**

@@ -19,0 +19,0 @@ * Supported types of metric instruments.

36

build/esm/Instruments.d.ts

@@ -1,4 +0,2 @@

import * as api from '@opentelemetry/api';
import * as metrics from '@opentelemetry/api-metrics';
import { ObservableCallback } from '@opentelemetry/api-metrics';
import { Context, MetricAttributes, UpDownCounter, Counter, Histogram, Observable, ObservableCallback, ObservableCounter, ObservableGauge, ObservableUpDownCounter } from '@opentelemetry/api';
import { InstrumentDescriptor } from './InstrumentDescriptor';

@@ -11,32 +9,32 @@ import { ObservableRegistry } from './state/ObservableRegistry';

constructor(_writableMetricStorage: WritableMetricStorage, _descriptor: InstrumentDescriptor);
protected _record(value: number, attributes?: metrics.MetricAttributes, context?: api.Context): void;
protected _record(value: number, attributes?: MetricAttributes, context?: Context): void;
}
/**
* The class implements {@link metrics.UpDownCounter} interface.
* The class implements {@link UpDownCounter} interface.
*/
export declare class UpDownCounterInstrument extends SyncInstrument implements metrics.UpDownCounter {
export declare class UpDownCounterInstrument extends SyncInstrument implements UpDownCounter {
/**
* Increment value of counter by the input. Inputs may be negative.
*/
add(value: number, attributes?: metrics.MetricAttributes, ctx?: api.Context): void;
add(value: number, attributes?: MetricAttributes, ctx?: Context): void;
}
/**
* The class implements {@link metrics.Counter} interface.
* The class implements {@link Counter} interface.
*/
export declare class CounterInstrument extends SyncInstrument implements metrics.Counter {
export declare class CounterInstrument extends SyncInstrument implements Counter {
/**
* Increment value of counter by the input. Inputs may not be negative.
*/
add(value: number, attributes?: metrics.MetricAttributes, ctx?: api.Context): void;
add(value: number, attributes?: MetricAttributes, ctx?: Context): void;
}
/**
* The class implements {@link metrics.Histogram} interface.
* The class implements {@link Histogram} interface.
*/
export declare class HistogramInstrument extends SyncInstrument implements metrics.Histogram {
export declare class HistogramInstrument extends SyncInstrument implements Histogram {
/**
* Records a measurement. Value of the measurement must not be negative.
*/
record(value: number, attributes?: metrics.MetricAttributes, ctx?: api.Context): void;
record(value: number, attributes?: MetricAttributes, ctx?: Context): void;
}
export declare class ObservableInstrument implements metrics.Observable {
export declare class ObservableInstrument implements Observable {
private _observableRegistry;

@@ -49,17 +47,17 @@ /** @internal */

/**
* @see {metrics.Observable.addCallback}
* @see {Observable.addCallback}
*/
addCallback(callback: ObservableCallback): void;
/**
* @see {metrics.Observable.removeCallback}
* @see {Observable.removeCallback}
*/
removeCallback(callback: ObservableCallback): void;
}
export declare class ObservableCounterInstrument extends ObservableInstrument implements metrics.ObservableCounter {
export declare class ObservableCounterInstrument extends ObservableInstrument implements ObservableCounter {
}
export declare class ObservableGaugeInstrument extends ObservableInstrument implements metrics.ObservableGauge {
export declare class ObservableGaugeInstrument extends ObservableInstrument implements ObservableGauge {
}
export declare class ObservableUpDownCounterInstrument extends ObservableInstrument implements metrics.ObservableUpDownCounter {
export declare class ObservableUpDownCounterInstrument extends ObservableInstrument implements ObservableUpDownCounter {
}
export declare function isObservableInstrument(it: unknown): it is ObservableInstrument;
//# sourceMappingURL=Instruments.d.ts.map

23

build/esm/Instruments.js

@@ -31,4 +31,3 @@ /*

})();
import * as api from '@opentelemetry/api';
import * as metrics from '@opentelemetry/api-metrics';
import { context as contextApi, diag, ValueType, } from '@opentelemetry/api';
import { hrTime } from '@opentelemetry/core';

@@ -42,5 +41,5 @@ var SyncInstrument = /** @class */ (function () {

if (attributes === void 0) { attributes = {}; }
if (context === void 0) { context = api.context.active(); }
if (this._descriptor.valueType === metrics.ValueType.INT && !Number.isInteger(value)) {
api.diag.warn("INT value type cannot accept a floating-point value for " + this._descriptor.name + ", ignoring the fractional digits.");
if (context === void 0) { context = contextApi.active(); }
if (this._descriptor.valueType === ValueType.INT && !Number.isInteger(value)) {
diag.warn("INT value type cannot accept a floating-point value for " + this._descriptor.name + ", ignoring the fractional digits.");
value = Math.trunc(value);

@@ -54,3 +53,3 @@ }

/**
* The class implements {@link metrics.UpDownCounter} interface.
* The class implements {@link UpDownCounter} interface.
*/

@@ -72,3 +71,3 @@ var UpDownCounterInstrument = /** @class */ (function (_super) {

/**
* The class implements {@link metrics.Counter} interface.
* The class implements {@link Counter} interface.
*/

@@ -85,3 +84,3 @@ var CounterInstrument = /** @class */ (function (_super) {

if (value < 0) {
api.diag.warn("negative value provided to counter " + this._descriptor.name + ": " + value);
diag.warn("negative value provided to counter " + this._descriptor.name + ": " + value);
return;

@@ -95,3 +94,3 @@ }

/**
* The class implements {@link metrics.Histogram} interface.
* The class implements {@link Histogram} interface.
*/

@@ -108,3 +107,3 @@ var HistogramInstrument = /** @class */ (function (_super) {

if (value < 0) {
api.diag.warn("negative value provided to histogram " + this._descriptor.name + ": " + value);
diag.warn("negative value provided to histogram " + this._descriptor.name + ": " + value);
return;

@@ -124,3 +123,3 @@ }

/**
* @see {metrics.Observable.addCallback}
* @see {Observable.addCallback}
*/

@@ -131,3 +130,3 @@ ObservableInstrument.prototype.addCallback = function (callback) {

/**
* @see {metrics.Observable.removeCallback}
* @see {Observable.removeCallback}
*/

@@ -134,0 +133,0 @@ ObservableInstrument.prototype.removeCallback = function (callback) {

38

build/esm/Meter.d.ts

@@ -1,42 +0,42 @@

import * as metrics from '@opentelemetry/api-metrics';
import { Meter as IMeter, MetricOptions, Histogram, Counter, UpDownCounter, ObservableGauge, ObservableCounter, ObservableUpDownCounter, BatchObservableCallback, Observable } from '@opentelemetry/api';
import { MeterSharedState } from './state/MeterSharedState';
/**
* This class implements the {@link metrics.Meter} interface.
* This class implements the {@link IMeter} interface.
*/
export declare class Meter implements metrics.Meter {
export declare class Meter implements IMeter {
private _meterSharedState;
constructor(_meterSharedState: MeterSharedState);
/**
* Create a {@link metrics.Histogram} instrument.
* Create a {@link Histogram} instrument.
*/
createHistogram(name: string, options?: metrics.MetricOptions): metrics.Histogram;
createHistogram(name: string, options?: MetricOptions): Histogram;
/**
* Create a {@link metrics.Counter} instrument.
* Create a {@link Counter} instrument.
*/
createCounter(name: string, options?: metrics.MetricOptions): metrics.Counter;
createCounter(name: string, options?: MetricOptions): Counter;
/**
* Create a {@link metrics.UpDownCounter} instrument.
* Create a {@link UpDownCounter} instrument.
*/
createUpDownCounter(name: string, options?: metrics.MetricOptions): metrics.UpDownCounter;
createUpDownCounter(name: string, options?: MetricOptions): UpDownCounter;
/**
* Create a {@link metrics.ObservableGauge} instrument.
* Create a {@link ObservableGauge} instrument.
*/
createObservableGauge(name: string, options?: metrics.MetricOptions): metrics.ObservableGauge;
createObservableGauge(name: string, options?: MetricOptions): ObservableGauge;
/**
* Create a {@link metrics.ObservableCounter} instrument.
* Create a {@link ObservableCounter} instrument.
*/
createObservableCounter(name: string, options?: metrics.MetricOptions): metrics.ObservableCounter;
createObservableCounter(name: string, options?: MetricOptions): ObservableCounter;
/**
* Create a {@link metrics.ObservableUpDownCounter} instrument.
* Create a {@link ObservableUpDownCounter} instrument.
*/
createObservableUpDownCounter(name: string, options?: metrics.MetricOptions): metrics.ObservableUpDownCounter;
createObservableUpDownCounter(name: string, options?: MetricOptions): ObservableUpDownCounter;
/**
* @see {@link metrics.Meter.addBatchObservableCallback}
* @see {@link Meter.addBatchObservableCallback}
*/
addBatchObservableCallback(callback: metrics.BatchObservableCallback, observables: metrics.Observable[]): void;
addBatchObservableCallback(callback: BatchObservableCallback, observables: Observable[]): void;
/**
* @see {@link metrics.Meter.removeBatchObservableCallback}
* @see {@link Meter.removeBatchObservableCallback}
*/
removeBatchObservableCallback(callback: metrics.BatchObservableCallback, observables: metrics.Observable[]): void;
removeBatchObservableCallback(callback: BatchObservableCallback, observables: Observable[]): void;
}
//# sourceMappingURL=Meter.d.ts.map

18

build/esm/Meter.js

@@ -19,3 +19,3 @@ /*

/**
* This class implements the {@link metrics.Meter} interface.
* This class implements the {@link IMeter} interface.
*/

@@ -27,3 +27,3 @@ var Meter = /** @class */ (function () {

/**
* Create a {@link metrics.Histogram} instrument.
* Create a {@link Histogram} instrument.
*/

@@ -36,3 +36,3 @@ Meter.prototype.createHistogram = function (name, options) {

/**
* Create a {@link metrics.Counter} instrument.
* Create a {@link Counter} instrument.
*/

@@ -45,3 +45,3 @@ Meter.prototype.createCounter = function (name, options) {

/**
* Create a {@link metrics.UpDownCounter} instrument.
* Create a {@link UpDownCounter} instrument.
*/

@@ -54,3 +54,3 @@ Meter.prototype.createUpDownCounter = function (name, options) {

/**
* Create a {@link metrics.ObservableGauge} instrument.
* Create a {@link ObservableGauge} instrument.
*/

@@ -63,3 +63,3 @@ Meter.prototype.createObservableGauge = function (name, options) {

/**
* Create a {@link metrics.ObservableCounter} instrument.
* Create a {@link ObservableCounter} instrument.
*/

@@ -72,3 +72,3 @@ Meter.prototype.createObservableCounter = function (name, options) {

/**
* Create a {@link metrics.ObservableUpDownCounter} instrument.
* Create a {@link ObservableUpDownCounter} instrument.
*/

@@ -81,3 +81,3 @@ Meter.prototype.createObservableUpDownCounter = function (name, options) {

/**
* @see {@link metrics.Meter.addBatchObservableCallback}
* @see {@link Meter.addBatchObservableCallback}
*/

@@ -88,3 +88,3 @@ Meter.prototype.addBatchObservableCallback = function (callback, observables) {

/**
* @see {@link metrics.Meter.removeBatchObservableCallback}
* @see {@link Meter.removeBatchObservableCallback}
*/

@@ -91,0 +91,0 @@ Meter.prototype.removeBatchObservableCallback = function (callback, observables) {

8

build/esm/MeterProvider.d.ts

@@ -1,2 +0,2 @@

import * as metrics from '@opentelemetry/api-metrics';
import { MeterProvider as IMeterProvider, Meter as IMeter, MeterOptions } from '@opentelemetry/api';
import { Resource } from '@opentelemetry/resources';

@@ -15,5 +15,5 @@ import { MetricReader } from './export/MetricReader';

/**
* This class implements the {@link metrics.MeterProvider} interface.
* This class implements the {@link MeterProvider} interface.
*/
export declare class MeterProvider implements metrics.MeterProvider {
export declare class MeterProvider implements IMeterProvider {
private _sharedState;

@@ -25,3 +25,3 @@ private _shutdown;

*/
getMeter(name: string, version?: string, options?: metrics.MeterOptions): metrics.Meter;
getMeter(name: string, version?: string, options?: MeterOptions): IMeter;
/**

@@ -28,0 +28,0 @@ * Register a {@link MetricReader} to the meter provider. After the

13

build/esm/MeterProvider.js

@@ -63,4 +63,3 @@ /*

};
import * as api from '@opentelemetry/api';
import * as metrics from '@opentelemetry/api-metrics';
import { diag, createNoopMeter, } from '@opentelemetry/api';
import { Resource } from '@opentelemetry/resources';

@@ -70,3 +69,3 @@ import { MeterProviderSharedState } from './state/MeterProviderSharedState';

/**
* This class implements the {@link metrics.MeterProvider} interface.
* This class implements the {@link MeterProvider} interface.
*/

@@ -103,4 +102,4 @@ var MeterProvider = /** @class */ (function () {

if (this._shutdown) {
api.diag.warn('A shutdown MeterProvider cannot provide a Meter');
return metrics.createNoopMeter();
diag.warn('A shutdown MeterProvider cannot provide a Meter');
return createNoopMeter();
}

@@ -134,3 +133,3 @@ return this._sharedState

if (this._shutdown) {
api.diag.warn('shutdown may only be called once per MeterProvider');
diag.warn('shutdown may only be called once per MeterProvider');
return [2 /*return*/];

@@ -161,3 +160,3 @@ }

if (this._shutdown) {
api.diag.warn('invalid attempt to force flush after MeterProvider shutdown');
diag.warn('invalid attempt to force flush after MeterProvider shutdown');
return [2 /*return*/];

@@ -164,0 +163,0 @@ }

14

build/esm/ObservableResult.d.ts

@@ -1,2 +0,2 @@

import * as metrics from '@opentelemetry/api-metrics';
import { ObservableResult, MetricAttributes, BatchObservableResult, Observable } from '@opentelemetry/api';
import { AttributeHashMap } from './state/HashMap';

@@ -6,5 +6,5 @@ import { ObservableInstrument } from './Instruments';

/**
* The class implements {@link metrics.ObservableResult} interface.
* The class implements {@link ObservableResult} interface.
*/
export declare class ObservableResultImpl implements metrics.ObservableResult {
export declare class ObservableResultImpl implements ObservableResult {
private _descriptor;

@@ -19,8 +19,8 @@ /**

*/
observe(value: number, attributes?: metrics.MetricAttributes): void;
observe(value: number, attributes?: MetricAttributes): void;
}
/**
* The class implements {@link metrics.BatchObservableCallback} interface.
* The class implements {@link BatchObservableCallback} interface.
*/
export declare class BatchObservableResultImpl implements metrics.BatchObservableResult {
export declare class BatchObservableResultImpl implements BatchObservableResult {
/**

@@ -33,4 +33,4 @@ * @internal

*/
observe(metric: metrics.Observable, value: number, attributes?: metrics.MetricAttributes): void;
observe(metric: Observable, value: number, attributes?: MetricAttributes): void;
}
//# sourceMappingURL=ObservableResult.d.ts.map

15

build/esm/ObservableResult.js

@@ -16,8 +16,7 @@ /*

*/
import * as api from '@opentelemetry/api';
import * as metrics from '@opentelemetry/api-metrics';
import { diag, ValueType, } from '@opentelemetry/api';
import { AttributeHashMap } from './state/HashMap';
import { isObservableInstrument } from './Instruments';
/**
* The class implements {@link metrics.ObservableResult} interface.
* The class implements {@link ObservableResult} interface.
*/

@@ -37,4 +36,4 @@ var ObservableResultImpl = /** @class */ (function () {

if (attributes === void 0) { attributes = {}; }
if (this._descriptor.valueType === metrics.ValueType.INT && !Number.isInteger(value)) {
api.diag.warn("INT value type cannot accept a floating-point value for " + this._descriptor.name + ", ignoring the fractional digits.");
if (this._descriptor.valueType === ValueType.INT && !Number.isInteger(value)) {
diag.warn("INT value type cannot accept a floating-point value for " + this._descriptor.name + ", ignoring the fractional digits.");
value = Math.trunc(value);

@@ -48,3 +47,3 @@ }

/**
* The class implements {@link metrics.BatchObservableCallback} interface.
* The class implements {@link BatchObservableCallback} interface.
*/

@@ -71,4 +70,4 @@ var BatchObservableResultImpl = /** @class */ (function () {

}
if (metric._descriptor.valueType === metrics.ValueType.INT && !Number.isInteger(value)) {
api.diag.warn("INT value type cannot accept a floating-point value for " + metric._descriptor.name + ", ignoring the fractional digits.");
if (metric._descriptor.valueType === ValueType.INT && !Number.isInteger(value)) {
diag.warn("INT value type cannot accept a floating-point value for " + metric._descriptor.name + ", ignoring the fractional digits.");
value = Math.trunc(value);

@@ -75,0 +74,0 @@ }

3

build/esm/state/DeltaMetricProcessor.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { Maybe } from '../utils';

@@ -4,0 +3,0 @@ import { Accumulation, Aggregator } from '../aggregator/types';

2

build/esm/state/HashMap.d.ts

@@ -1,2 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { MetricAttributes } from '@opentelemetry/api';
export interface Hash<ValueType, HashCodeType> {

@@ -3,0 +3,0 @@ (value: ValueType): HashCodeType;

3

build/esm/state/MultiWritableMetricStorage.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { WritableMetricStorage } from './WritableMetricStorage';

@@ -4,0 +3,0 @@ /**

3

build/esm/state/ObservableRegistry.d.ts

@@ -1,3 +0,2 @@

import { HrTime } from '@opentelemetry/api';
import { BatchObservableCallback, Observable, ObservableCallback } from '@opentelemetry/api-metrics';
import { HrTime, BatchObservableCallback, Observable, ObservableCallback } from '@opentelemetry/api';
import { ObservableInstrument } from '../Instruments';

@@ -4,0 +3,0 @@ /**

4

build/esm/state/ObservableRegistry.js

@@ -77,3 +77,3 @@ /*

};
import * as api from '@opentelemetry/api';
import { diag } from '@opentelemetry/api';
import { isObservableInstrument } from '../Instruments';

@@ -111,3 +111,3 @@ import { BatchObservableResultImpl, ObservableResultImpl } from '../ObservableResult';

if (observableInstruments.size === 0) {
api.diag.error('BatchObservableCallback is not associated with valid instruments', instruments);
diag.error('BatchObservableCallback is not associated with valid instruments', instruments);
return;

@@ -114,0 +114,0 @@ }

3

build/esm/state/SyncMetricStorage.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { WritableMetricStorage } from './WritableMetricStorage';

@@ -4,0 +3,0 @@ import { Accumulation, Aggregator } from '../aggregator/types';

3

build/esm/state/WritableMetricStorage.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { AttributeHashMap } from './HashMap';

@@ -4,0 +3,0 @@ /**

2

build/esm/utils.d.ts

@@ -1,2 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { MetricAttributes } from '@opentelemetry/api';
import { InstrumentationScope } from '@opentelemetry/core';

@@ -3,0 +3,0 @@ export declare type Maybe<T> = T | undefined;

2

build/esm/version.d.ts

@@ -1,2 +0,2 @@

export declare const VERSION = "0.33.0";
export declare const VERSION = "1.8.0";
//# sourceMappingURL=version.d.ts.map

2

build/esm/version.js

@@ -17,3 +17,3 @@ /*

// this is autogenerated file, see scripts/version-update.js
export var VERSION = '0.33.0';
export var VERSION = '1.8.0';
//# sourceMappingURL=version.js.map

3

build/esm/view/AttributesProcessor.d.ts

@@ -1,3 +0,2 @@

import { Context } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, MetricAttributes } from '@opentelemetry/api';
/**

@@ -4,0 +3,0 @@ * The {@link AttributesProcessor} is responsible for customizing which

3

build/esnext/aggregator/types.d.ts

@@ -1,3 +0,2 @@

import { HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { HrTime, MetricAttributes } from '@opentelemetry/api';
import { AggregationTemporality } from '../export/AggregationTemporality';

@@ -4,0 +3,0 @@ import { MetricData } from '../export/MetricData';

3

build/esnext/exemplar/AlignedHistogramBucketExemplarReservoir.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { FixedSizeExemplarReservoirBase } from './ExemplarReservoir';

@@ -4,0 +3,0 @@ /**

3

build/esnext/exemplar/AlwaysSampleExemplarFilter.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { ExemplarFilter } from './ExemplarFilter';

@@ -4,0 +3,0 @@ export declare class AlwaysSampleExemplarFilter implements ExemplarFilter {

3

build/esnext/exemplar/Exemplar.d.ts

@@ -1,3 +0,2 @@

import { HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { HrTime, MetricAttributes } from '@opentelemetry/api';
/**

@@ -4,0 +3,0 @@ * A representation of an exemplar, which is a sample input measurement.

3

build/esnext/exemplar/ExemplarFilter.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
/**

@@ -4,0 +3,0 @@ * This interface represents a ExemplarFilter. Exemplar filters are

3

build/esnext/exemplar/ExemplarReservoir.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { Exemplar } from './Exemplar';

@@ -4,0 +3,0 @@ /**

3

build/esnext/exemplar/NeverSampleExemplarFilter.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { ExemplarFilter } from './ExemplarFilter';

@@ -4,0 +3,0 @@ export declare class NeverSampleExemplarFilter implements ExemplarFilter {

3

build/esnext/exemplar/SimpleFixedSizeExemplarReservoir.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { FixedSizeExemplarReservoirBase } from './ExemplarReservoir';

@@ -4,0 +3,0 @@ /**

3

build/esnext/exemplar/WithTraceExemplarFilter.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { ExemplarFilter } from './ExemplarFilter';

@@ -4,0 +3,0 @@ export declare class WithTraceExemplarFilter implements ExemplarFilter {

3

build/esnext/export/MetricData.d.ts

@@ -1,3 +0,2 @@

import { HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { HrTime, MetricAttributes } from '@opentelemetry/api';
import { InstrumentationScope } from '@opentelemetry/core';

@@ -4,0 +3,0 @@ import { Resource } from '@opentelemetry/resources';

17

build/esnext/export/PeriodicExportingMetricReader.js

@@ -17,3 +17,3 @@ /*

import * as api from '@opentelemetry/api';
import { ExportResultCode, globalErrorHandler, unrefTimer } from '@opentelemetry/core';
import { internal, ExportResultCode, globalErrorHandler, unrefTimer } from '@opentelemetry/core';
import { MetricReader } from './MetricReader';

@@ -52,13 +52,6 @@ import { callWithTimeout, TimeoutError } from '../utils';

}
return new Promise((resolve, reject) => {
this._exporter.export(resourceMetrics, result => {
var _a;
if (result.code !== ExportResultCode.SUCCESS) {
reject((_a = result.error) !== null && _a !== void 0 ? _a : new Error(`PeriodicExportingMetricReader: metrics export failed (error ${result.error})`));
}
else {
resolve();
}
});
});
const result = await internal._export(this._exporter, resourceMetrics);
if (result.code !== ExportResultCode.SUCCESS) {
throw new Error(`PeriodicExportingMetricReader: metrics export failed (error ${result.error})`);
}
}

@@ -65,0 +58,0 @@ onInitialized() {

2

build/esnext/InstrumentDescriptor.d.ts

@@ -1,2 +0,2 @@

import { MetricOptions, ValueType } from '@opentelemetry/api-metrics';
import { MetricOptions, ValueType } from '@opentelemetry/api';
import { View } from './view/View';

@@ -3,0 +3,0 @@ /**

2

build/esnext/InstrumentDescriptor.js

@@ -16,3 +16,3 @@ /*

*/
import { ValueType } from '@opentelemetry/api-metrics';
import { ValueType } from '@opentelemetry/api';
/**

@@ -19,0 +19,0 @@ * Supported types of metric instruments.

36

build/esnext/Instruments.d.ts

@@ -1,4 +0,2 @@

import * as api from '@opentelemetry/api';
import * as metrics from '@opentelemetry/api-metrics';
import { ObservableCallback } from '@opentelemetry/api-metrics';
import { Context, MetricAttributes, UpDownCounter, Counter, Histogram, Observable, ObservableCallback, ObservableCounter, ObservableGauge, ObservableUpDownCounter } from '@opentelemetry/api';
import { InstrumentDescriptor } from './InstrumentDescriptor';

@@ -11,32 +9,32 @@ import { ObservableRegistry } from './state/ObservableRegistry';

constructor(_writableMetricStorage: WritableMetricStorage, _descriptor: InstrumentDescriptor);
protected _record(value: number, attributes?: metrics.MetricAttributes, context?: api.Context): void;
protected _record(value: number, attributes?: MetricAttributes, context?: Context): void;
}
/**
* The class implements {@link metrics.UpDownCounter} interface.
* The class implements {@link UpDownCounter} interface.
*/
export declare class UpDownCounterInstrument extends SyncInstrument implements metrics.UpDownCounter {
export declare class UpDownCounterInstrument extends SyncInstrument implements UpDownCounter {
/**
* Increment value of counter by the input. Inputs may be negative.
*/
add(value: number, attributes?: metrics.MetricAttributes, ctx?: api.Context): void;
add(value: number, attributes?: MetricAttributes, ctx?: Context): void;
}
/**
* The class implements {@link metrics.Counter} interface.
* The class implements {@link Counter} interface.
*/
export declare class CounterInstrument extends SyncInstrument implements metrics.Counter {
export declare class CounterInstrument extends SyncInstrument implements Counter {
/**
* Increment value of counter by the input. Inputs may not be negative.
*/
add(value: number, attributes?: metrics.MetricAttributes, ctx?: api.Context): void;
add(value: number, attributes?: MetricAttributes, ctx?: Context): void;
}
/**
* The class implements {@link metrics.Histogram} interface.
* The class implements {@link Histogram} interface.
*/
export declare class HistogramInstrument extends SyncInstrument implements metrics.Histogram {
export declare class HistogramInstrument extends SyncInstrument implements Histogram {
/**
* Records a measurement. Value of the measurement must not be negative.
*/
record(value: number, attributes?: metrics.MetricAttributes, ctx?: api.Context): void;
record(value: number, attributes?: MetricAttributes, ctx?: Context): void;
}
export declare class ObservableInstrument implements metrics.Observable {
export declare class ObservableInstrument implements Observable {
private _observableRegistry;

@@ -49,17 +47,17 @@ /** @internal */

/**
* @see {metrics.Observable.addCallback}
* @see {Observable.addCallback}
*/
addCallback(callback: ObservableCallback): void;
/**
* @see {metrics.Observable.removeCallback}
* @see {Observable.removeCallback}
*/
removeCallback(callback: ObservableCallback): void;
}
export declare class ObservableCounterInstrument extends ObservableInstrument implements metrics.ObservableCounter {
export declare class ObservableCounterInstrument extends ObservableInstrument implements ObservableCounter {
}
export declare class ObservableGaugeInstrument extends ObservableInstrument implements metrics.ObservableGauge {
export declare class ObservableGaugeInstrument extends ObservableInstrument implements ObservableGauge {
}
export declare class ObservableUpDownCounterInstrument extends ObservableInstrument implements metrics.ObservableUpDownCounter {
export declare class ObservableUpDownCounterInstrument extends ObservableInstrument implements ObservableUpDownCounter {
}
export declare function isObservableInstrument(it: unknown): it is ObservableInstrument;
//# sourceMappingURL=Instruments.d.ts.map

23

build/esnext/Instruments.js

@@ -16,4 +16,3 @@ /*

*/
import * as api from '@opentelemetry/api';
import * as metrics from '@opentelemetry/api-metrics';
import { context as contextApi, diag, ValueType, } from '@opentelemetry/api';
import { hrTime } from '@opentelemetry/core';

@@ -25,5 +24,5 @@ export class SyncInstrument {

}
_record(value, attributes = {}, context = api.context.active()) {
if (this._descriptor.valueType === metrics.ValueType.INT && !Number.isInteger(value)) {
api.diag.warn(`INT value type cannot accept a floating-point value for ${this._descriptor.name}, ignoring the fractional digits.`);
_record(value, attributes = {}, context = contextApi.active()) {
if (this._descriptor.valueType === ValueType.INT && !Number.isInteger(value)) {
diag.warn(`INT value type cannot accept a floating-point value for ${this._descriptor.name}, ignoring the fractional digits.`);
value = Math.trunc(value);

@@ -35,3 +34,3 @@ }

/**
* The class implements {@link metrics.UpDownCounter} interface.
* The class implements {@link UpDownCounter} interface.
*/

@@ -47,3 +46,3 @@ export class UpDownCounterInstrument extends SyncInstrument {

/**
* The class implements {@link metrics.Counter} interface.
* The class implements {@link Counter} interface.
*/

@@ -56,3 +55,3 @@ export class CounterInstrument extends SyncInstrument {

if (value < 0) {
api.diag.warn(`negative value provided to counter ${this._descriptor.name}: ${value}`);
diag.warn(`negative value provided to counter ${this._descriptor.name}: ${value}`);
return;

@@ -64,3 +63,3 @@ }

/**
* The class implements {@link metrics.Histogram} interface.
* The class implements {@link Histogram} interface.
*/

@@ -73,3 +72,3 @@ export class HistogramInstrument extends SyncInstrument {

if (value < 0) {
api.diag.warn(`negative value provided to histogram ${this._descriptor.name}: ${value}`);
diag.warn(`negative value provided to histogram ${this._descriptor.name}: ${value}`);
return;

@@ -87,3 +86,3 @@ }

/**
* @see {metrics.Observable.addCallback}
* @see {Observable.addCallback}
*/

@@ -94,3 +93,3 @@ addCallback(callback) {

/**
* @see {metrics.Observable.removeCallback}
* @see {Observable.removeCallback}
*/

@@ -97,0 +96,0 @@ removeCallback(callback) {

38

build/esnext/Meter.d.ts

@@ -1,42 +0,42 @@

import * as metrics from '@opentelemetry/api-metrics';
import { Meter as IMeter, MetricOptions, Histogram, Counter, UpDownCounter, ObservableGauge, ObservableCounter, ObservableUpDownCounter, BatchObservableCallback, Observable } from '@opentelemetry/api';
import { MeterSharedState } from './state/MeterSharedState';
/**
* This class implements the {@link metrics.Meter} interface.
* This class implements the {@link IMeter} interface.
*/
export declare class Meter implements metrics.Meter {
export declare class Meter implements IMeter {
private _meterSharedState;
constructor(_meterSharedState: MeterSharedState);
/**
* Create a {@link metrics.Histogram} instrument.
* Create a {@link Histogram} instrument.
*/
createHistogram(name: string, options?: metrics.MetricOptions): metrics.Histogram;
createHistogram(name: string, options?: MetricOptions): Histogram;
/**
* Create a {@link metrics.Counter} instrument.
* Create a {@link Counter} instrument.
*/
createCounter(name: string, options?: metrics.MetricOptions): metrics.Counter;
createCounter(name: string, options?: MetricOptions): Counter;
/**
* Create a {@link metrics.UpDownCounter} instrument.
* Create a {@link UpDownCounter} instrument.
*/
createUpDownCounter(name: string, options?: metrics.MetricOptions): metrics.UpDownCounter;
createUpDownCounter(name: string, options?: MetricOptions): UpDownCounter;
/**
* Create a {@link metrics.ObservableGauge} instrument.
* Create a {@link ObservableGauge} instrument.
*/
createObservableGauge(name: string, options?: metrics.MetricOptions): metrics.ObservableGauge;
createObservableGauge(name: string, options?: MetricOptions): ObservableGauge;
/**
* Create a {@link metrics.ObservableCounter} instrument.
* Create a {@link ObservableCounter} instrument.
*/
createObservableCounter(name: string, options?: metrics.MetricOptions): metrics.ObservableCounter;
createObservableCounter(name: string, options?: MetricOptions): ObservableCounter;
/**
* Create a {@link metrics.ObservableUpDownCounter} instrument.
* Create a {@link ObservableUpDownCounter} instrument.
*/
createObservableUpDownCounter(name: string, options?: metrics.MetricOptions): metrics.ObservableUpDownCounter;
createObservableUpDownCounter(name: string, options?: MetricOptions): ObservableUpDownCounter;
/**
* @see {@link metrics.Meter.addBatchObservableCallback}
* @see {@link Meter.addBatchObservableCallback}
*/
addBatchObservableCallback(callback: metrics.BatchObservableCallback, observables: metrics.Observable[]): void;
addBatchObservableCallback(callback: BatchObservableCallback, observables: Observable[]): void;
/**
* @see {@link metrics.Meter.removeBatchObservableCallback}
* @see {@link Meter.removeBatchObservableCallback}
*/
removeBatchObservableCallback(callback: metrics.BatchObservableCallback, observables: metrics.Observable[]): void;
removeBatchObservableCallback(callback: BatchObservableCallback, observables: Observable[]): void;
}
//# sourceMappingURL=Meter.d.ts.map

18

build/esnext/Meter.js

@@ -19,3 +19,3 @@ /*

/**
* This class implements the {@link metrics.Meter} interface.
* This class implements the {@link IMeter} interface.
*/

@@ -27,3 +27,3 @@ export class Meter {

/**
* Create a {@link metrics.Histogram} instrument.
* Create a {@link Histogram} instrument.
*/

@@ -36,3 +36,3 @@ createHistogram(name, options) {

/**
* Create a {@link metrics.Counter} instrument.
* Create a {@link Counter} instrument.
*/

@@ -45,3 +45,3 @@ createCounter(name, options) {

/**
* Create a {@link metrics.UpDownCounter} instrument.
* Create a {@link UpDownCounter} instrument.
*/

@@ -54,3 +54,3 @@ createUpDownCounter(name, options) {

/**
* Create a {@link metrics.ObservableGauge} instrument.
* Create a {@link ObservableGauge} instrument.
*/

@@ -63,3 +63,3 @@ createObservableGauge(name, options) {

/**
* Create a {@link metrics.ObservableCounter} instrument.
* Create a {@link ObservableCounter} instrument.
*/

@@ -72,3 +72,3 @@ createObservableCounter(name, options) {

/**
* Create a {@link metrics.ObservableUpDownCounter} instrument.
* Create a {@link ObservableUpDownCounter} instrument.
*/

@@ -81,3 +81,3 @@ createObservableUpDownCounter(name, options) {

/**
* @see {@link metrics.Meter.addBatchObservableCallback}
* @see {@link Meter.addBatchObservableCallback}
*/

@@ -88,3 +88,3 @@ addBatchObservableCallback(callback, observables) {

/**
* @see {@link metrics.Meter.removeBatchObservableCallback}
* @see {@link Meter.removeBatchObservableCallback}
*/

@@ -91,0 +91,0 @@ removeBatchObservableCallback(callback, observables) {

8

build/esnext/MeterProvider.d.ts

@@ -1,2 +0,2 @@

import * as metrics from '@opentelemetry/api-metrics';
import { MeterProvider as IMeterProvider, Meter as IMeter, MeterOptions } from '@opentelemetry/api';
import { Resource } from '@opentelemetry/resources';

@@ -15,5 +15,5 @@ import { MetricReader } from './export/MetricReader';

/**
* This class implements the {@link metrics.MeterProvider} interface.
* This class implements the {@link MeterProvider} interface.
*/
export declare class MeterProvider implements metrics.MeterProvider {
export declare class MeterProvider implements IMeterProvider {
private _sharedState;

@@ -25,3 +25,3 @@ private _shutdown;

*/
getMeter(name: string, version?: string, options?: metrics.MeterOptions): metrics.Meter;
getMeter(name: string, version?: string, options?: MeterOptions): IMeter;
/**

@@ -28,0 +28,0 @@ * Register a {@link MetricReader} to the meter provider. After the

13

build/esnext/MeterProvider.js

@@ -16,4 +16,3 @@ /*

*/
import * as api from '@opentelemetry/api';
import * as metrics from '@opentelemetry/api-metrics';
import { diag, createNoopMeter, } from '@opentelemetry/api';
import { Resource } from '@opentelemetry/resources';

@@ -23,3 +22,3 @@ import { MeterProviderSharedState } from './state/MeterProviderSharedState';

/**
* This class implements the {@link metrics.MeterProvider} interface.
* This class implements the {@link MeterProvider} interface.
*/

@@ -43,4 +42,4 @@ export class MeterProvider {

if (this._shutdown) {
api.diag.warn('A shutdown MeterProvider cannot provide a Meter');
return metrics.createNoopMeter();
diag.warn('A shutdown MeterProvider cannot provide a Meter');
return createNoopMeter();
}

@@ -70,3 +69,3 @@ return this._sharedState

if (this._shutdown) {
api.diag.warn('shutdown may only be called once per MeterProvider');
diag.warn('shutdown may only be called once per MeterProvider');
return;

@@ -87,3 +86,3 @@ }

if (this._shutdown) {
api.diag.warn('invalid attempt to force flush after MeterProvider shutdown');
diag.warn('invalid attempt to force flush after MeterProvider shutdown');
return;

@@ -90,0 +89,0 @@ }

14

build/esnext/ObservableResult.d.ts

@@ -1,2 +0,2 @@

import * as metrics from '@opentelemetry/api-metrics';
import { ObservableResult, MetricAttributes, BatchObservableResult, Observable } from '@opentelemetry/api';
import { AttributeHashMap } from './state/HashMap';

@@ -6,5 +6,5 @@ import { ObservableInstrument } from './Instruments';

/**
* The class implements {@link metrics.ObservableResult} interface.
* The class implements {@link ObservableResult} interface.
*/
export declare class ObservableResultImpl implements metrics.ObservableResult {
export declare class ObservableResultImpl implements ObservableResult {
private _descriptor;

@@ -19,8 +19,8 @@ /**

*/
observe(value: number, attributes?: metrics.MetricAttributes): void;
observe(value: number, attributes?: MetricAttributes): void;
}
/**
* The class implements {@link metrics.BatchObservableCallback} interface.
* The class implements {@link BatchObservableCallback} interface.
*/
export declare class BatchObservableResultImpl implements metrics.BatchObservableResult {
export declare class BatchObservableResultImpl implements BatchObservableResult {
/**

@@ -33,4 +33,4 @@ * @internal

*/
observe(metric: metrics.Observable, value: number, attributes?: metrics.MetricAttributes): void;
observe(metric: Observable, value: number, attributes?: MetricAttributes): void;
}
//# sourceMappingURL=ObservableResult.d.ts.map

15

build/esnext/ObservableResult.js

@@ -16,8 +16,7 @@ /*

*/
import * as api from '@opentelemetry/api';
import * as metrics from '@opentelemetry/api-metrics';
import { diag, ValueType, } from '@opentelemetry/api';
import { AttributeHashMap } from './state/HashMap';
import { isObservableInstrument } from './Instruments';
/**
* The class implements {@link metrics.ObservableResult} interface.
* The class implements {@link ObservableResult} interface.
*/

@@ -36,4 +35,4 @@ export class ObservableResultImpl {

observe(value, attributes = {}) {
if (this._descriptor.valueType === metrics.ValueType.INT && !Number.isInteger(value)) {
api.diag.warn(`INT value type cannot accept a floating-point value for ${this._descriptor.name}, ignoring the fractional digits.`);
if (this._descriptor.valueType === ValueType.INT && !Number.isInteger(value)) {
diag.warn(`INT value type cannot accept a floating-point value for ${this._descriptor.name}, ignoring the fractional digits.`);
value = Math.trunc(value);

@@ -45,3 +44,3 @@ }

/**
* The class implements {@link metrics.BatchObservableCallback} interface.
* The class implements {@link BatchObservableCallback} interface.
*/

@@ -67,4 +66,4 @@ export class BatchObservableResultImpl {

}
if (metric._descriptor.valueType === metrics.ValueType.INT && !Number.isInteger(value)) {
api.diag.warn(`INT value type cannot accept a floating-point value for ${metric._descriptor.name}, ignoring the fractional digits.`);
if (metric._descriptor.valueType === ValueType.INT && !Number.isInteger(value)) {
diag.warn(`INT value type cannot accept a floating-point value for ${metric._descriptor.name}, ignoring the fractional digits.`);
value = Math.trunc(value);

@@ -71,0 +70,0 @@ }

3

build/esnext/state/DeltaMetricProcessor.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { Maybe } from '../utils';

@@ -4,0 +3,0 @@ import { Accumulation, Aggregator } from '../aggregator/types';

2

build/esnext/state/HashMap.d.ts

@@ -1,2 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { MetricAttributes } from '@opentelemetry/api';
export interface Hash<ValueType, HashCodeType> {

@@ -3,0 +3,0 @@ (value: ValueType): HashCodeType;

3

build/esnext/state/MultiWritableMetricStorage.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { WritableMetricStorage } from './WritableMetricStorage';

@@ -4,0 +3,0 @@ /**

3

build/esnext/state/ObservableRegistry.d.ts

@@ -1,3 +0,2 @@

import { HrTime } from '@opentelemetry/api';
import { BatchObservableCallback, Observable, ObservableCallback } from '@opentelemetry/api-metrics';
import { HrTime, BatchObservableCallback, Observable, ObservableCallback } from '@opentelemetry/api';
import { ObservableInstrument } from '../Instruments';

@@ -4,0 +3,0 @@ /**

4

build/esnext/state/ObservableRegistry.js

@@ -16,3 +16,3 @@ /*

*/
import * as api from '@opentelemetry/api';
import { diag } from '@opentelemetry/api';
import { isObservableInstrument } from '../Instruments';

@@ -50,3 +50,3 @@ import { BatchObservableResultImpl, ObservableResultImpl } from '../ObservableResult';

if (observableInstruments.size === 0) {
api.diag.error('BatchObservableCallback is not associated with valid instruments', instruments);
diag.error('BatchObservableCallback is not associated with valid instruments', instruments);
return;

@@ -53,0 +53,0 @@ }

3

build/esnext/state/SyncMetricStorage.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { WritableMetricStorage } from './WritableMetricStorage';

@@ -4,0 +3,0 @@ import { Accumulation, Aggregator } from '../aggregator/types';

3

build/esnext/state/WritableMetricStorage.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { AttributeHashMap } from './HashMap';

@@ -4,0 +3,0 @@ /**

2

build/esnext/utils.d.ts

@@ -1,2 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { MetricAttributes } from '@opentelemetry/api';
import { InstrumentationScope } from '@opentelemetry/core';

@@ -3,0 +3,0 @@ export declare type Maybe<T> = T | undefined;

2

build/esnext/version.d.ts

@@ -1,2 +0,2 @@

export declare const VERSION = "0.33.0";
export declare const VERSION = "1.8.0";
//# sourceMappingURL=version.d.ts.map

2

build/esnext/version.js

@@ -17,3 +17,3 @@ /*

// this is autogenerated file, see scripts/version-update.js
export const VERSION = '0.33.0';
export const VERSION = '1.8.0';
//# sourceMappingURL=version.js.map

3

build/esnext/view/AttributesProcessor.d.ts

@@ -1,3 +0,2 @@

import { Context } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, MetricAttributes } from '@opentelemetry/api';
/**

@@ -4,0 +3,0 @@ * The {@link AttributesProcessor} is responsible for customizing which

3

build/src/aggregator/types.d.ts

@@ -1,3 +0,2 @@

import { HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { HrTime, MetricAttributes } from '@opentelemetry/api';
import { AggregationTemporality } from '../export/AggregationTemporality';

@@ -4,0 +3,0 @@ import { MetricData } from '../export/MetricData';

3

build/src/exemplar/AlignedHistogramBucketExemplarReservoir.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { FixedSizeExemplarReservoirBase } from './ExemplarReservoir';

@@ -4,0 +3,0 @@ /**

3

build/src/exemplar/AlwaysSampleExemplarFilter.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { ExemplarFilter } from './ExemplarFilter';

@@ -4,0 +3,0 @@ export declare class AlwaysSampleExemplarFilter implements ExemplarFilter {

3

build/src/exemplar/Exemplar.d.ts

@@ -1,3 +0,2 @@

import { HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { HrTime, MetricAttributes } from '@opentelemetry/api';
/**

@@ -4,0 +3,0 @@ * A representation of an exemplar, which is a sample input measurement.

3

build/src/exemplar/ExemplarFilter.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
/**

@@ -4,0 +3,0 @@ * This interface represents a ExemplarFilter. Exemplar filters are

3

build/src/exemplar/ExemplarReservoir.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { Exemplar } from './Exemplar';

@@ -4,0 +3,0 @@ /**

3

build/src/exemplar/NeverSampleExemplarFilter.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { ExemplarFilter } from './ExemplarFilter';

@@ -4,0 +3,0 @@ export declare class NeverSampleExemplarFilter implements ExemplarFilter {

3

build/src/exemplar/SimpleFixedSizeExemplarReservoir.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { FixedSizeExemplarReservoirBase } from './ExemplarReservoir';

@@ -4,0 +3,0 @@ /**

3

build/src/exemplar/WithTraceExemplarFilter.d.ts

@@ -1,3 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime } from '@opentelemetry/api';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { ExemplarFilter } from './ExemplarFilter';

@@ -4,0 +3,0 @@ export declare class WithTraceExemplarFilter implements ExemplarFilter {

3

build/src/export/MetricData.d.ts

@@ -1,3 +0,2 @@

import { HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { HrTime, MetricAttributes } from '@opentelemetry/api';
import { InstrumentationScope } from '@opentelemetry/core';

@@ -4,0 +3,0 @@ import { Resource } from '@opentelemetry/resources';

15

build/src/export/PeriodicExportingMetricReader.js

@@ -54,13 +54,6 @@ "use strict";

}
return new Promise((resolve, reject) => {
this._exporter.export(resourceMetrics, result => {
var _a;
if (result.code !== core_1.ExportResultCode.SUCCESS) {
reject((_a = result.error) !== null && _a !== void 0 ? _a : new Error(`PeriodicExportingMetricReader: metrics export failed (error ${result.error})`));
}
else {
resolve();
}
});
});
const result = await core_1.internal._export(this._exporter, resourceMetrics);
if (result.code !== core_1.ExportResultCode.SUCCESS) {
throw new Error(`PeriodicExportingMetricReader: metrics export failed (error ${result.error})`);
}
}

@@ -67,0 +60,0 @@ onInitialized() {

2

build/src/InstrumentDescriptor.d.ts

@@ -1,2 +0,2 @@

import { MetricOptions, ValueType } from '@opentelemetry/api-metrics';
import { MetricOptions, ValueType } from '@opentelemetry/api';
import { View } from './view/View';

@@ -3,0 +3,0 @@ /**

4

build/src/InstrumentDescriptor.js

@@ -19,3 +19,3 @@ "use strict";

exports.isDescriptorCompatibleWith = exports.createInstrumentDescriptorWithView = exports.createInstrumentDescriptor = exports.InstrumentType = void 0;
const api_metrics_1 = require("@opentelemetry/api-metrics");
const api_1 = require("@opentelemetry/api");
/**

@@ -40,3 +40,3 @@ * Supported types of metric instruments.

unit: (_b = options === null || options === void 0 ? void 0 : options.unit) !== null && _b !== void 0 ? _b : '',
valueType: (_c = options === null || options === void 0 ? void 0 : options.valueType) !== null && _c !== void 0 ? _c : api_metrics_1.ValueType.DOUBLE,
valueType: (_c = options === null || options === void 0 ? void 0 : options.valueType) !== null && _c !== void 0 ? _c : api_1.ValueType.DOUBLE,
};

@@ -43,0 +43,0 @@ }

36

build/src/Instruments.d.ts

@@ -1,4 +0,2 @@

import * as api from '@opentelemetry/api';
import * as metrics from '@opentelemetry/api-metrics';
import { ObservableCallback } from '@opentelemetry/api-metrics';
import { Context, MetricAttributes, UpDownCounter, Counter, Histogram, Observable, ObservableCallback, ObservableCounter, ObservableGauge, ObservableUpDownCounter } from '@opentelemetry/api';
import { InstrumentDescriptor } from './InstrumentDescriptor';

@@ -11,32 +9,32 @@ import { ObservableRegistry } from './state/ObservableRegistry';

constructor(_writableMetricStorage: WritableMetricStorage, _descriptor: InstrumentDescriptor);
protected _record(value: number, attributes?: metrics.MetricAttributes, context?: api.Context): void;
protected _record(value: number, attributes?: MetricAttributes, context?: Context): void;
}
/**
* The class implements {@link metrics.UpDownCounter} interface.
* The class implements {@link UpDownCounter} interface.
*/
export declare class UpDownCounterInstrument extends SyncInstrument implements metrics.UpDownCounter {
export declare class UpDownCounterInstrument extends SyncInstrument implements UpDownCounter {
/**
* Increment value of counter by the input. Inputs may be negative.
*/
add(value: number, attributes?: metrics.MetricAttributes, ctx?: api.Context): void;
add(value: number, attributes?: MetricAttributes, ctx?: Context): void;
}
/**
* The class implements {@link metrics.Counter} interface.
* The class implements {@link Counter} interface.
*/
export declare class CounterInstrument extends SyncInstrument implements metrics.Counter {
export declare class CounterInstrument extends SyncInstrument implements Counter {
/**
* Increment value of counter by the input. Inputs may not be negative.
*/
add(value: number, attributes?: metrics.MetricAttributes, ctx?: api.Context): void;
add(value: number, attributes?: MetricAttributes, ctx?: Context): void;
}
/**
* The class implements {@link metrics.Histogram} interface.
* The class implements {@link Histogram} interface.
*/
export declare class HistogramInstrument extends SyncInstrument implements metrics.Histogram {
export declare class HistogramInstrument extends SyncInstrument implements Histogram {
/**
* Records a measurement. Value of the measurement must not be negative.
*/
record(value: number, attributes?: metrics.MetricAttributes, ctx?: api.Context): void;
record(value: number, attributes?: MetricAttributes, ctx?: Context): void;
}
export declare class ObservableInstrument implements metrics.Observable {
export declare class ObservableInstrument implements Observable {
private _observableRegistry;

@@ -49,17 +47,17 @@ /** @internal */

/**
* @see {metrics.Observable.addCallback}
* @see {Observable.addCallback}
*/
addCallback(callback: ObservableCallback): void;
/**
* @see {metrics.Observable.removeCallback}
* @see {Observable.removeCallback}
*/
removeCallback(callback: ObservableCallback): void;
}
export declare class ObservableCounterInstrument extends ObservableInstrument implements metrics.ObservableCounter {
export declare class ObservableCounterInstrument extends ObservableInstrument implements ObservableCounter {
}
export declare class ObservableGaugeInstrument extends ObservableInstrument implements metrics.ObservableGauge {
export declare class ObservableGaugeInstrument extends ObservableInstrument implements ObservableGauge {
}
export declare class ObservableUpDownCounterInstrument extends ObservableInstrument implements metrics.ObservableUpDownCounter {
export declare class ObservableUpDownCounterInstrument extends ObservableInstrument implements ObservableUpDownCounter {
}
export declare function isObservableInstrument(it: unknown): it is ObservableInstrument;
//# sourceMappingURL=Instruments.d.ts.map

23

build/src/Instruments.js

@@ -19,4 +19,3 @@ "use strict";

exports.isObservableInstrument = exports.ObservableUpDownCounterInstrument = exports.ObservableGaugeInstrument = exports.ObservableCounterInstrument = exports.ObservableInstrument = exports.HistogramInstrument = exports.CounterInstrument = exports.UpDownCounterInstrument = exports.SyncInstrument = void 0;
const api = require("@opentelemetry/api");
const metrics = require("@opentelemetry/api-metrics");
const api_1 = require("@opentelemetry/api");
const core_1 = require("@opentelemetry/core");

@@ -28,5 +27,5 @@ class SyncInstrument {

}
_record(value, attributes = {}, context = api.context.active()) {
if (this._descriptor.valueType === metrics.ValueType.INT && !Number.isInteger(value)) {
api.diag.warn(`INT value type cannot accept a floating-point value for ${this._descriptor.name}, ignoring the fractional digits.`);
_record(value, attributes = {}, context = api_1.context.active()) {
if (this._descriptor.valueType === api_1.ValueType.INT && !Number.isInteger(value)) {
api_1.diag.warn(`INT value type cannot accept a floating-point value for ${this._descriptor.name}, ignoring the fractional digits.`);
value = Math.trunc(value);

@@ -39,3 +38,3 @@ }

/**
* The class implements {@link metrics.UpDownCounter} interface.
* The class implements {@link UpDownCounter} interface.
*/

@@ -52,3 +51,3 @@ class UpDownCounterInstrument extends SyncInstrument {

/**
* The class implements {@link metrics.Counter} interface.
* The class implements {@link Counter} interface.
*/

@@ -61,3 +60,3 @@ class CounterInstrument extends SyncInstrument {

if (value < 0) {
api.diag.warn(`negative value provided to counter ${this._descriptor.name}: ${value}`);
api_1.diag.warn(`negative value provided to counter ${this._descriptor.name}: ${value}`);
return;

@@ -70,3 +69,3 @@ }

/**
* The class implements {@link metrics.Histogram} interface.
* The class implements {@link Histogram} interface.
*/

@@ -79,3 +78,3 @@ class HistogramInstrument extends SyncInstrument {

if (value < 0) {
api.diag.warn(`negative value provided to histogram ${this._descriptor.name}: ${value}`);
api_1.diag.warn(`negative value provided to histogram ${this._descriptor.name}: ${value}`);
return;

@@ -94,3 +93,3 @@ }

/**
* @see {metrics.Observable.addCallback}
* @see {Observable.addCallback}
*/

@@ -101,3 +100,3 @@ addCallback(callback) {

/**
* @see {metrics.Observable.removeCallback}
* @see {Observable.removeCallback}
*/

@@ -104,0 +103,0 @@ removeCallback(callback) {

38

build/src/Meter.d.ts

@@ -1,42 +0,42 @@

import * as metrics from '@opentelemetry/api-metrics';
import { Meter as IMeter, MetricOptions, Histogram, Counter, UpDownCounter, ObservableGauge, ObservableCounter, ObservableUpDownCounter, BatchObservableCallback, Observable } from '@opentelemetry/api';
import { MeterSharedState } from './state/MeterSharedState';
/**
* This class implements the {@link metrics.Meter} interface.
* This class implements the {@link IMeter} interface.
*/
export declare class Meter implements metrics.Meter {
export declare class Meter implements IMeter {
private _meterSharedState;
constructor(_meterSharedState: MeterSharedState);
/**
* Create a {@link metrics.Histogram} instrument.
* Create a {@link Histogram} instrument.
*/
createHistogram(name: string, options?: metrics.MetricOptions): metrics.Histogram;
createHistogram(name: string, options?: MetricOptions): Histogram;
/**
* Create a {@link metrics.Counter} instrument.
* Create a {@link Counter} instrument.
*/
createCounter(name: string, options?: metrics.MetricOptions): metrics.Counter;
createCounter(name: string, options?: MetricOptions): Counter;
/**
* Create a {@link metrics.UpDownCounter} instrument.
* Create a {@link UpDownCounter} instrument.
*/
createUpDownCounter(name: string, options?: metrics.MetricOptions): metrics.UpDownCounter;
createUpDownCounter(name: string, options?: MetricOptions): UpDownCounter;
/**
* Create a {@link metrics.ObservableGauge} instrument.
* Create a {@link ObservableGauge} instrument.
*/
createObservableGauge(name: string, options?: metrics.MetricOptions): metrics.ObservableGauge;
createObservableGauge(name: string, options?: MetricOptions): ObservableGauge;
/**
* Create a {@link metrics.ObservableCounter} instrument.
* Create a {@link ObservableCounter} instrument.
*/
createObservableCounter(name: string, options?: metrics.MetricOptions): metrics.ObservableCounter;
createObservableCounter(name: string, options?: MetricOptions): ObservableCounter;
/**
* Create a {@link metrics.ObservableUpDownCounter} instrument.
* Create a {@link ObservableUpDownCounter} instrument.
*/
createObservableUpDownCounter(name: string, options?: metrics.MetricOptions): metrics.ObservableUpDownCounter;
createObservableUpDownCounter(name: string, options?: MetricOptions): ObservableUpDownCounter;
/**
* @see {@link metrics.Meter.addBatchObservableCallback}
* @see {@link Meter.addBatchObservableCallback}
*/
addBatchObservableCallback(callback: metrics.BatchObservableCallback, observables: metrics.Observable[]): void;
addBatchObservableCallback(callback: BatchObservableCallback, observables: Observable[]): void;
/**
* @see {@link metrics.Meter.removeBatchObservableCallback}
* @see {@link Meter.removeBatchObservableCallback}
*/
removeBatchObservableCallback(callback: metrics.BatchObservableCallback, observables: metrics.Observable[]): void;
removeBatchObservableCallback(callback: BatchObservableCallback, observables: Observable[]): void;
}
//# sourceMappingURL=Meter.d.ts.map

18

build/src/Meter.js

@@ -22,3 +22,3 @@ "use strict";

/**
* This class implements the {@link metrics.Meter} interface.
* This class implements the {@link IMeter} interface.
*/

@@ -30,3 +30,3 @@ class Meter {

/**
* Create a {@link metrics.Histogram} instrument.
* Create a {@link Histogram} instrument.
*/

@@ -39,3 +39,3 @@ createHistogram(name, options) {

/**
* Create a {@link metrics.Counter} instrument.
* Create a {@link Counter} instrument.
*/

@@ -48,3 +48,3 @@ createCounter(name, options) {

/**
* Create a {@link metrics.UpDownCounter} instrument.
* Create a {@link UpDownCounter} instrument.
*/

@@ -57,3 +57,3 @@ createUpDownCounter(name, options) {

/**
* Create a {@link metrics.ObservableGauge} instrument.
* Create a {@link ObservableGauge} instrument.
*/

@@ -66,3 +66,3 @@ createObservableGauge(name, options) {

/**
* Create a {@link metrics.ObservableCounter} instrument.
* Create a {@link ObservableCounter} instrument.
*/

@@ -75,3 +75,3 @@ createObservableCounter(name, options) {

/**
* Create a {@link metrics.ObservableUpDownCounter} instrument.
* Create a {@link ObservableUpDownCounter} instrument.
*/

@@ -84,3 +84,3 @@ createObservableUpDownCounter(name, options) {

/**
* @see {@link metrics.Meter.addBatchObservableCallback}
* @see {@link Meter.addBatchObservableCallback}
*/

@@ -91,3 +91,3 @@ addBatchObservableCallback(callback, observables) {

/**
* @see {@link metrics.Meter.removeBatchObservableCallback}
* @see {@link Meter.removeBatchObservableCallback}
*/

@@ -94,0 +94,0 @@ removeBatchObservableCallback(callback, observables) {

8

build/src/MeterProvider.d.ts

@@ -1,2 +0,2 @@

import * as metrics from '@opentelemetry/api-metrics';
import { MeterProvider as IMeterProvider, Meter as IMeter, MeterOptions } from '@opentelemetry/api';
import { Resource } from '@opentelemetry/resources';

@@ -15,5 +15,5 @@ import { MetricReader } from './export/MetricReader';

/**
* This class implements the {@link metrics.MeterProvider} interface.
* This class implements the {@link MeterProvider} interface.
*/
export declare class MeterProvider implements metrics.MeterProvider {
export declare class MeterProvider implements IMeterProvider {
private _sharedState;

@@ -25,3 +25,3 @@ private _shutdown;

*/
getMeter(name: string, version?: string, options?: metrics.MeterOptions): metrics.Meter;
getMeter(name: string, version?: string, options?: MeterOptions): IMeter;
/**

@@ -28,0 +28,0 @@ * Register a {@link MetricReader} to the meter provider. After the

13

build/src/MeterProvider.js

@@ -19,4 +19,3 @@ "use strict";

exports.MeterProvider = void 0;
const api = require("@opentelemetry/api");
const metrics = require("@opentelemetry/api-metrics");
const api_1 = require("@opentelemetry/api");
const resources_1 = require("@opentelemetry/resources");

@@ -26,3 +25,3 @@ const MeterProviderSharedState_1 = require("./state/MeterProviderSharedState");

/**
* This class implements the {@link metrics.MeterProvider} interface.
* This class implements the {@link MeterProvider} interface.
*/

@@ -46,4 +45,4 @@ class MeterProvider {

if (this._shutdown) {
api.diag.warn('A shutdown MeterProvider cannot provide a Meter');
return metrics.createNoopMeter();
api_1.diag.warn('A shutdown MeterProvider cannot provide a Meter');
return (0, api_1.createNoopMeter)();
}

@@ -73,3 +72,3 @@ return this._sharedState

if (this._shutdown) {
api.diag.warn('shutdown may only be called once per MeterProvider');
api_1.diag.warn('shutdown may only be called once per MeterProvider');
return;

@@ -90,3 +89,3 @@ }

if (this._shutdown) {
api.diag.warn('invalid attempt to force flush after MeterProvider shutdown');
api_1.diag.warn('invalid attempt to force flush after MeterProvider shutdown');
return;

@@ -93,0 +92,0 @@ }

14

build/src/ObservableResult.d.ts

@@ -1,2 +0,2 @@

import * as metrics from '@opentelemetry/api-metrics';
import { ObservableResult, MetricAttributes, BatchObservableResult, Observable } from '@opentelemetry/api';
import { AttributeHashMap } from './state/HashMap';

@@ -6,5 +6,5 @@ import { ObservableInstrument } from './Instruments';

/**
* The class implements {@link metrics.ObservableResult} interface.
* The class implements {@link ObservableResult} interface.
*/
export declare class ObservableResultImpl implements metrics.ObservableResult {
export declare class ObservableResultImpl implements ObservableResult {
private _descriptor;

@@ -19,8 +19,8 @@ /**

*/
observe(value: number, attributes?: metrics.MetricAttributes): void;
observe(value: number, attributes?: MetricAttributes): void;
}
/**
* The class implements {@link metrics.BatchObservableCallback} interface.
* The class implements {@link BatchObservableCallback} interface.
*/
export declare class BatchObservableResultImpl implements metrics.BatchObservableResult {
export declare class BatchObservableResultImpl implements BatchObservableResult {
/**

@@ -33,4 +33,4 @@ * @internal

*/
observe(metric: metrics.Observable, value: number, attributes?: metrics.MetricAttributes): void;
observe(metric: Observable, value: number, attributes?: MetricAttributes): void;
}
//# sourceMappingURL=ObservableResult.d.ts.map

15

build/src/ObservableResult.js

@@ -19,8 +19,7 @@ "use strict";

exports.BatchObservableResultImpl = exports.ObservableResultImpl = void 0;
const api = require("@opentelemetry/api");
const metrics = require("@opentelemetry/api-metrics");
const api_1 = require("@opentelemetry/api");
const HashMap_1 = require("./state/HashMap");
const Instruments_1 = require("./Instruments");
/**
* The class implements {@link metrics.ObservableResult} interface.
* The class implements {@link ObservableResult} interface.
*/

@@ -39,4 +38,4 @@ class ObservableResultImpl {

observe(value, attributes = {}) {
if (this._descriptor.valueType === metrics.ValueType.INT && !Number.isInteger(value)) {
api.diag.warn(`INT value type cannot accept a floating-point value for ${this._descriptor.name}, ignoring the fractional digits.`);
if (this._descriptor.valueType === api_1.ValueType.INT && !Number.isInteger(value)) {
api_1.diag.warn(`INT value type cannot accept a floating-point value for ${this._descriptor.name}, ignoring the fractional digits.`);
value = Math.trunc(value);

@@ -49,3 +48,3 @@ }

/**
* The class implements {@link metrics.BatchObservableCallback} interface.
* The class implements {@link BatchObservableCallback} interface.
*/

@@ -71,4 +70,4 @@ class BatchObservableResultImpl {

}
if (metric._descriptor.valueType === metrics.ValueType.INT && !Number.isInteger(value)) {
api.diag.warn(`INT value type cannot accept a floating-point value for ${metric._descriptor.name}, ignoring the fractional digits.`);
if (metric._descriptor.valueType === api_1.ValueType.INT && !Number.isInteger(value)) {
api_1.diag.warn(`INT value type cannot accept a floating-point value for ${metric._descriptor.name}, ignoring the fractional digits.`);
value = Math.trunc(value);

@@ -75,0 +74,0 @@ }

3

build/src/state/DeltaMetricProcessor.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { Maybe } from '../utils';

@@ -4,0 +3,0 @@ import { Accumulation, Aggregator } from '../aggregator/types';

2

build/src/state/HashMap.d.ts

@@ -1,2 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { MetricAttributes } from '@opentelemetry/api';
export interface Hash<ValueType, HashCodeType> {

@@ -3,0 +3,0 @@ (value: ValueType): HashCodeType;

3

build/src/state/MultiWritableMetricStorage.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { WritableMetricStorage } from './WritableMetricStorage';

@@ -4,0 +3,0 @@ /**

3

build/src/state/ObservableRegistry.d.ts

@@ -1,3 +0,2 @@

import { HrTime } from '@opentelemetry/api';
import { BatchObservableCallback, Observable, ObservableCallback } from '@opentelemetry/api-metrics';
import { HrTime, BatchObservableCallback, Observable, ObservableCallback } from '@opentelemetry/api';
import { ObservableInstrument } from '../Instruments';

@@ -4,0 +3,0 @@ /**

4

build/src/state/ObservableRegistry.js

@@ -19,3 +19,3 @@ "use strict";

exports.ObservableRegistry = void 0;
const api = require("@opentelemetry/api");
const api_1 = require("@opentelemetry/api");
const Instruments_1 = require("../Instruments");

@@ -53,3 +53,3 @@ const ObservableResult_1 = require("../ObservableResult");

if (observableInstruments.size === 0) {
api.diag.error('BatchObservableCallback is not associated with valid instruments', instruments);
api_1.diag.error('BatchObservableCallback is not associated with valid instruments', instruments);
return;

@@ -56,0 +56,0 @@ }

3

build/src/state/SyncMetricStorage.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { WritableMetricStorage } from './WritableMetricStorage';

@@ -4,0 +3,0 @@ import { Accumulation, Aggregator } from '../aggregator/types';

3

build/src/state/WritableMetricStorage.d.ts

@@ -1,3 +0,2 @@

import { Context, HrTime } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, HrTime, MetricAttributes } from '@opentelemetry/api';
import { AttributeHashMap } from './HashMap';

@@ -4,0 +3,0 @@ /**

2

build/src/utils.d.ts

@@ -1,2 +0,2 @@

import { MetricAttributes } from '@opentelemetry/api-metrics';
import { MetricAttributes } from '@opentelemetry/api';
import { InstrumentationScope } from '@opentelemetry/core';

@@ -3,0 +3,0 @@ export declare type Maybe<T> = T | undefined;

2

build/src/version.d.ts

@@ -1,2 +0,2 @@

export declare const VERSION = "0.33.0";
export declare const VERSION = "1.8.0";
//# sourceMappingURL=version.d.ts.map

2

build/src/version.js

@@ -20,3 +20,3 @@ "use strict";

// this is autogenerated file, see scripts/version-update.js
exports.VERSION = '0.33.0';
exports.VERSION = '1.8.0';
//# sourceMappingURL=version.js.map

3

build/src/view/AttributesProcessor.d.ts

@@ -1,3 +0,2 @@

import { Context } from '@opentelemetry/api';
import { MetricAttributes } from '@opentelemetry/api-metrics';
import { Context, MetricAttributes } from '@opentelemetry/api';
/**

@@ -4,0 +3,0 @@ * The {@link AttributesProcessor} is responsible for customizing which

24

package.json
{
"name": "@opentelemetry/sdk-metrics",
"version": "0.33.0",
"version": "1.8.0",
"description": "Work in progress OpenTelemetry metrics SDK",

@@ -18,10 +18,10 @@ "main": "build/src/index.js",

"tdd:browser": "karma start",
"codecov": "nyc report --reporter=json && codecov -f coverage/*.json -p ../../../",
"codecov": "nyc report --reporter=json && codecov -f coverage/*.json -p ../../",
"lint": "eslint . --ext .ts",
"lint:fix": "eslint . --ext .ts --fix",
"version": "node ../../../scripts/version-update.js",
"version": "node ../../scripts/version-update.js",
"watch": "tsc --build --watch tsconfig.all.json",
"precompile": "lerna run version --scope $(npm pkg get name) --include-dependencies",
"prewatch": "node ../../../scripts/version-update.js",
"peer-api-check": "node ../../../scripts/peer-api-check.js"
"prewatch": "node ../../scripts/version-update.js",
"peer-api-check": "node ../../scripts/peer-api-check.js"
},

@@ -58,5 +58,5 @@ "keywords": [

"devDependencies": {
"@opentelemetry/api": "^1.0.0",
"@opentelemetry/api": ">=1.3.0 <1.4.0",
"@types/lodash.merge": "4.6.6",
"@types/mocha": "9.1.1",
"@types/mocha": "10.0.0",
"@types/node": "18.6.5",

@@ -79,12 +79,12 @@ "@types/sinon": "10.0.13",

"peerDependencies": {
"@opentelemetry/api": "^1.0.0"
"@opentelemetry/api": ">=1.3.0 <1.4.0"
},
"dependencies": {
"@opentelemetry/api-metrics": "0.33.0",
"@opentelemetry/core": "1.7.0",
"@opentelemetry/resources": "1.7.0",
"@opentelemetry/core": "1.8.0",
"@opentelemetry/resources": "1.8.0",
"lodash.merge": "4.6.2"
},
"homepage": "https://github.com/open-telemetry/opentelemetry-js/tree/main/experimental/packages/opentelemetry-sdk-metrics",
"gitHead": "ad88c3d9aa0100fe259b93f4b660e84417b757ac"
"sideEffects": false,
"gitHead": "7972edf6659fb6e0d5928a5cf7a35f26683e168f"
}

4

README.md

@@ -17,3 +17,3 @@ # OpenTelemetry Metrics SDK

```bash
npm install --save @opentelemetry/api-metrics
npm install --save @opentelemetry/api
npm install --save @opentelemetry/sdk-metrics

@@ -27,3 +27,3 @@ ```

```js
const opentelemetry = require('@opentelemetry/api-metrics');
const opentelemetry = require('@opentelemetry/api');
const { MeterProvider } = require('@opentelemetry/sdk-metrics');

@@ -30,0 +30,0 @@ 

build/esm/aggregator/types.js.map

Sorry, the diff of this file is not supported yet

build/esm/exemplar/AlignedHistogramBucketExemplarReservoir.js.map

Sorry, the diff of this file is not supported yet

build/esm/exemplar/AlwaysSampleExemplarFilter.js.map

Sorry, the diff of this file is not supported yet

build/esm/exemplar/Exemplar.js.map

Sorry, the diff of this file is not supported yet

build/esm/exemplar/ExemplarFilter.js.map

Sorry, the diff of this file is not supported yet

build/esm/exemplar/ExemplarReservoir.js.map

Sorry, the diff of this file is not supported yet

build/esm/exemplar/NeverSampleExemplarFilter.js.map

Sorry, the diff of this file is not supported yet

build/esm/exemplar/SimpleFixedSizeExemplarReservoir.js.map

Sorry, the diff of this file is not supported yet

build/esm/exemplar/WithTraceExemplarFilter.js.map

Sorry, the diff of this file is not supported yet

build/esm/export/MetricData.js.map

Sorry, the diff of this file is not supported yet

build/esm/export/PeriodicExportingMetricReader.js.map

Sorry, the diff of this file is not supported yet

build/esm/InstrumentDescriptor.js.map

Sorry, the diff of this file is not supported yet

build/esm/Instruments.js.map

Sorry, the diff of this file is not supported yet

build/esm/Meter.js.map

Sorry, the diff of this file is not supported yet

build/esm/MeterProvider.js.map

Sorry, the diff of this file is not supported yet

build/esm/ObservableResult.js.map

Sorry, the diff of this file is not supported yet

build/esm/state/DeltaMetricProcessor.js.map

Sorry, the diff of this file is not supported yet

build/esm/state/HashMap.js.map

Sorry, the diff of this file is not supported yet

build/esm/state/MultiWritableMetricStorage.js.map

Sorry, the diff of this file is not supported yet

build/esm/state/ObservableRegistry.js.map

Sorry, the diff of this file is not supported yet

build/esm/state/SyncMetricStorage.js.map

Sorry, the diff of this file is not supported yet

build/esm/state/WritableMetricStorage.js.map

Sorry, the diff of this file is not supported yet

build/esm/utils.js.map

Sorry, the diff of this file is not supported yet

build/esm/version.js.map

Sorry, the diff of this file is not supported yet

build/esm/view/AttributesProcessor.js.map

Sorry, the diff of this file is not supported yet

build/esnext/aggregator/types.js.map

Sorry, the diff of this file is not supported yet

build/esnext/exemplar/AlignedHistogramBucketExemplarReservoir.js.map

Sorry, the diff of this file is not supported yet

build/esnext/exemplar/AlwaysSampleExemplarFilter.js.map

Sorry, the diff of this file is not supported yet

build/esnext/exemplar/Exemplar.js.map

Sorry, the diff of this file is not supported yet

build/esnext/exemplar/ExemplarFilter.js.map

Sorry, the diff of this file is not supported yet

build/esnext/exemplar/ExemplarReservoir.js.map

Sorry, the diff of this file is not supported yet

build/esnext/exemplar/NeverSampleExemplarFilter.js.map

Sorry, the diff of this file is not supported yet

build/esnext/exemplar/SimpleFixedSizeExemplarReservoir.js.map

Sorry, the diff of this file is not supported yet

build/esnext/exemplar/WithTraceExemplarFilter.js.map

Sorry, the diff of this file is not supported yet

build/esnext/export/MetricData.js.map

Sorry, the diff of this file is not supported yet

build/esnext/export/PeriodicExportingMetricReader.js.map

Sorry, the diff of this file is not supported yet

build/esnext/InstrumentDescriptor.js.map

Sorry, the diff of this file is not supported yet

build/esnext/Instruments.js.map

Sorry, the diff of this file is not supported yet

build/esnext/Meter.js.map

Sorry, the diff of this file is not supported yet

build/esnext/MeterProvider.js.map

Sorry, the diff of this file is not supported yet

build/esnext/ObservableResult.js.map

Sorry, the diff of this file is not supported yet

build/esnext/state/DeltaMetricProcessor.js.map

Sorry, the diff of this file is not supported yet

build/esnext/state/HashMap.js.map

Sorry, the diff of this file is not supported yet

build/esnext/state/MultiWritableMetricStorage.js.map

Sorry, the diff of this file is not supported yet

build/esnext/state/ObservableRegistry.js.map

Sorry, the diff of this file is not supported yet

build/esnext/state/SyncMetricStorage.js.map

Sorry, the diff of this file is not supported yet

build/esnext/state/WritableMetricStorage.js.map

Sorry, the diff of this file is not supported yet

build/esnext/utils.js.map

Sorry, the diff of this file is not supported yet

build/esnext/version.js.map

Sorry, the diff of this file is not supported yet

build/esnext/view/AttributesProcessor.js.map

Sorry, the diff of this file is not supported yet

build/src/aggregator/types.js.map

Sorry, the diff of this file is not supported yet

build/src/exemplar/AlignedHistogramBucketExemplarReservoir.js.map

Sorry, the diff of this file is not supported yet

build/src/exemplar/AlwaysSampleExemplarFilter.js.map

Sorry, the diff of this file is not supported yet

build/src/exemplar/Exemplar.js.map

Sorry, the diff of this file is not supported yet

build/src/exemplar/ExemplarFilter.js.map

Sorry, the diff of this file is not supported yet

build/src/exemplar/ExemplarReservoir.js.map

Sorry, the diff of this file is not supported yet

build/src/exemplar/NeverSampleExemplarFilter.js.map

Sorry, the diff of this file is not supported yet

build/src/exemplar/SimpleFixedSizeExemplarReservoir.js.map

Sorry, the diff of this file is not supported yet

build/src/exemplar/WithTraceExemplarFilter.js.map

Sorry, the diff of this file is not supported yet

build/src/export/MetricData.js.map

Sorry, the diff of this file is not supported yet

build/src/export/PeriodicExportingMetricReader.js.map

Sorry, the diff of this file is not supported yet

build/src/InstrumentDescriptor.js.map

Sorry, the diff of this file is not supported yet

build/src/Instruments.js.map

Sorry, the diff of this file is not supported yet

build/src/Meter.js.map

Sorry, the diff of this file is not supported yet

build/src/MeterProvider.js.map

Sorry, the diff of this file is not supported yet

build/src/ObservableResult.js.map

Sorry, the diff of this file is not supported yet

build/src/state/DeltaMetricProcessor.js.map

Sorry, the diff of this file is not supported yet

build/src/state/HashMap.js.map

Sorry, the diff of this file is not supported yet

build/src/state/MultiWritableMetricStorage.js.map

Sorry, the diff of this file is not supported yet

build/src/state/ObservableRegistry.js.map

Sorry, the diff of this file is not supported yet

build/src/state/SyncMetricStorage.js.map

Sorry, the diff of this file is not supported yet

build/src/state/WritableMetricStorage.js.map

Sorry, the diff of this file is not supported yet

build/src/utils.js.map

Sorry, the diff of this file is not supported yet

build/src/version.js.map

Sorry, the diff of this file is not supported yet

build/src/view/AttributesProcessor.js.map

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc