Versions in this module Expand all Collapse all v0 v0.1.0 Oct 29, 2024 Changes in this version + type DefaultSchema struct + func NewTable() *DefaultSchema + func (d *DefaultSchema) ActorName() string + func (d *DefaultSchema) CreateTable() []string + func (d *DefaultSchema) Created() string + func (d *DefaultSchema) ID() string + func (d *DefaultSchema) JournalTableName() string + func (d *DefaultSchema) Payload() string + func (d *DefaultSchema) SequenceNumber() string + func (d *DefaultSchema) SnapshotTableName() string + func (d *DefaultSchema) WithJournalTable(name string) *DefaultSchema + func (d *DefaultSchema) WithSnapshotTable(name string) *DefaultSchema + type Provider struct + func New(ctx context.Context, snapshotInterval int, table Schemaer, db *pgxpool.Pool, ...) (*Provider, error) + func (provider *Provider) DeleteEvents(_ string, _ int) + func (provider *Provider) DeleteSnapshots(_ string, _ int) + func (provider *Provider) GetEvents(actorName string, eventIndexStart int, eventIndexEnd int, ...) + func (provider *Provider) GetSnapshot(actorName string) (snapshot interface{}, eventIndex int, ok bool) + func (provider *Provider) GetSnapshotInterval() int + func (provider *Provider) GetState() persistence.ProviderState + func (provider *Provider) PersistEvent(actorName string, eventIndex int, snapshot proto.Message) + func (provider *Provider) PersistSnapshot(actorName string, eventIndex int, snapshot proto.Message) + func (provider *Provider) Restart() + type Schemaer interface + ActorName func() string + CreateTable func() []string + Created func() string + ID func() string + JournalTableName func() string + Payload func() string + SequenceNumber func() string + SnapshotTableName func() string
Go to main page