consumer

Documentation

Index

• func DecryptEvent[T any](e event.ByteReadEvent, cryptoKey stream.CryptoKeyProvider) (out event.ReadEvent[T], err error)
• func EncryptEvent[T any](e event.Event[T], cryptoKey stream.CryptoKeyProvider) (es event.ByteEvent, err error)
• type Consumer
  • func New[T any](s stream.Stream, cryptoKey stream.CryptoKeyProvider, ctx context.Context) (out Consumer[T], err error)
• type Map
  • func NewMap[T any]() Map[T]

Functions

func DecryptEvent

func DecryptEvent[T any](e event.ByteReadEvent, cryptoKey stream.CryptoKeyProvider) (out event.ReadEvent[T], err error)

func EncryptEvent

func EncryptEvent[T any](e event.Event[T], cryptoKey stream.CryptoKeyProvider) (es event.ByteEvent, err error)

Types

type Consumer

type Consumer[T any] interface {
	Write() chan<- event.WriteEventReadStatus[T]
	Stream(eventTypes []event.Type, from store.StreamPosition, filter stream.Filter, ctx context.Context) (out <-chan event.ReadEventWAcc[T], err error)
	End() (pos uint64, err error)
	Name() string
}

func New

func New[T any](s stream.Stream, cryptoKey stream.CryptoKeyProvider, ctx context.Context) (out Consumer[T], err error)

type Map

type Map[T any] interface {
	Store(id string, data T)
	Load(id string) (data T, ok bool)
	Delete(id string)
	Range(f func(k string, v T) bool)
}

func NewMap

func NewMap[T any]() Map[T]