Struct InMemoryCommitLog 

pub struct InMemoryCommitLog { /* private fields */ }

Thread-safe in-memory CommitLog; see the module documentation.

Implementations

impl InMemoryCommitLog

pub fn new() -> Self

Creates an empty log whose commit timestamps come from the system clock in microseconds (logical and node_tiebreaker are zero).

pub fn with_timestamp_source(timestamp_source: TimestampSource) -> Self

Creates an empty log with an injectable commit-timestamp source.

Trait Implementations

impl CommitLog for InMemoryCommitLog

fn propose( &self, command: CommandEnvelope, control: &ExecutionControl, ) -> Result<CommitReceipt, LogError>

Verifies the envelope, honors cancellation/deadline, then commits and applies the command in one step. The receipt’s transaction id is derived from the envelope’s command id (the idempotent-apply identifier).

fn read_committed( &self, after: LogPosition, limit: usize, ) -> Result<Vec<CommittedEntry>, LogError>

Reads committed entries strictly after after, in log order.

fn applied_position(&self) -> LogPosition

The highest position the local state machine has applied.

fn create_snapshot(&self) -> Result<LogSnapshot, LogError>

Captures applied state through the current applied position.

fn install_snapshot(&self, snapshot: LogSnapshot) -> Result<(), LogError>

Replaces applied state with a snapshot taken at a log boundary.

impl Debug for InMemoryCommitLog

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

Formats the value using the given formatter.

impl Default for InMemoryCommitLog

fn default() -> Self

Returns the “default value” for a type.