Skip to main content

ReplayMsg

atomr_accel_cuda::replay

Enum ReplayMsg

pub enum ReplayMsg {
    Record(JournalEntry),
    Snapshot {
        reply: Sender<Vec<JournalEntry>>,
    },
    SetMode {
        mode: ReplayMode,
    },
    LoadJournal {
        entries: Vec<JournalEntry>,
        reply: Sender<()>,
    },
    ReplayAll,
    LoadFromJournal {
        from_sequence_nr: u64,
        max: u64,
        reply: Sender<Result<usize, String>>,
    },
}

Variants§

Record(JournalEntry)

Snapshot

Fields

§reply: Sender<Vec<JournalEntry>>

SetMode

Fields

§mode: ReplayMode

LoadJournal

Load a previously-recorded journal as the replay source. Use before sending ReplayAll.

Fields

§entries: Vec<JournalEntry>

§reply: Sender<()>

ReplayAll

Stream the loaded journal through the sink. Replies after every entry has been acknowledged. Only valid in ReplayMode::Replay.

LoadFromJournal

Pull history from the attached persistence backend and load it into self.journal for subsequent ReplayAll. Returns the number of entries loaded. Only available with the replay cargo feature.

Fields

§from_sequence_nr: u64

§max: u64

§reply: Sender<Result<usize, String>>

Auto Trait Implementations§

impl Freeze for ReplayMsg

impl !RefUnwindSafe for ReplayMsg

impl Send for ReplayMsg

impl Sync for ReplayMsg

impl Unpin for ReplayMsg

impl UnsafeUnpin for ReplayMsg

impl !UnwindSafe for ReplayMsg

Blanket Implementations§

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> From<T> for T

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

impl<T, U> Into<U> for T
where U: From<T>,

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T, U> TryFrom<U> for T
where U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more

impl<T> Extension for T
where T: Any + Send + Sync,