metric

Nov 8, 2024

Changes in this version

+ func DefaultExemplarReservoirProviderSelector(agg Aggregation) exemplar.ReservoirProvider

+ type ExemplarReservoirProviderSelector func(Aggregation) exemplar.ReservoirProvider

type Option

+ func WithExemplarFilter(filter exemplar.Filter) Option

type Stream

+ ExemplarReservoirProviderSelector ExemplarReservoirProviderSelector

Jul 2, 2024

Changes in this version

type Instrument

+ func (i Instrument) IsEmpty() bool

May 21, 2024

Changes in this version

type InstrumentKind

+ const InstrumentKindGauge

Aug 28, 2023

Changes in this version

+ var ErrInstrumentName = errors.New("invalid instrument name")

+ type Aggregation interface

+ type AggregationBase2ExponentialHistogram struct

+ MaxScale int32

+ MaxSize int32

+ NoMinMax bool

+ type AggregationDefault struct

+ type AggregationDrop struct

+ type AggregationExplicitBucketHistogram struct

+ Boundaries []float64

+ NoMinMax bool

+ type AggregationLastValue struct

+ type AggregationSum struct

type InstrumentKind

+ func (i InstrumentKind) String() string

+ type ManualReader struct

+ func (mr *ManualReader) Collect(ctx context.Context, rm *metricdata.ResourceMetrics) error

+ func (mr *ManualReader) Shutdown(context.Context) error

+ func (r *ManualReader) MarshalLog() interface{}

+ type PeriodicReader struct

+ func (r *PeriodicReader) Collect(ctx context.Context, rm *metricdata.ResourceMetrics) error

+ func (r *PeriodicReader) ForceFlush(ctx context.Context) error

+ func (r *PeriodicReader) MarshalLog() interface{}

+ func (r *PeriodicReader) Shutdown(ctx context.Context) error

type ReaderOption

+ func WithProducer(p Producer) ReaderOption

Jan 29, 2023

Changes in this version

type InstrumentKind

+ const InstrumentKindCounter

+ const InstrumentKindHistogram

+ const InstrumentKindObservableCounter

+ const InstrumentKindObservableGauge

+ const InstrumentKindObservableUpDownCounter

+ const InstrumentKindUpDownCounter

+ type Producer interface

+ Produce func(context.Context) ([]metricdata.ScopeMetrics, error)

type Reader

+ RegisterProducer func(Producer)

Dec 5, 2022

Changes in this version

type Exporter

+ Aggregation func(InstrumentKind) aggregation.Aggregation

+ Temporality func(InstrumentKind) metricdata.Temporality

+ type Instrument struct

+ Description string

+ Kind InstrumentKind

+ Name string

+ Scope instrumentation.Scope

+ Unit unit.Unit

+ type InstrumentKind uint8

+ const InstrumentKindAsyncCounter

+ const InstrumentKindAsyncGauge

+ const InstrumentKindAsyncUpDownCounter

+ const InstrumentKindSyncCounter

+ const InstrumentKindSyncHistogram

+ const InstrumentKindSyncUpDownCounter

type Option

+ func WithView(views ...View) Option

+ type Stream struct

+ Aggregation aggregation.Aggregation

+ AttributeFilter attribute.Filter

+ Description string

+ Name string

+ Unit unit.Unit

+ type View func(Instrument) (Stream, bool)

+ func NewView(criteria Instrument, mask Stream) View

Sep 19, 2022

Changes in this version

+ var ErrExporterShutdown = fmt.Errorf("exporter is shutdown")

+ var ErrReaderNotRegistered = fmt.Errorf("reader is not registered")

+ var ErrReaderShutdown = fmt.Errorf("reader is shutdown")

+ func DefaultAggregationSelector(ik view.InstrumentKind) aggregation.Aggregation

+ func DefaultTemporalitySelector(view.InstrumentKind) metricdata.Temporality

+ type AggregationSelector func(view.InstrumentKind) aggregation.Aggregation

+ type Exporter interface

+ Export func(context.Context, metricdata.ResourceMetrics) error

+ ForceFlush func(context.Context) error

+ Shutdown func(context.Context) error

+ type ManualReaderOption interface

+ type MeterProvider struct

+ func NewMeterProvider(options ...Option) *MeterProvider

+ func (mp *MeterProvider) ForceFlush(ctx context.Context) error

+ func (mp *MeterProvider) Meter(name string, options ...metric.MeterOption) metric.Meter

+ func (mp *MeterProvider) Shutdown(ctx context.Context) error

+ type Option interface

+ func WithReader(r Reader, views ...view.View) Option

+ func WithResource(res *resource.Resource) Option

+ type PeriodicReaderOption interface

+ func WithInterval(d time.Duration) PeriodicReaderOption

+ func WithTimeout(d time.Duration) PeriodicReaderOption

+ type Reader interface

+ Collect func(context.Context) (metricdata.ResourceMetrics, error)

+ ForceFlush func(context.Context) error

+ Shutdown func(context.Context) error

+ func NewManualReader(opts ...ManualReaderOption) Reader

+ func NewPeriodicReader(exporter Exporter, options ...PeriodicReaderOption) Reader

+ type ReaderOption interface

+ func WithAggregationSelector(selector AggregationSelector) ReaderOption

+ func WithTemporalitySelector(selector TemporalitySelector) ReaderOption

+ type TemporalitySelector func(view.InstrumentKind) metricdata.Temporality

Mar 23, 2022

Changes in this version

+ var ErrBadInstrument = fmt.Errorf("use of a instrument from another SDK")

type Accumulator

+ func (m *Accumulator) RegisterCallback(insts []instrument.Asynchronous, f func(context.Context)) error

Feb 15, 2021

Changes in this version

+ var ErrUninitializedInstrument = fmt.Errorf("use of an uninitialized instrument")

+ func AtomicFieldOffsets() map[string]uintptr

+ type Accumulator struct

+ func NewAccumulator(processor export.Processor, resource *resource.Resource) *Accumulator

+ func (m *Accumulator) Collect(ctx context.Context) int

+ func (m *Accumulator) CollectAsync(kv []label.KeyValue, obs ...metric.Observation)

+ func (m *Accumulator) NewAsyncInstrument(descriptor metric.Descriptor, runner metric.AsyncRunner) (metric.AsyncImpl, error)

+ func (m *Accumulator) NewSyncInstrument(descriptor metric.Descriptor) (metric.SyncImpl, error)

+ func (m *Accumulator) RecordBatch(ctx context.Context, kvs []label.KeyValue, measurements ...metric.Measurement)