storage

package module

Go to main page

Versions in this module

v0

v0.9.1

Oct 16, 2026

v0.9.0

Sep 30, 2026

Changes in this version

+ const BoundedBlobReaderCloseBound

+ type BlobReaderClosedError struct

+ func (e *BlobReaderClosedError) Error() string

+ func (e *BlobReaderClosedError) Unwrap() error

type BlobReaderLifecycle

+ func WithBoundedBlobReaders(b Blobs) (BlobReaderLifecycle, error)

type Composite

+ func (c *Composite) WithBoundedBlobReaders() (*Composite, error)

+ type NilBlobReaderError struct

+ Key string

+ func (e *NilBlobReaderError) Error() string

+ type NilBlobsError struct

+ func (e *NilBlobsError) Error() string

v0.8.0

Sep 29, 2026

v0.7.0

Sep 23, 2026

v0.6.1

Sep 17, 2026

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL