Struct AssignmentSnapshotStore 

pub struct AssignmentSnapshotStore { /* private fields */ }

I/O wrapper for AssignmentSnapshot on an object store.

Implementations

impl AssignmentSnapshotStore

pub fn new(store: Arc<dyn ObjectStore>) -> Self

Wrap a pre-constructed object store.

pub async fn load(&self) -> Result<Option<AssignmentSnapshot>, SnapshotError>

Load the current (highest-versioned) snapshot; Ok(None) on fresh cluster.

Errors

Object-store I/O or JSON decode failure.

pub async fn load_version( &self, version: u64, ) -> Result<Option<AssignmentSnapshot>, SnapshotError>

Load a specific version’s snapshot. Ok(None) if that version was never written or has been pruned.

Errors

Object-store I/O or JSON decode failure.

pub async fn save_if_absent( &self, snapshot: &AssignmentSnapshot, ) -> Result<Option<AssignmentSnapshot>, SnapshotError>

CAS-create the object for snapshot.version. Ok(None) means another writer landed there first. Used for both the initial seed and for rotations (via Self::save_if_version).

Errors

Object-store I/O or JSON encode failure.

pub async fn save_if_version( &self, snapshot: &AssignmentSnapshot, prior_version: u64, ) -> Result<RotateOutcome, SnapshotError>

Rotate to snapshot assuming the current durable version is prior_version. Returns RotateOutcome::Conflict carrying the winner’s snapshot if a racer produced prior_version + 1 first.

Errors

Object-store I/O, JSON encode, or a non-monotonic version bump (caller bug).

pub async fn prune_before(&self, before: u64) -> Result<(), SnapshotError>

Delete every snapshot object with version < before. Idempotent — missing objects are tolerated.

Errors

Object-store I/O.

Trait Implementations

impl Debug for AssignmentSnapshotStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.