Struct persist::mem::MemRegistry

pub struct MemRegistry {
    log: Arc<Mutex<MemLogCore>>,
    blob: Arc<Mutex<MemBlobCore>>,
}

An in-memory representation of a Log and Blob that can be reused across dataflows

Fields

log: Arc<Mutex<MemLogCore>>

blob: Arc<Mutex<MemBlobCore>>

Implementations

impl MemRegistry

pub fn new() -> Self

Constructs a new, empty MemRegistry

pub fn log_no_reentrance(&self) -> Result<MemLog, Error>

Opens the MemLog contained by this registry.

pub fn blob_no_reentrance(&self) -> Result<MemBlob, Error>

Opens the MemBlob contained by this registry.

pub fn indexed_no_reentrance(
    &mut self
) -> Result<Indexed<MemLog, MemBlob>, Error>

Returns a RuntimeClient using the MemLog and MemBlob contained by this registry.

pub fn indexed_unreliable(
    &mut self,
    unreliable: UnreliableHandle
) -> Result<Indexed<UnreliableLog<MemLog>, UnreliableBlob<MemBlob>>, Error>

Returns a RuntimeClient with unreliable storage backed by the given UnreliableHandle.

pub fn runtime_no_reentrance(&mut self) -> Result<RuntimeClient, Error>

Starts a RuntimeClient using the MemLog and MemBlob contained by this registry.

pub fn runtime_unreliable(
    &mut self,
    unreliable: UnreliableHandle
) -> Result<RuntimeClient, Error>

Open a RuntimeClient with unreliable storage backed by the given UnreliableHandle.

Trait Implementations

impl Clone for MemRegistry

fn clone(&self) -> MemRegistry

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for MemRegistry

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

Formats the value using the given formatter.