Versions in this module Expand all Collapse all v0 v0.1.8 Feb 17, 2022 v0.1.5 Feb 11, 2022 Changes in this version + func NewEventStore(db *pgxpool.Pool) es.EventStore + func NewSequenceStore(db *pgxpool.Pool) es.SequenceStore + type EventStore struct + func (s *EventStore) LastKnownSequence() int64 + func (s *EventStore) Read(sequence int64) (*es.Event, error) + func (s *EventStore) ReadAll(ctx context.Context, sel es.Selector, bracket es.Bracket, ...) error + func (s *EventStore) Store(event *es.Event) (int64, error) + type SequenceStore struct + func (s *SequenceStore) Get(persistentClientID string) (int64, error) + func (s *SequenceStore) Store(persistentClientID string, sequence int64) error
Go to main page