vaultvol

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 15, 2025 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Tx

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

func (*Tx) Abort

func (v *Tx) Abort(ctx context.Context) error

func (*Tx) Commit

func (v *Tx) Commit(ctx context.Context) error

func (*Tx) Delete

func (v *Tx) Delete(ctx context.Context, cids []blobcache.CID) error

func (*Tx) Exists

func (v *Tx) Exists(ctx context.Context, cids []blobcache.CID, dst []bool) error

func (*Tx) Get

func (v *Tx) Get(ctx context.Context, cid blobcache.CID, buf []byte, opts blobcache.GetOpts) (int, error)

func (*Tx) Hash

func (v *Tx) Hash(salt *blobcache.CID, data []byte) blobcache.CID

func (*Tx) IsVisited

func (v *Tx) IsVisited(ctx context.Context, ptcids []blobcache.CID, dst []bool) error
func (v *Tx) Link(ctx context.Context, subvol blobcache.OID, rights blobcache.ActionSet, targetVol volumes.Volume) error

func (*Tx) Load

func (v *Tx) Load(ctx context.Context, dst *[]byte) error

func (*Tx) MaxSize

func (v *Tx) MaxSize() int

func (*Tx) Params added in v0.0.2

func (tx *Tx) Params() blobcache.TxParams

func (*Tx) Post

func (v *Tx) Post(ctx context.Context, data []byte, opts blobcache.PostOpts) (blobcache.CID, error)

func (*Tx) Save

func (v *Tx) Save(ctx context.Context, src []byte) error
func (v *Tx) Unlink(ctx context.Context, targets []blobcache.OID) error

func (*Tx) Visit

func (v *Tx) Visit(ctx context.Context, ptcids []blobcache.CID) error
func (v *Tx) VisitLinks(ctx context.Context, targets []blobcache.OID) error

func (*Tx) Volume

func (tx *Tx) Volume() volumes.Volume

type Vault

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

func New

func New(inner volumes.Volume, secret [32]byte, hf blobcache.HashFunc) *Vault

func (*Vault) AccessSubVolume

func (v *Vault) AccessSubVolume(ctx context.Context, target blobcache.OID) (blobcache.ActionSet, error)

func (*Vault) Await

func (v *Vault) Await(ctx context.Context, prev []byte, next *[]byte) error

func (*Vault) BeginTx

func (v *Vault) BeginTx(ctx context.Context, params blobcache.TxParams) (volumes.Tx, error)

func (*Vault) GetBackend

func (v *Vault) GetBackend() blobcache.VolumeBackend[blobcache.OID]

func (*Vault) GetParams

func (v *Vault) GetParams() blobcache.VolumeConfig

func (*Vault) Inner

func (v *Vault) Inner() volumes.Volume

Jump to

Keyboard shortcuts

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