postgres

Oct 29, 2023

Changes in this version

type EventsStore

+ func (s *EventsStore) GetShardEvents(ctx context.Context, shardNumber uint64, offset int64, max uint64) ([]*egopb.Event, int64, error)

+ func (s *EventsStore) ShardNumbers(ctx context.Context) ([]uint64, error)

Oct 7, 2023

Changes in this version

+ type EventsStore struct

+ func NewEventsStore(config *postgres.Config) *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) 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) WriteEvents(ctx context.Context, events []*egopb.Event) error

+ type SchemaUtils struct

+ func NewSchemaUtils(db *postgres.TestDB) *SchemaUtils

+ func (d SchemaUtils) CreateTable(ctx context.Context) error

+ func (d SchemaUtils) DropTable(ctx context.Context) error