sqlitestore

Oct 4, 2026

Changes in this version

type Store

+ func (s *Store) EndPreviewRecord(ctx context.Context, id, state string) error

+ func (s *Store) InspectPreviewRecord(ctx context.Context, w data.PreviewRecord) error

+ func (s *Store) LookupPreviewRecord(ctx context.Context, id string) (out data.PreviewRecord, err error)

+ func (s *Store) OpenPreviewRecord(ctx context.Context, w data.PreviewRecord, quota int) (out data.PreviewRecord, err error)

+ func (s *Store) PrunePreviewRecords(ctx context.Context, limit int) error

Oct 2, 2026

Changes in this version

type Store

+ func (s *Store) ListReceipts(ctx context.Context, target data.TargetKey, query data.ReceiptQuery) (out data.ReceiptPage, err error)

+ func (s *Store) LookupRequest(ctx context.Context, request data.RequestKey) (out data.Operation, found bool, err error)

Oct 2, 2026

Changes in this version

+ type Options struct

+ Now func() time.Time

+ ReceiptRetention time.Duration

+ RetryWindow time.Duration

+ type Store struct

+ func Open(path string, options Options) (*Store, error)

+ func (*Store) Capabilities() data.StoreCapabilities

+ func (s *Store) Acquire(ctx context.Context, id string, target data.TargetKey, ttl time.Duration) (data.Lease, error)

+ func (s *Store) AcquireRecovery(ctx context.Context, id string, target data.TargetKey, ttl time.Duration) (data.Lease, error)

+ func (s *Store) BeginIntent(ctx context.Context, l data.Lease, intent data.Intent, revision uint64) error

+ func (s *Store) CheckCleanup(ctx context.Context, lease data.Lease, stageID string) error

+ func (s *Store) CheckLease(ctx context.Context, l data.Lease) error

+ func (s *Store) Claim(ctx context.Context, op data.Operation) (out data.Claim, err error)

+ func (s *Store) Close() error

+ func (s *Store) GetArtifact(ctx context.Context, provider, id string) (out data.ArtifactRef, err error)

+ func (s *Store) GetOperation(ctx context.Context, id string) (out data.Operation, err error)

+ func (s *Store) GetReceipt(ctx context.Context, id string) (out data.PreparationReceipt, err error)

+ func (s *Store) ListOperations(ctx context.Context, target data.TargetKey, limit int) (out []data.Operation, err error)

+ func (s *Store) Prune(ctx context.Context) error

+ func (s *Store) PutReceipt(ctx context.Context, l data.Lease, r data.PreparationReceipt) error

+ func (s *Store) PutVerification(ctx context.Context, l data.Lease, id string, contentRev uint64, ...) (out data.PreparationReceipt, err error)

+ func (s *Store) Release(ctx context.Context, l data.Lease) error

+ func (s *Store) Renew(ctx context.Context, l data.Lease, ttl time.Duration) (out data.Lease, err error)

+ func (s *Store) RequestCancel(ctx context.Context, id string, rev uint64) (out data.Operation, err error)

+ func (s *Store) ResolveIntent(ctx context.Context, l data.Lease, intent data.Intent, ...) (out data.Operation, err error)

+ func (s *Store) Save(ctx context.Context, next data.Operation, rev uint64, l *data.Lease) (out data.Operation, err error)

+ func (s *Store) Target(ctx context.Context, target data.TargetKey) (out data.TargetState, err error)