volumes

type System[K any] interface {
	Create(ctx context.Context, k K, spec blobcache.VolumeSpec) error
	Open(ctx context.Context, k K) (Volume, error)
	Drop(ctx context.Context, k K) error
	Clone(ctx context.Context, k K) (Volume, error)
}

type Tx interface {
	Commit(ctx context.Context) error
	Abort(ctx context.Context) error

	Save(ctx context.Context, src []byte) error
	Load(ctx context.Context, dst *[]byte) error

	Post(ctx context.Context, data []byte, opts blobcache.PostOpts) (blobcache.CID, error)
	Get(ctx context.Context, cid blobcache.CID, buf []byte, opts blobcache.GetOpts) (int, error)
	Delete(ctx context.Context, cids []blobcache.CID) error
	Exists(ctx context.Context, cids []blobcache.CID, dst []bool) error
	IsVisited(ctx context.Context, cids []blobcache.CID, dst []bool) error
	Visit(ctx context.Context, cids []blobcache.CID) error

	MaxSize() int
	Hash(salt *blobcache.CID, data []byte) blobcache.CID

	// AllowLink creates adds a handle to prove access to a volume.
	AllowLink(ctx context.Context, subvol blobcache.Handle) error
}

type UnsaltedStore struct {
	// contains filtered or unexported fields
}

type Vault struct {
	Inner Volume
	// contains filtered or unexported fields
}

type VaultTx struct {
	// contains filtered or unexported fields
}

type Volume interface {
	BeginTx(ctx context.Context, spec blobcache.TxParams) (Tx, error)
	// Await blocks until the volume root changes away from prev to something else.
	// The next state is written to next.
	Await(ctx context.Context, prev []byte, next *[]byte) error
}