Struct InProcessBackend 

pub struct InProcessBackend { /* private fields */ }

In-process, non-durable state backend.

Implementations

impl InProcessBackend

pub fn new(vnode_capacity: u32) -> Self

Create a new backend sized for vnode_capacity vnodes.

pub fn vnode_capacity(&self) -> u32

Vnode range this backend is configured for.

Trait Implementations

impl Debug for InProcessBackend

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

Formats the value using the given formatter.

impl StateBackend for InProcessBackend

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,

In-process backend opts out of the split-brain fence — there’s only one process so the scenario is moot. assignment_version is accepted and ignored.

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.