sqlite

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