Documentation
¶
Overview ¶
Package sqlite stores canonical facts, events and receipts in one transaction.
Index ¶
- type Batch
- type Receipt
- type Store
- type Tx
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Tx ¶
type Tx struct {
// contains filtered or unexported fields
}
func (*Tx) AppendBatch ¶
func (t *Tx) AppendBatch(b domain.CommitBatch, taskID string) error
func (*Tx) PutReceipt ¶
func (*Tx) PutTokenHash ¶
Source Files
Click to show internal directories.
Click to hide internal directories.