Versions in this module Expand all Collapse all v2 v2.0.2 Jun 23, 2024 v2.0.1 Jun 6, 2024 Changes in this version + type EventsStore struct + KeepRecordsAfterDisconnect bool + func NewEventsStore() *EventsStore + func (s *EventsStore) Connect(ctx context.Context) error + func (s *EventsStore) DeleteEvents(ctx context.Context, persistenceID string, toSequenceNumber uint64) error + func (s *EventsStore) Disconnect(ctx context.Context) error + func (s *EventsStore) GetLatestEvent(ctx context.Context, persistenceID string) (*egopb.Event, error) + func (s *EventsStore) GetShardEvents(ctx context.Context, shardNumber uint64, offset int64, max uint64) ([]*egopb.Event, int64, error) + func (s *EventsStore) PersistenceIDs(ctx context.Context, pageSize uint64, pageToken string) (persistenceIDs []string, nextPageToken string, err error) + func (s *EventsStore) Ping(ctx context.Context) error + func (s *EventsStore) ReplayEvents(ctx context.Context, persistenceID string, ...) ([]*egopb.Event, error) + func (s *EventsStore) ShardNumbers(ctx context.Context) ([]uint64, error) + func (s *EventsStore) WriteEvents(ctx context.Context, events []*egopb.Event) error Other modules containing this package github.com/tochemey/ego github.com/tochemey/ego/v3
Go to main page