persistenteventmap

Documentation

Index

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

Variables

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

Types

type EventMap

type EventMap[DT, MT any] interface {
	Get(key string) (data DT, metadata event.Metadata[MT], err error)
	Exists(key string) (exists bool)
	Len() (l int)
	Keys() (keys []string)
	Range(f func(key, value any) bool)
	Delete(data DT, metadata MT) (err error)
	Set(key string, data DT, metadata MT) (err error)
}

func Init

func Init[DT, MT any](s stream.Stream[DT, MT], dataTypeName, dataTypeVersion string, p stream.CryptoKeyProvider, getKey func(dt DT) string, ctx context.Context) (ed EventMap[DT, MT], err error)