inmem

package

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

Details

This section is empty.

This section is empty.

This section is empty.

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

Coordinator coordinates ObjectStore access within one process.

func ForVolume(volumeID string) *Coordinator

ForVolume returns the process-local coordinator for a Volume id.

func NewCoordinator() *Coordinator

NewCoordinator builds an in-memory coordinator.

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

Capability reports in-memory coordination support.

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

Snapshot returns the latest in-memory generation and root.

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

TryAcquireWriteLease attempts to acquire the logical write lease.

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

WaitAcquireWriteLease waits until the logical write lease is available.

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

Watch returns coordination events after afterGeneration.