Versions in this module Expand all Collapse all v0 v0.1.45 Oct 2, 2026 Changes in this version + const CatalogVersion + func VersionedPath(configured string) string + type Backend struct + func Open(options Options) (*Backend, error) + func (b *Backend) Append(ctx context.Context, stream, kind string, rows []recordstore.Row) (recordstore.AppendResult, error) + func (b *Backend) AppendBatch(ctx context.Context, batch recordstore.Batch) (recordstore.BatchResult, error) + func (b *Backend) BatchOutcome(ctx context.Context, id string) (recordstore.BatchResult, bool, error) + func (b *Backend) Close() error + func (b *Backend) Compact(ctx context.Context) (int, error) + func (b *Backend) Delete(ctx context.Context, stream string) error + func (b *Backend) DeleteSeqs(ctx context.Context, stream string, seqs []int64, compactions int64) (recordstore.Meta, error) + func (b *Backend) Derived() bool + func (b *Backend) Expire(ctx context.Context, stream string, ttl time.Duration) error + func (b *Backend) Import(ctx context.Context, request recordstore.ImportRequest) (recordstore.Window, error) + func (b *Backend) Lease() func() + func (b *Backend) Merge(ctx context.Context, target string, sources []string, ...) (recordstore.AppendResult, error) + func (b *Backend) Meta(ctx context.Context, stream string) (recordstore.Meta, error) + func (b *Backend) Path() string + func (b *Backend) Prepare(ctx context.Context, source recordstore.Meta) (recordstore.Meta, bool, error) + func (b *Backend) ProducerSeq(ctx context.Context, instance string) (int64, error) + func (b *Backend) Promote(ctx context.Context) error + func (b *Backend) ReadDSN() string + func (b *Backend) Reopen(ctx context.Context, stream, generation string) error + func (b *Backend) Scan(ctx context.Context, stream string, afterSeq int64, ...) error + func (b *Backend) Seal(ctx context.Context, stream string) error + func (b *Backend) SetExpiry(ctx context.Context, stream string, expiresAt *time.Time) error + func (b *Backend) Sweep(ctx context.Context) (int, error) + func (b *Backend) SweepBatches(ctx context.Context, before time.Time, keep func(id string) bool) (int, error) + func (b *Backend) Table(kind string) (sqlitetable.Table, error) + func (b *Backend) Trim(ctx context.Context, stream string, before time.Time) (recordstore.Meta, error) + func (b *Backend) TrimBelow(ctx context.Context, stream string, lowSeq int64) (recordstore.Meta, error) + func (b *Backend) WatchChanges(ctx context.Context, changed func()) error + type Options struct + Derived bool + Now func() time.Time + Path string + ReadOnly bool + Schema recordstore.SchemaResolver + Submit recordstore.Submitter + SweepInterval time.Duration + TTL time.Duration Other modules containing this package github.com/flanksource/commons-db
Go to main page