Struct MemoryStream 

pub struct MemoryStream { /* private fields */ }

Deterministic process-local provider. It retains idempotency results indefinitely, satisfying the minimum 24-hour contract while the process exists; it deliberately claims no crash recovery.

Implementations

impl MemoryStream

pub fn new(limits: MemoryLimits) -> Self

Constructs one bounded independent provider.

pub fn new_with_clock( limits: MemoryLimits, clock: Arc<dyn UnixMillisClock>, ) -> Self

Constructs a provider with an injected trusted clock.

Trait Implementations

impl Clone for MemoryStream

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for MemoryStream

fn default() -> Self

Returns the “default value” for a type.

impl StreamProvider for MemoryStream

fn inspect_idempotency<'life0, 'async_trait>( &'life0 self, idempotency_key: IdempotencyKey, ) -> Pin<Box<dyn Future<Output = Result<Option<IdempotencyObservation>, StreamError>> + Send + 'async_trait>>

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

Reads the retained terminal result for one caller-owned retry identity.

fn tail<'life0, 'async_trait>( &'life0 self, path: StreamPath, ) -> Pin<Box<dyn Future<Output = Result<u64, StreamError>> + Send + 'async_trait>>

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

Current next sequence.

fn append<'life0, 'async_trait>( &'life0 self, request: AppendRequest, ) -> Pin<Box<dyn Future<Output = Result<AppendOutcome, StreamError>> + Send + 'async_trait>>

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

Atomic append or tail conflict.

fn fork<'life0, 'async_trait>( &'life0 self, request: ForkRequest, ) -> Pin<Box<dyn Future<Output = Result<ForkReceipt, StreamError>> + Send + 'async_trait>>

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

Atomic immutable-prefix fork.

fn trim<'life0, 'async_trait>( &'life0 self, path: StreamPath, before: u64, idempotency_key: IdempotencyKey, ) -> Pin<Box<dyn Future<Output = Result<TrimReceipt, StreamError>> + Send + 'async_trait>>

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

Monotonically advances a path’s logical trim point.

fn delete<'life0, 'async_trait>( &'life0 self, path: StreamPath, idempotency_key: IdempotencyKey, ) -> Pin<Box<dyn Future<Output = Result<DeleteReceipt, StreamError>> + Send + 'async_trait>>

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

Permanently retires a path with no live descendants.

fn read<'life0, 'async_trait>( &'life0 self, request: ReadRequest, ) -> Pin<Box<dyn Future<Output = Result<RecordStream, StreamError>> + Send + 'async_trait>>

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

Opens a bounded finite read.

fn follow<'life0, 'async_trait>( &'life0 self, path: StreamPath, from: u64, ) -> Pin<Box<dyn Future<Output = Result<RecordStream, StreamError>> + Send + 'async_trait>>

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

Replays and then remains live without a handoff gap.

fn children<'life0, 'async_trait>( &'life0 self, request: ChildrenRequest, ) -> Pin<Box<dyn Future<Output = Result<ChildStream, StreamError>> + Send + 'async_trait>>

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

Lists one fixed-snapshot direct-child page.

fn commit<'life0, 'async_trait>( &'life0 self, request: CommitRequest, ) -> Pin<Box<dyn Future<Output = Result<CommitOutcome, StreamError>> + Send + 'async_trait>>

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

Executes one all-or-nothing optimistic commit.

fn commit_before<'life0, 'async_trait>( &'life0 self, request: CommitRequest, deadline_unix_millis: u64, ) -> Pin<Box<dyn Future<Output = Result<CommitOutcome, StreamError>> + Send + 'async_trait>>

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

Executes one coordinated commit only if the provider’s trusted clock is strictly before deadline_unix_millis at the linearization point.

fn read_commit<'life0, 'async_trait>( &'life0 self, commit_id: CommitId, ) -> Pin<Box<dyn Future<Output = Result<CommittedEnvelope, StreamError>> + Send + 'async_trait>>

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

Reads one complete immutable successful envelope.