Versions in this module Expand all Collapse all v0 v0.2.1 Sep 22, 2023 Changes in this version + const DefaultRunnerBufferSize + type Appender interface + Append func(ctx context.Context, id StreamID, expected version.Check, events ...Envelope) (version.Version, error) + type Envelope message.GenericEnvelope + func ToEnvelope(event Event) Envelope + func ToEnvelopes(events ...Event) []Envelope + type Event message.Message + type FusedStore struct + type Persisted struct + func StreamToSlice(ctx context.Context, f func(ctx context.Context, stream StreamWrite) error) ([]Persisted, error) + type Processor interface + Process func(ctx context.Context, event Persisted) error + type ProcessorFunc func(ctx context.Context, event Persisted) error + func (pf ProcessorFunc) Process(ctx context.Context, event Persisted) error + type ProcessorRunner struct + BufferSize int + Logger func(string, ...any) + func (r ProcessorRunner) Run(ctx context.Context) error + type Store interface + type Stream = chan Persisted + func SliceToStream(events []Persisted) Stream + type StreamID string + type StreamRead <-chan Persisted + type StreamWrite chan<- Persisted + type Streamer interface + Stream func(ctx context.Context, stream StreamWrite, id StreamID, ...) error + type Subscription interface + Checkpoint func(ctx context.Context, event Persisted) error + Name func() string + Start func(ctx context.Context, eventStream StreamWrite) error
Go to main page