stream

type CryptoKeyProvider func(key string) log.RedactedString

type Filter func(md event.Metadata) bool

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

type Stream interface {
	Write() chan<- store.WriteEvent
	Stream(from store.StreamPosition, ctx context.Context) (out <-chan store.ReadEvent, err error)
	End() (pos uint64, err error)
	Name() string
}