Versions in this module Expand all Collapse all v0 v0.6.0 Aug 30, 2026 Changes in this version + type BlobReaderLifecycle interface + BlobReaderCloseBound func() time.Duration v0.5.0 Aug 29, 2026 Changes in this version + const MaxOrderedPageLimit + const MaxOrderedValueBytes + const MaxStableKeyBytes + func ValidateDue(due Due) error + func ValidateOrderedID(id OrderedID) error + func ValidateOrderedLimit(limit int) error + func ValidateOrderedRecord(record OrderedRecord) error + func ValidateOrderedValue(value []byte) error + func ValidateStableKey(key StableKey) error type Composite + OrderedIndex OrderedIndex + func NewCompositeWithOrderedIndex(l Ledger, le Leaser, kv KV, bl Blobs, oi OrderedIndex) (*Composite, error) + func (c *Composite) RequireOrderedIndex() (OrderedIndex, error) + type Due struct + State DueState + UnixMillis int64 + type DueCursor string + type DuePage struct + NextCursor DueCursor + Records []OrderedRecord + type DueState uint8 + const DueAt + const NotDue + type InvalidDueError struct + Due Due + Rule string + func (e *InvalidDueError) Error() string + type InvalidOrderedCursorError struct + CursorLength uint16 + Kind OrderedCursorKind + Rule OrderedCursorRule + func NewInvalidOrderedCursorError(kind OrderedCursorKind, cursor string, rule OrderedCursorRule) *InvalidOrderedCursorError + func (e *InvalidOrderedCursorError) Error() string + type InvalidOrderedLimitError struct + Limit int + Max int + func (e *InvalidOrderedLimitError) Error() string + type InvalidOrderedRecordError struct + ID OrderedID + Rule string + func (e *InvalidOrderedRecordError) Error() string + type InvalidStableKeyError struct + Rule string + StableKeyLength uint16 + func (e *InvalidStableKeyError) Error() string + type OrderedAmbiguousError struct + Cause error + ID OrderedID + Operation OrderedOperation + func (e *OrderedAmbiguousError) Error() string + func (e *OrderedAmbiguousError) Unwrap() error + type OrderedCursorKind string + const DueCursorKind + const RankedCursorKind + func (k OrderedCursorKind) String() string + type OrderedCursorRule uint8 + const OrderedCursorMalformed + const OrderedCursorQueryMismatch + const OrderedCursorUnknownVersion + const OrderedCursorWrongKind + func (r OrderedCursorRule) String() string + type OrderedDeletedError struct + ID OrderedID + func (e *OrderedDeletedError) Error() string + type OrderedID struct + Namespace string + OrderingScope string + StableKey StableKey + type OrderedIndex interface + Create func(ctx context.Context, id OrderedID, rankingScope string, value []byte, ...) (record OrderedRecord, created bool, err error) + Delete func(ctx context.Context, id OrderedID, expectedRevision uint64) (OrderedRecord, error) + Get func(ctx context.Context, id OrderedID) (OrderedRecord, error) + ListDue func(ctx context.Context, namespace string, dueAtOrBefore int64, after DueCursor, ...) (DuePage, error) + ListOrdered func(ctx context.Context, namespace string, orderingScope string, afterOrder uint64, ...) (OrderedPage, error) + ListRanked func(ctx context.Context, namespace string, rankingScope string, after RankedCursor, ...) (RankedPage, error) + Update func(ctx context.Context, id OrderedID, expectedRevision uint64, value []byte, ...) (OrderedRecord, error) + type OrderedOperation string + const OrderedCreateOperation + const OrderedDeleteOperation + const OrderedUpdateOperation + type OrderedPage struct + NextAfterOrder uint64 + Records []OrderedRecord + type OrderedRecord struct + Deleted bool + Due Due + ID OrderedID + Order uint64 + Rank Rank + RankingScope string + Revision uint64 + Value []byte + type OrderedRecordNotFoundError struct + ID OrderedID + func (e *OrderedRecordNotFoundError) Error() string + type OrderedRevisionConflictError struct + ActualRevision uint64 + ExpectedRevision uint64 + ID OrderedID + func (e *OrderedRevisionConflictError) Error() string + type OrderedRevisionExhaustedError struct + ID OrderedID + Revision uint64 + func (e *OrderedRevisionExhaustedError) Error() string + type OrderedValueTooLargeError struct + Max int + Size int + func (e *OrderedValueTooLargeError) Error() string + type Rank struct + Ranked bool + Value int64 + type RankedCursor string + type RankedPage struct + NextCursor RankedCursor + Records []OrderedRecord + type StableKey string v0.4.1 Aug 24, 2026 v0.4.0 Aug 14, 2026 Changes in this version + func AppendDefinite(ctx context.Context, l Ledger, name string, expected uint64, payload []byte) error + func ValidateName(name string) error + type AmbiguousError struct + Cause error + Expected uint64 + Name string + func (e *AmbiguousError) Error() string + func (e *AmbiguousError) Unwrap() error + type AppendVerifyError struct + Cause error + Name string + Seq uint64 + func (e *AppendVerifyError) Error() string + func (e *AppendVerifyError) Unwrap() error + type BlobConflictError struct + Key string + func (e *BlobConflictError) Error() string + type BlobNotFoundError struct + Key string + func (e *BlobNotFoundError) Error() string + type Blobs interface + Delete func(ctx context.Context, key string) error + Get func(ctx context.Context, key string) (io.ReadCloser, error) + List func(ctx context.Context, prefix string) ([]string, error) + Put func(ctx context.Context, key string, r io.Reader) error + type Composite struct + func NewComposite(l Ledger, le Leaser, kv KV, bl Blobs) (*Composite, error) + type ConflictError struct + Expected uint64 + Name string + func (e *ConflictError) Error() string + type Cursor interface + Close func() error + Next func(ctx context.Context) (Record, error) + type IncompleteCompositeError struct + Missing []string + func (e *IncompleteCompositeError) Error() string + type InvalidNameError struct + Name string + Rule string + func (e *InvalidNameError) Error() string + type KV interface + Delete func(ctx context.Context, key string) error + Get func(ctx context.Context, key string) (val []byte, rev uint64, err error) + Keys func(ctx context.Context, prefix string) ([]string, error) + Put func(ctx context.Context, key string, expectedRev uint64, val []byte) (rev uint64, err error) + type KeyNotFoundError struct + Key string + func (e *KeyNotFoundError) Error() string + type Lease interface + Epoch func() uint64 + Lost func() <-chan struct{} + Release func(ctx context.Context) error + type LeaseHeldError struct + HolderEpoch uint64 + Name string + func (e *LeaseHeldError) Error() string + type LeaseLostError struct + Epoch uint64 + Name string + func (e *LeaseLostError) Error() string + type Leaser interface + Acquire func(ctx context.Context, name string) (Lease, error) + type Ledger interface + Append func(ctx context.Context, name string, expected uint64, payload []byte) error + Delete func(ctx context.Context, name string) error + Read func(ctx context.Context, name string, from uint64) (Cursor, error) + Tip func(ctx context.Context, name string) (uint64, error) + type PathReporter interface + StoragePaths func() []string + type Record struct + Payload []byte + Seq uint64 + type RecordNotFoundError struct + Name string + Seq uint64 + func (e *RecordNotFoundError) Error() string v0.3.1 Aug 7, 2026 v0.3.0 Jul 23, 2026 v0.2.0 Jul 11, 2026 v0.1.0 Jul 4, 2026
Go to main page