Struct InProcessBackend 

pub struct InProcessBackend { /* private fields */ }

In-process, non-durable checkpoint-artifact backend.

Implementations

impl InProcessBackend

pub fn new(vnode_capacity: u32) -> Self

Create a new backend sized for vnode_capacity vnodes.

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, attempt: CheckpointAttempt, vnode: u32, 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 assignment fence — there’s only one process so the scenario is moot. assignment_version is accepted and ignored.

fn key_group_capacity(&self) -> u32

Number of stable key groups this backend can address.

fn bind_state_namespace<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, deployment_id: &'life1 str, pipeline_identity: &'life2 PipelineIdentity, ) -> Pin<Box<dyn Future<Output = Result<(), StateBackendError>> + Send + 'async_trait>>

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

Bind this storage root to one deployment and logical pipeline before recovery or writes.

fn write_certified_partial<'life0, 'life1, 'async_trait>( &'life0 self, attempt: CheckpointAttempt, vnode: u32, assignment_fence: &'life1 CheckpointAssignmentFence, writer_node_id: u64, bytes: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), StateBackendError>> + Send + 'async_trait>>

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

Persist a cluster partial certified by the exact active assignment and writer process.

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

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

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

fn write_commit_descriptor<'life0, 'life1, 'async_trait>( &'life0 self, attempt: CheckpointAttempt, key: &'life1 str, bytes: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), StateBackendError>> + Send + 'async_trait>>

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

Persist a local-runtime coordinated-commit descriptor for attempt under key.

fn write_certified_commit_descriptor<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, attempt: CheckpointAttempt, key: &'life1 str, assignment_fence: &'life2 CheckpointAssignmentFence, writer_node_id: u64, leader_proof: &'life3 LeaderProof, bytes: Bytes, ) -> Pin<Box<dyn Future<Output = Result<(), StateBackendError>> + Send + 'async_trait>>

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

Persist a cluster descriptor certified by the exact assignment, writer process, and checkpoint-initiating leader term.

fn read_commit_descriptor<'life0, 'life1, 'async_trait>( &'life0 self, attempt: CheckpointAttempt, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<Bytes>, StateBackendError>> + Send + 'async_trait>>

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

Read one exact coordinated-commit descriptor, if it exists.

fn read_sealed_commit_descriptor_bounded<'life0, 'life1, 'async_trait>( &'life0 self, attempt: CheckpointAttempt, sealed: &'life1 SealedCommitDescriptor, max_bytes: u64, ) -> Pin<Box<dyn Future<Output = Result<Option<Bytes>, StateBackendError>> + Send + 'async_trait>>

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

Read a descriptor admitted by an exact checkpoint seal.

fn seal_checkpoint<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, attempt: CheckpointAttempt, assignment_fence: Option<&'life1 CheckpointAssignmentFence>, vnodes: &'life2 [u32], required_descriptors: &'life3 [String], ) -> Pin<Box<dyn Future<Output = Result<bool, StateBackendError>> + Send + 'async_trait>>

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

Durability barrier: true once every vnode partial and every required_descriptors key for attempt is persisted, sealing that exact attempt. Sinks do not commit until it returns Ok(true). In cluster mode, required_descriptors also binds every participant’s final readiness attestation, including participants with no vnodes or coordinated sinks.

fn checkpoint_seal_inventory<'life0, 'async_trait>( &'life0 self, attempt: CheckpointAttempt, ) -> Pin<Box<dyn Future<Output = Result<Option<CheckpointSealInventory>, StateBackendError>> + Send + 'async_trait>>

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

Read the canonical artifact inventory for an exact sealed attempt. Returns None when that attempt has no live seal or is below the durable prune floor.

fn verify_checkpoint_artifact_metadata<'life0, 'life1, 'async_trait>( &'life0 self, inventory: &'life1 CheckpointSealInventory, ) -> Pin<Box<dyn Future<Output = Result<(), StateBackendError>> + Send + 'async_trait>>

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

Prove from storage metadata that every artifact named by an exact seal still exists with its sealed length, without reading artifact payloads.

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 state seal 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 read_commit_descriptor_bounded<'life0, 'life1, 'async_trait>( &'life0 self, attempt: CheckpointAttempt, key: &'life1 str, max_bytes: u64, ) -> Pin<Box<dyn Future<Output = Result<Option<Bytes>, StateBackendError>> + Send + 'async_trait>>

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

Read one descriptor while enforcing a private control-plane allocation bound.

fn durability_scope(&self) -> StateBackendDurability

Failure scope survived by this backend.

fn uses_exact_object_store(&self, _expected: &Arc<dyn ObjectStore>) -> bool

Whether this backend uses the exact object-store handle admitted by cluster startup.

fn set_authoritative_version(&self, _version: u64)

Raise the backend’s authoritative assignment version — the exact VnodeRegistry::assignment_version it will accept on partial and descriptor writes. 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.