Enum Output 

pub enum Output {
    Send(NodeId, RaftRpc),
    Reply(NodeId, RaftRpcReply),
    Apply(Committed),
    RoleChanged(Role),
    ReadReady {
        id: ReadId,
        index: LogIndex,
    },
    ReadFailed {
        id: ReadId,
    },
    LoadSnapshot {
        index: LogIndex,
        data: Vec<u8>,
    },
    CatalogApplied {
        index: LogIndex,
        command: CatalogCommand,
    },
    SagaJournalApplied {
        index: LogIndex,
        command: SagaJournalCommand,
    },
    TwoPhasePrepareApplied {
        index: LogIndex,
        command: TwoPhasePrepareCommand,
    },
    TwoPhaseAbortApplied {
        index: LogIndex,
        command: TwoPhaseAbortCommand,
    },
    TwoPhaseJournalApplied {
        index: LogIndex,
        command: TwoPhaseJournalCommand,
    },
    QueueAutoscalePolicyApplied {
        index: LogIndex,
        command: QueueAutoscalePolicyCommand,
    },
}

An effect produced by the core for the runtime to execute.

Variants

Send(NodeId, RaftRpc)

Send a request RPC to a peer.

Reply(NodeId, RaftRpcReply)

Reply to a peer’s request RPC.

Apply(Committed)

A committed command to apply, in index order.

RoleChanged(Role)

The node changed role (useful for observability and tests).

ReadReady

A ReadIndex read is safe to serve: the state machine at index (or later) reflects everything committed before the request (read-consistency).

Fields

id: ReadId

The client’s read token.

index: LogIndex

The confirmed read index.

ReadFailed

A pending read could not be honored (leadership was lost); retry it against the new leader.

Fields

id: ReadId

The client’s read token.

LoadSnapshot

Load a snapshot installed from the leader into the application state machine, replacing all state through index (Raft §7).

Fields

index: LogIndex

Last log index the snapshot includes.

data: Vec<u8>

Opaque application snapshot bytes.

CatalogApplied

A committed catalog metadata entry (Tier 2; not applied to the user SM).

Fields

index: LogIndex

Log index of the catalog entry.

command: CatalogCommand

Catalog command committed at index.

SagaJournalApplied

A committed saga journal entry (Tier 2 v2; not applied to the user SM).

Fields

index: LogIndex

Log index of the saga journal entry.

command: SagaJournalCommand

Saga journal command committed at index.

TwoPhasePrepareApplied

A committed durable 2PC prepare entry (not applied to the user SM).

Fields

index: LogIndex

Log index of the prepare entry.

command: TwoPhasePrepareCommand

Prepare command committed at index.

TwoPhaseAbortApplied

A committed durable 2PC abort entry (not applied to the user SM).

Fields

index: LogIndex

Log index of the abort entry.

command: TwoPhaseAbortCommand

Abort command committed at index.

TwoPhaseJournalApplied

A committed 2PC client journal entry (not applied to the user SM).

Fields

index: LogIndex

Log index of the journal entry.

command: TwoPhaseJournalCommand

Journal command committed at index.

QueueAutoscalePolicyApplied

A committed queue autoscale policy entry (Meta-Raft; not applied to the user SM).

Fields

index: LogIndex

Log index of the policy entry.

command: QueueAutoscalePolicyCommand

Policy command committed at index.

Trait Implementations

impl Clone for Output

fn clone(&self) -> Output

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Output

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

Formats the value using the given formatter.

impl Eq for Output

impl PartialEq for Output

fn eq(&self, other: &Output) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for Output