competing

Documentation

Index

• type Consumer
  • func New[T any](s stream.Stream, cryptoKey stream.CryptoKeyProvider, from store.StreamPosition, ...) (out Consumer[T], err error)

Types

type Consumer

type Consumer[T any] interface {
	Write() chan<- event.WriteEvent[T]
	Stream() <-chan event.ReadEventWAcc[T]
	End() (pos uint64, err error)
	Name() string
}

func New

func New[T any](s stream.Stream, cryptoKey stream.CryptoKeyProvider, from store.StreamPosition, datatype string, timeoutDuration time.Duration, ctx context.Context) (out Consumer[T], err error)