volumes

type LinkSet = map[blobcache.OID]blobcache.ActionSet

type System[Params any, V Volume] interface {
	// Up loads volume state into memory.
	// This should be called to begin using the Volume.
	Up(ctx context.Context, spec Params) (V, error)

	// Drop should remove all state associated with the volume
	Drop(ctx context.Context, vol V) error
}

type Tx interface {
	Params() blobcache.TxParams
	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

	// Link creates adds a handle to prove access to a volume.
	Link(ctx context.Context, target blobcache.OID, rights blobcache.ActionSet, targetVol Volume) error
	// Unlink removes a link from the volume.
	Unlink(ctx context.Context, targets []blobcache.OID) error
	// VisitLinks visits a link to another volume.
	// This is only usable in a GC transaction.
	VisitLinks(ctx context.Context, targets []blobcache.OID) error
}

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

type Volume interface {
	// GetParams returns the effective parameters of the volume.
	GetParams() blobcache.VolumeConfig
	// GetBackend returns the backend of the volume.
	GetBackend() blobcache.VolumeBackend[blobcache.OID]

	BeginTx(ctx context.Context, spec blobcache.TxParams) (Tx, error)

	// AccessSubVolume returns the rights granted to access a subvolume.
	// Returns 0 if there is no link to the target.
	AccessSubVolume(ctx context.Context, target blobcache.OID) (blobcache.ActionSet, error)
}