Documentation
¶
Index ¶
- Constants
- type Queue
- func (q *Queue) Backend() blobcache.QueueBackend[blobcache.OID]
- func (q *Queue) Config() blobcache.QueueConfig
- func (q *Queue) Dequeue(ctx context.Context, buf []blobcache.Message, opts blobcache.DequeueOpts) (int, error)
- func (q *Queue) Down(ctx context.Context) error
- func (q *Queue) Enqueue(ctx context.Context, msgs []blobcache.Message) (int, error)
- type System
- type Tx
- func (tx *Tx) Abort(ctx context.Context) error
- func (tx *Tx) Commit(ctx context.Context) error
- func (tx *Tx) Delete(_ context.Context, cids []blobcache.CID) error
- func (tx *Tx) Exists(_ context.Context, cids []blobcache.CID, dst *blobcache.BitMap) error
- func (tx *Tx) Get(_ context.Context, cid blobcache.CID, buf []byte, opts blobcache.GetOpts) (int, error)
- func (tx *Tx) HashAlgo() blobcache.HashAlgo
- func (tx *Tx) IsVisited(_ context.Context, cids []blobcache.CID, dst *blobcache.BitMap) error
- func (tx *Tx) Link(ctx context.Context, svoid blobcache.OID, rights blobcache.ActionSet, ...) (*blobcache.LinkToken, error)
- func (tx *Tx) Load(ctx context.Context, dst *[]byte) error
- func (tx *Tx) MaxSize() int
- func (tx *Tx) Params() blobcache.TxParams
- func (tx *Tx) Post(ctx context.Context, data []byte, opts blobcache.PostOpts) (blobcache.CID, error)
- func (tx *Tx) Save(ctx context.Context, src []byte) error
- func (tx *Tx) Unlink(ctx context.Context, targets []blobcache.LinkID) error
- func (tx *Tx) Visit(ctx context.Context, cids []blobcache.CID) error
- func (tx *Tx) VisitLinks(ctx context.Context, targets []blobcache.LinkID) error
- type Volume
- func (vol *Volume) AccessSubVolume(ctx context.Context, target blobcache.LinkToken) (blobcache.ActionSet, error)
- func (vol *Volume) BeginTx(ctx context.Context, spec blobcache.TxParams) (backend.Tx, error)
- func (vol *Volume) Down(ctx context.Context) error
- func (vol *Volume) GetBackend() blobcache.VolumeBackend[blobcache.OID]
- func (vol *Volume) GetParams() blobcache.VolumeConfig
- func (vol *Volume) Load(ctx context.Context, dst *[]byte) error
Constants ¶
View Source
const ( MaxMaxDepth = 16 MaxMaxHandlesPer = 16 MaxMaxBytesPer = 1 << 20 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Queue ¶
type Queue struct {
// contains filtered or unexported fields
}
func (*Queue) Backend ¶ added in v0.8.0
func (q *Queue) Backend() blobcache.QueueBackend[blobcache.OID]
func (*Queue) Config ¶
func (q *Queue) Config() blobcache.QueueConfig
type Tx ¶ added in v0.8.0
type Tx struct {
// contains filtered or unexported fields
}
type Volume ¶ added in v0.8.0
type Volume struct {
// contains filtered or unexported fields
}
func (*Volume) AccessSubVolume ¶ added in v0.8.0
func (*Volume) GetBackend ¶ added in v0.8.0
func (vol *Volume) GetBackend() blobcache.VolumeBackend[blobcache.OID]
func (*Volume) GetParams ¶ added in v0.8.0
func (vol *Volume) GetParams() blobcache.VolumeConfig
Source Files
Click to show internal directories.
Click to hide internal directories.