tracking

Documentation

Index

• Constants
• type DeltaValue
• type MetricIdentity
  • func (mi *MetricIdentity) IsFloatVal() bool
  • func (mi *MetricIdentity) IsSupportedMetricType() bool
  • func (mi *MetricIdentity) Write(b *bytes.Buffer)
• type MetricPoint
• type MetricTracker
  • func NewMetricTracker(ctx context.Context, logger *zap.Logger, maxStale time.Duration) MetricTracker
• type State
  • func (s *State) Lock()
  • func (s *State) Unlock()
• type ValuePoint

Constants

const A = int32('A')

const SEP = byte(0x1E)

const SEPSTR = string(SEP)

Types

type DeltaValue

type DeltaValue struct {
	StartTimestamp pdata.Timestamp
	FloatValue     float64
	IntValue       int64
}

type MetricIdentity

type MetricIdentity struct {
	Resource               pdata.Resource
	InstrumentationLibrary pdata.InstrumentationLibrary
	MetricDataType         pdata.MetricDataType
	MetricIsMonotonic      bool
	MetricName             string
	MetricUnit             string
	StartTimestamp         pdata.Timestamp
	Attributes             pdata.AttributeMap
	MetricValueType        pdata.MetricValueType
}

func (*MetricIdentity) IsFloatVal

func (mi *MetricIdentity) IsFloatVal() bool

func (*MetricIdentity) IsSupportedMetricType

func (mi *MetricIdentity) IsSupportedMetricType() bool

func (*MetricIdentity) Write

func (mi *MetricIdentity) Write(b *bytes.Buffer)

type MetricPoint

type MetricPoint struct {
	Identity MetricIdentity
	Value    ValuePoint
}

type MetricTracker

type MetricTracker interface {
	Convert(MetricPoint) (DeltaValue, bool)
}

func NewMetricTracker

func NewMetricTracker(ctx context.Context, logger *zap.Logger, maxStale time.Duration) MetricTracker

type State

type State struct {
	Identity  MetricIdentity
	PrevPoint ValuePoint
	// contains filtered or unexported fields
}

func (*State) Lock

func (s *State) Lock()

func (*State) Unlock

func (s *State) Unlock()

type ValuePoint

type ValuePoint struct {
	ObservedTimestamp pdata.Timestamp
	FloatValue        float64
	IntValue          int64
}