Versions in this module Expand all Collapse all v0 v0.1.37 Sep 15, 2026 Changes in this version + 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) Close() 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) 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) ReadDSN() string + func (b *Backend) Scan(ctx context.Context, stream string, afterSeq int64, ...) 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) 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) + type Options struct + Derived bool + Now func() time.Time + Path string + Schema recordstore.SchemaResolver + SweepInterval time.Duration + TTL time.Duration
Go to main page