Struct ObjectStoreBackend 

pub struct ObjectStoreBackend { /* private fields */ }

Object-store-backed StateBackend.

Implementations

impl ObjectStoreBackend

pub fn new( store: Arc<dyn ObjectStore>, instance_id: impl Into<String>, vnode_capacity: u32, ) -> Self

Wrap an existing [ObjectStore].

pub fn vnode_capacity(&self) -> u32

Vnode range this backend is configured for.

pub fn authoritative_version_handle(&self) -> Arc<AtomicU64>

Shared handle to the authoritative version counter. Callers that want to bump several objects (e.g. backend plus a future metric) from a single owner can clone this handle instead of relaying through StateBackend::set_authoritative_version.

Trait Implementations

impl Debug for ObjectStoreBackend

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

Formats the value using the given formatter.

impl StateBackend for ObjectStoreBackend

fn write_partial<'life0, 'async_trait>( &'life0 self, vnode: u32, epoch: u64, assignment_version: u64, bytes: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), StateBackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Persist a partial aggregate for (vnode, epoch).

fn read_partial<'life0, 'async_trait>( &'life0 self, vnode: u32, epoch: u64, ) -> Pin<Box<dyn Future<Output = Result<Option<Bytes>, StateBackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Read the partial aggregate for (vnode, epoch), if any.

fn epoch_complete<'life0, 'life1, 'async_trait>( &'life0 self, epoch: u64, vnodes: &'life1 [u32], ) -> Pin<Box<dyn Future<Output = Result<bool, StateBackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Durability barrier: returns true iff every vnode in the set has a partial persisted for epoch.

fn prune_before<'life0, 'async_trait>( &'life0 self, before: u64, ) -> Pin<Box<dyn Future<Output = Result<(), StateBackendError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Garbage-collect every partial and commit marker whose epoch is strictly less than before. Called by the checkpoint coordinator after a successful checkpoint commit so the backend does not retain state for epochs that can never be recovered.

fn set_authoritative_version(&self, version: u64)

Raise the backend’s authoritative assignment version — the minimum VnodeRegistry::assignment_version it will accept on write_partial. Hosts call this on boot after adopting an AssignmentSnapshot and on each subsequent rotation so stale writers from a deposed leader are fenced out.

fn authoritative_version(&self) -> u64

Current authoritative assignment version. 0 means the fence is disabled — every caller version is accepted. Backends that do not fence return 0 unconditionally.