eventmap

Documentation

Index

• Variables
• type EventMap
  • func Init[DT any](pers stream.Stream, eventType, dataTypeVersion string, ...) (ed EventMap[DT], err error)

Variables

var ERROR_KEY_NOT_FOUND = fmt.Errorf("provided key does not exist")

Types

type EventMap

type EventMap[DT any] interface {
	Get(key string) (data DT, err error)
	Exists(key string) (exists bool)
	Len() (l int)
	Keys() (keys []string)
	Range(f func(key string, value DT) bool)
	GetMap() map[string]DT
	Delete(key string) (err error)
	Set(key string, data DT) (err error)
	Stream(eventTypes []event.Type, from store.StreamPosition, filter stream.Filter, ctx context.Context) (out <-chan event.Event[DT], err error)
}

func Init

func Init[DT any](pers stream.Stream, eventType, dataTypeVersion string, p stream.CryptoKeyProvider, ctx context.Context, opts ...func(event.Type, *DT)) (ed EventMap[DT], err error)