streams

May 21, 2024

Changes in this version

+ type EvictorFunc func() (identity.Stream, bool)

+ func (ev EvictorFunc) Evict() (identity.Stream, bool)

Apr 11, 2024

Changes in this version

type ErrEvicted

+ Ident Ident

Mar 26, 2024

Changes in this version

+ func AtLimit(err error) bool

+ type ErrEvicted struct

+ func (e ErrEvicted) Error() string

+ func (e ErrEvicted) Unwrap() error

+ type ErrLimit int

+ func (e ErrLimit) Error() string

+ type Evictor = streams.Evictor

+ type LimitMap struct

+ Evictor streams.Evictor

+ Max int

+ func Limit[T any](m Map[T], max int) LimitMap[T]

+ func (m LimitMap[T]) Store(id identity.Stream, v T) error

+ type Map streams.Map[T]

+ type MapAggr struct

+ func IntoAggregator[D data.Point[D]](m Map[D]) MapAggr[D]

+ func (a MapAggr[D]) Aggregate(id Ident, dp D) (D, error)

+ type Seq streams.Seq[T]

Feb 21, 2024

Changes in this version

+ func Aggregate[D data.Point[D]](m metrics.Data[D], aggr Aggregator[D]) error

+ func Error(id Ident, err error) error

+ type Aggregator interface

+ Aggregate func(Ident, D) (D, error)

+ type Ident struct

+ func Identify(metric metrics.Ident, attrs pcommon.Map) Ident

+ func (i Ident) Hash() hash.Hash64

+ func (i Ident) Metric() metrics.Ident

+ func (i Ident) String() string

+ type Iter func(yield func(Ident, V) bool)

+ func Samples[D data.Point[D]](m metrics.Data[D]) Iter[D]

+ type StreamErr struct

+ Err error

+ Ident Ident

+ func (e StreamErr) Error() string