syncstate

Documentation

Index

• func Observe[N number.Any, Traits number.Traits[N]](ctx context.Context, inst *Observer, num N, cfg OpConfig)
• type Observer
  • func New(desc sdkinstrument.Descriptor, performance sdkinstrument.Performance, ...) *Observer
  • func (inst *Observer) ObserveFloat64(ctx context.Context, num float64, cfg OpConfig)
  • func (inst *Observer) ObserveInt64(ctx context.Context, num int64, cfg OpConfig)
  • func (inst *Observer) SnapshotAndProcess()
• type OpConfig

Functions

func Observe

func Observe[N number.Any, Traits number.Traits[N]](ctx context.Context, inst *Observer, num N, cfg OpConfig)

Observe performs a generic update for any synchronous instrument.

Types

type Observer

type Observer struct {
	// contains filtered or unexported fields
}

Instrument maintains a mapping from attribute.Set to an internal record type for a single API-level instrument. This type is organized so that a single attribute.Set lookup is performed regardless of the number of reader and instrument-view behaviors. Entries in the map have their accumulator's SnapshotAndProcess() method called whenever they are removed from the map, which can happen when any reader collects the instrument.

func New

func New(desc sdkinstrument.Descriptor, performance sdkinstrument.Performance, _ interface{}, compiled pipeline.Register[viewstate.Instrument]) *Observer

New builds a new synchronous instrument *Observer given the per-pipeline instrument-views compiled. Note that the unused third parameter is an opaque value used in the asyncstate package, passed here to make these two packages generalize.

func (*Observer) ObserveFloat64

func (inst *Observer) ObserveFloat64(ctx context.Context, num float64, cfg OpConfig)

func (*Observer) ObserveInt64

func (inst *Observer) ObserveInt64(ctx context.Context, num int64, cfg OpConfig)

func (*Observer) SnapshotAndProcess

func (inst *Observer) SnapshotAndProcess()

SnapshotAndProcess calls SnapshotAndProcess() for all live accumulators of this instrument. Inactive accumulators will be subsequently removed from the map.

type OpConfig

type OpConfig struct {
	Attributes attribute.Set
	KeyValues  []attribute.KeyValue
}

interface conversion.