postgres

package

v0.1.8 Latest Latest Go to latest Published: Feb 17, 2022 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func NewEventStore(db *pgxpool.Pool) es.EventStore

func NewSequenceStore(db *pgxpool.Pool) es.SequenceStore

type EventStore struct {
	// contains filtered or unexported fields
}

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, handler es.EventHandler) error

func (s *EventStore) Store(event *es.Event) (int64, error)

type SequenceStore struct {
	// contains filtered or unexported fields
}

func (s *SequenceStore) Get(persistentClientID string) (int64, error)

func (s *SequenceStore) Store(persistentClientID string, sequence int64) error