streams

Documentation

Index

• type Evictor
• type HashMap
  • 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 Evictor

type Evictor interface {
	Evict() identity.Stream
}

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

type HashMap

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

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
}

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