Versions in this module Expand all Collapse all v0 v0.1.0 Oct 30, 2026 Changes in this version + type Batch = ports.Batch + type Receipt = ports.Receipt + type Store struct + func Open(path string) (*Store, error) + func (s *Store) Begin(ctx context.Context, write bool) (ports.Transaction, error) + func (s *Store) Close() error + type Tx struct + func (t *Tx) AppendBatch(b domain.CommitBatch, taskID string) error + func (t *Tx) Audit(at, action string) error + func (t *Tx) Batches(after int64, limit int) ([]Batch, error) + func (t *Tx) Commit() error + func (t *Tx) Meta(key string) (string, error) + func (t *Tx) PutReceipt(r Receipt) error + func (t *Tx) PutRecord(r domain.Record) error + func (t *Tx) PutTask(task domain.Task, previous int64) error + func (t *Tx) PutTokenHash(id, hash string) error + func (t *Tx) Receipt(principal, key string) (*Receipt, error) + func (t *Tx) Record(kind, id string) (*domain.Record, error) + func (t *Tx) Records(taskID string) ([]domain.Record, error) + func (t *Tx) Rollback() + func (t *Tx) SetMeta(key, value string) error + func (t *Tx) Task(id string) (*domain.Task, error) + func (t *Tx) Tasks() ([]domain.Task, error) + func (t *Tx) TokenHash(id string) (string, error) + func (t *Tx) Watermark() (int64, error)
Go to main page