Enum StoreCommand 

pub enum StoreCommand<P, E> {
    Persist(E),
    PersistFullEvent {
        event: E,
        snapshot_every: Option<u64>,
    },
    PersistFull {
        event: E,
        actor: P,
        snapshot_every: Option<u64>,
    },
    PersistLight(E, P),
    Snapshot(P),
    Compact,
    LastEvent,
    LastEventNumber,
    LastEventsFrom(u64),
    GetEvents {
        from: u64,
        to: u64,
    },
    Recover,
    Purge,
}

Commands processed by the internal Store actor.

Variants

Persist(E)

Persist an event without forcing a snapshot.

PersistFullEvent

Persist an event and report whether the caller should snapshot now.

Fields

event: E

Event to append to the event log.

snapshot_every: Option<u64>

Snapshot cadence for FullPersistence.

PersistFull

Persist an event and snapshot the supplied actor state if required.

Fields

event: E

Event to append to the event log.

actor: P

Current actor state, used when a snapshot is triggered.

snapshot_every: Option<u64>

Snapshot cadence for FullPersistence.

PersistLight(E, P)

Persist an event together with a snapshot of the supplied actor state.

Snapshot(P)

Snapshot the supplied actor state immediately.

Compact

Remove event log entries already covered by the latest snapshot.

LastEvent

Return the most recently persisted event.

LastEventNumber

Return the next free event index.

LastEventsFrom(u64)

Return all events from the supplied event index to the end of the log.

GetEvents

Return all events within the inclusive [from, to] range.

Fields

from: u64

to: u64

Recover

Recover the current actor state from snapshots and events.

Purge

Delete all events, snapshots, and metadata for this actor.

Trait Implementations

impl<P, E> Clone for StoreCommand<P, E>

where P: Clone, E: Clone,

fn clone(&self) -> StoreCommand<P, E>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<P, E> Debug for StoreCommand<P, E>

where P: Debug, E: Debug,

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

Formats the value using the given formatter.

impl<P, E> Message for StoreCommand<P, E>

where P: PersistentActor, <P as Actor>::Event: BorshSerialize + BorshDeserialize, E: Event + BorshSerialize + BorshDeserialize,

fn is_critical(&self) -> bool

Returns true if this message must be processed before the actor stops; defaults to false.