Documentation
¶
Index ¶
- type LinkSet
- type Queue
- type QueueSystem
- type System
- type Tx
- type UnsaltedStore
- func (v UnsaltedStore) Delete(ctx context.Context, cids []blobcache.CID) error
- func (v UnsaltedStore) Exists(ctx context.Context, cids []blobcache.CID, dst *blobcache.BitMap) error
- func (v UnsaltedStore) Get(ctx context.Context, cid blobcache.CID, buf []byte) (int, error)
- func (v UnsaltedStore) Hash(data []byte) blobcache.CID
- func (v UnsaltedStore) HashAlgo() blobcache.HashAlgo
- func (v UnsaltedStore) MaxSize() int
- func (v UnsaltedStore) Post(ctx context.Context, data []byte) (blobcache.CID, error)
- type Volume
- type VolumeSystem
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type QueueSystem ¶
type System ¶
type System[VP any, V Volume, QP any, Q Queue] interface { VolumeSystem[VP, V] QueueSystem[QP, Q] }
System is a full backend System, supporting Volumes, Queues and subscriptions on Volumes.
type UnsaltedStore ¶
type UnsaltedStore struct {
// contains filtered or unexported fields
}
This is an adapter to a store, since we added salts to the API.
func NewUnsaltedStore ¶
func NewUnsaltedStore(inner Tx) *UnsaltedStore
func ViewUnsalted ¶
func (UnsaltedStore) HashAlgo ¶ added in v0.6.0
func (v UnsaltedStore) HashAlgo() blobcache.HashAlgo
func (UnsaltedStore) MaxSize ¶
func (v UnsaltedStore) MaxSize() int
type VolumeSystem ¶
type VolumeSystem[Params any, V Volume] interface { // VolumeUp loads volume state into memory. // This should be called to begin using the Volume. VolumeUp(ctx context.Context, spec Params) (V, error) // VolumeDestroy should remove all state associated with the volume VolumeDestroy(ctx context.Context, vol V) error }
Click to show internal directories.
Click to hide internal directories.