eventmap

Documentation

Index

• Variables
• func Init[DT, MT any](pers stream.Persistence, eventType, dataTypeVersion, streamName string, ...) (ed *mapData[DT, MT], err error)
• type EventMap

Variables

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

Functions

func Init

func Init[DT, MT any](pers stream.Persistence, eventType, dataTypeVersion, streamName string, p stream.CryptoKeyProvider, ctx context.Context) (ed *mapData[DT, MT], err error)

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(key string) (err error)
	Set(key string, data DT, metadata MT) (err error)
	Close()
}