streams

Documentation

Index

• type DataPoint
• type DataPointSlice
• type Evictor
• type HashMap
  • func (m HashMap[T]) Clear()
  • func (m HashMap[T]) Delete(id identity.Stream)
  • func (m HashMap[T]) Items() func(yield func(identity.Stream, T) bool) bool
  • func (m HashMap[T]) Len() int
  • func (m HashMap[T]) Load(id identity.Stream) (T, bool)
  • func (m HashMap[T]) Store(id identity.Stream, v T) error
• type Map
• type Seq

Types

type DataPoint

type DataPoint[Self any] interface {
	Timestamp() pcommon.Timestamp
	Attributes() pcommon.Map
	CopyTo(dest Self)
}

type DataPointSlice

type DataPointSlice[DP DataPoint[DP]] interface {
	Len() int
	At(i int) DP
	AppendEmpty() DP
}

type Evictor

type Evictor interface {
	Evict() (gone identity.Stream, ok bool)
}

Evictors remove the "least important" stream based on some strategy such as the oldest, least active, etc.

Returns whether a stream was evicted and if so the now gone stream id

type HashMap

type HashMap[T any] map[identity.Stream]T

func (HashMap[T]) Clear

func (m HashMap[T]) Clear()

func (HashMap[T]) Delete

func (m HashMap[T]) Delete(id identity.Stream)

func (HashMap[T]) Items

func (m HashMap[T]) Items() func(yield func(identity.Stream, T) bool) bool

func (HashMap[T]) Len

func (m HashMap[T]) Len() int

func (HashMap[T]) Load

func (m HashMap[T]) Load(id identity.Stream) (T, bool)

func (HashMap[T]) Store

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

type Map

type Map[T any] interface {
	Load(identity.Stream) (T, bool)
	Store(identity.Stream, T) error
	Delete(identity.Stream)
	Items() func(yield func(identity.Stream, T) bool) bool
	Len() int
	Clear()
}

Map defines a collection of items tracked by a stream-id and the operations on it

type Seq

type Seq[T any] func(yield func(identity.Stream, T) bool) bool

Sequence of streams that can be iterated upon