bolt

package

v0.57.21 Latest Latest Go to latest Published: Oct 2, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Rendered for

This section is empty.

This section is empty.

This section is empty.

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

Coordinator adapts bbolt commit generation into the Volume coordinator contract.

func NewCoordinator(db *bdb.DB, inner *coord_inmem.Coordinator) *Coordinator

NewCoordinator builds a bbolt-backed coordinator.

func (c *Coordinator) Capability(ctx context.Context, scope coord.Scope) (*coord.Capability, error)

Capability reports bbolt coordination support.

func (c *Coordinator) Snapshot(ctx context.Context, scope coord.Scope) (*coord.Snapshot, error)

Snapshot returns the latest bbolt commit generation and coordinator root.

func (c *Coordinator) TryAcquireWriteLease(ctx context.Context, scope coord.Scope) (coord.WriteLease, bool, error)

TryAcquireWriteLease attempts to acquire the logical bbolt write lease.

func (c *Coordinator) WaitAcquireWriteLease(ctx context.Context, scope coord.Scope) (coord.WriteLease, error)

WaitAcquireWriteLease waits until the logical bbolt write lease is available.

func (c *Coordinator) Watch(ctx context.Context, scope coord.Scope, afterGeneration uint64) (coord.Watch, error)

Watch streams root/prefix lease events and bbolt commit-generation changes.