Enum persist::indexed::CmdRead

pub enum CmdRead {
    Load(String, (String, String), PFutureHandle<Option<Id>>),
    GetDescription(String, PFutureHandle<Description<u64>>),
    Snapshot(Id, PFutureHandle<ArrangementSnapshot>),
    Listen(Id, Sender<ListenEvent>, PFutureHandle<ArrangementSnapshot>),
    Stop(PFutureHandle<()>),
}

A read-only input to the persist state machine.

Variants

Load(String, (String, String), PFutureHandle<Option<Id>>)

Tuple Fields

0: String

1: (String, String)

2: PFutureHandle<Option<Id>>

Loads the arrangement with the given external stream name, returning the corresponding internal stream id.

GetDescription(String, PFutureHandle<Description<u64>>)

Tuple Fields

0: String

1: PFutureHandle<Description<u64>>

Returns a Description of the stream identified by id_str.

Snapshot(Id, PFutureHandle<ArrangementSnapshot>)

Tuple Fields

0: Id

1: PFutureHandle<ArrangementSnapshot>

Returns a Snapshot for the given id.

Listen(Id, Sender<ListenEvent>, PFutureHandle<ArrangementSnapshot>)

Tuple Fields

0: Id

1: Sender<ListenEvent>

2: PFutureHandle<ArrangementSnapshot>

Registers a callback to be invoked on successful writes and seals.

Also returns a copy of the snapshot so that users can, if they want, apply their logic to a consistent read of the entire stream.

Stop(PFutureHandle<()>)

Tuple Fields

0: PFutureHandle<()>

Flush out any pending work and close the underlying storage, causing all future commands to error.

If applicable, releases exclusive-writer locks.

Implementations

impl CmdRead

pub fn fill_err_runtime_shutdown(self)

Fills self’s response, if applicable, with Error::RuntimeShutdown.

Trait Implementations

impl Debug for CmdRead

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

Formats the value using the given formatter.