Struct Driver 

pub struct Driver { /* private fields */ }

Bounded single-broker state. Payloads remain owned by the journal adapter.

Implementations

impl Driver

pub const fn configuration(&self) -> Configuration

Persisted single-broker identity, independent of current write readiness.

pub const fn limits(&self) -> PipelineLimits

Count/byte capacity shared by all admitted operations on this partition.

pub fn recover( configuration: Configuration, generation: JournalGeneration, recovered: Prefix, limits: PipelineLimits, ) -> Result<Self, Error>

Activate only after exact-identity journal recovery has validated and synchronized this prefix. A fresh, explicitly formatted store uses genesis. Unlike replicated restart, no remote agreement or election exists here.

pub fn snapshot(&self) -> Snapshot

Observe local progress without changing authority.

pub fn begin_validation(&self) -> Result<ValidationTicket, Error>

Capture validation authority without accepting or confirming records.

pub fn prepare_validated( &mut self, ticket: ValidationTicket, operations: &[PreparedOperation], ) -> Result<WriteTicket, Error>

Admit only a fresh contiguous suffix validated on this exact image. Retries resolve in the shared canonical journal before this boundary.

pub fn complete_write(&mut self, ticket: WriteTicket) -> Result<(), Error>

Physical write completion alone never confirms or exposes records.

pub fn begin_sync(&self) -> Result<SyncTicket, Error>

Capture a generation-fenced durability ticket for the written prefix.

pub fn complete_sync(&mut self, ticket: SyncTicket) -> Result<(), Error>

Called after both the data barrier and exact durable-prefix evidence complete. Later writes cannot extend this captured confirmation boundary.

pub fn complete_durable_write( &mut self, ticket: WriteTicket, ) -> Result<(), Error>

Install a write that its O_DSYNC completion made durable, and confirm through it. Durable-prefix evidence is published separately.

pub fn apply_through(&mut self, through: Prefix) -> Result<(), Error>

Release live credit only after the shared journal applies this prefix. Application visibility and confirmation replies require this boundary.

pub fn fail(&mut self, generation: JournalGeneration) -> Result<(), Error>

Fence uncertain I/O until a new exact-identity recovery and generation.

Trait Implementations

impl Debug for Driver

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

Formats the value using the given formatter.