Versions in this module Expand all Collapse all v0 v0.3.0 Oct 7, 2026 v0.2.0 Sep 17, 2026 Changes in this version type Config + Publisher timebox.Publisher v0.1.0 Sep 13, 2026 Changes in this version + const DefaultMaxConns + const DefaultPrefix + const DefaultURL + var ErrInvalidMaxConns = errors.New("max conns must be positive") + var ErrPrefixRequired = errors.New("prefix is required") + var ErrURLRequired = errors.New("postgres URL is required") + type Backend struct + func Open(cfgs ...Config) (*Backend, error) + func (b *Backend) Append(reqs ...timebox.AppendRequest) error + func (b *Backend) Close() error + func (b *Backend) GetAggregateStatus(id timebox.AggregateID) (string, error) + func (b *Backend) ListAggregates(typ timebox.ID) ([]timebox.AggregateID, error) + func (b *Backend) ListAggregatesByStatus(status string) ([]timebox.StatusEntry, error) + func (b *Backend) ListAggregatesByTag(tag string) ([]timebox.AggregateID, error) + func (b *Backend) LoadEvents(req timebox.LoadEventsRequest) (*timebox.EventsResult, error) + func (b *Backend) LoadSnapshot(req timebox.LoadSnapshotRequest) (*timebox.SnapshotRecord, error) + func (b *Backend) NewStore(cfgs ...timebox.Config) (*timebox.Store, error) + func (b *Backend) SaveSnapshot(req timebox.SnapshotRequest) error + type Config struct + MaxConns int32 + Prefix string + URL string + func DefaultConfig() Config + func (c Config) Validate() error + func (c Config) With(other Config) Config
Go to main page