consensusvol

package

v0.0.2 Latest Latest Go to latest Published: Dec 15, 2025 License: GPL-3.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

func NewTID(sch blobcache.SchemaSpec) blobcache.TID

NewTID returns a TID from a SchemaSpec

type Env struct {
	Background context.Context
	// Hub is used to subscribe to events
	Hub  *pubsub.Hub
	Send func(blobcache.Message) error
}

type Params struct {
	Schema blobcache.SchemaSpec
	State  volumes.Volume
}

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

func New(env Env) System

func (sys *System) Drop(ctx context.Context, vol *Volume) error

func (sys *System) Up(ctx context.Context, params Params) (*Volume, error)

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

Volume manages state for a volume.

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

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

Await implements volumes.Volume.

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

BeginTx implements volumes.Volume.

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

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

func (v *Volume) Handle(out *[]blobcache.Message, msg blobcache.Message) error