Enum Event 

pub enum Event {
    TaskSpawned {
        task: TaskId,
        node: NodeId,
        name: String,
    },
    TaskDone {
        task: TaskId,
        node: NodeId,
        name: String,
    },
    MessageSent {
        from: NodeId,
        to: NodeId,
        seq: u64,
        deliver_at: Micros,
    },
    MessageDropped {
        from: NodeId,
        to: NodeId,
        seq: u64,
        reason: DropReason,
    },
    MessageDuplicated {
        from: NodeId,
        to: NodeId,
        seq: u64,
    },
    MessageReordered {
        from: NodeId,
        to: NodeId,
        seq: u64,
    },
    MessageDelivered {
        from: NodeId,
        to: NodeId,
        seq: u64,
    },
    DiskWrite {
        node: NodeId,
        path: String,
        len: usize,
    },
    DiskTornWrite {
        node: NodeId,
        path: String,
        requested: usize,
        written: usize,
    },
    DiskWriteFailed {
        node: NodeId,
        path: String,
    },
    DiskFsync {
        node: NodeId,
        path: String,
        durable_len: usize,
    },
    DiskFsyncFailed {
        node: NodeId,
        path: String,
    },
    Crash {
        node: NodeId,
    },
    Restart {
        node: NodeId,
    },
    Partition {
        group_a: Vec<NodeId>,
        group_b: Vec<NodeId>,
    },
    Healed,
    SkewUpdated {
        node: NodeId,
    },
    ClockAdvanced {
        from: Micros,
        to: Micros,
    },
    Custom {
        node: NodeId,
        message: String,
    },
}

One recorded step of a simulation run, in execution order. Two runs of the same scenario with the same seed produce identical sequences.

Variants

TaskSpawned

A task was spawned for a node process.

Fields

task: TaskId

New task id.

node: NodeId

Owning node.

name: String

Process name.

TaskDone

A task finished.

Fields

task: TaskId

Finished task id.

node: NodeId

Owning node.

name: String

Process name.

MessageSent

A message entered the flight queue.

Fields

from: NodeId

Sender.

to: NodeId

Destination.

seq: u64

Sequence number.

deliver_at: Micros

Scheduled delivery time.

MessageDropped

A message never reached its destination.

Fields

from: NodeId

Sender.

to: NodeId

Destination.

seq: u64

Sequence number.

reason: DropReason

Why it was dropped.

MessageDuplicated

A send scheduled an extra copy.

Fields

from: NodeId

Sender.

to: NodeId

Destination.

seq: u64

Sequence number of the original copy.

MessageReordered

A send undercut a previously scheduled send on the same link.

Fields

from: NodeId

Sender.

to: NodeId

Destination.

seq: u64

Sequence number.

MessageDelivered

A message reached a destination inbox.

Fields

from: NodeId

Sender.

to: NodeId

Destination.

seq: u64

Sequence number.

DiskWrite

A write landed in a file’s pending stage.

Fields

node: NodeId

Owning node.

path: String

File path.

len: usize

Bytes written.

DiskTornWrite

A write was truncated (torn write).

Fields

node: NodeId

Owning node.

path: String

File path.

requested: usize

Bytes requested.

written: usize

Bytes actually written.

DiskWriteFailed

An injected write failure fired.

Fields

node: NodeId

Owning node.

path: String

File path.

DiskFsync

Pending bytes became durable.

Fields

node: NodeId

Owning node.

path: String

File path.

durable_len: usize

Total durable bytes after the sync.

DiskFsyncFailed

An injected fsync failure fired.

Fields

node: NodeId

Owning node.

path: String

File path.

Crash

A node process crashed; volatile state was dropped.

Fields

node: NodeId

Crashed node.

Restart

A crashed node process restarted.

Fields

node: NodeId

Restarted node.

Partition

Connectivity between two node sets was cut.

Fields

group_a: Vec<NodeId>

First side.

group_b: Vec<NodeId>

Second side.

Healed

All partition cuts were removed.

SkewUpdated

A node’s skew schedule was replaced.

Fields

node: NodeId

Affected node.

ClockAdvanced

The virtual clock advanced on idle.

Fields

from: Micros

Previous time.

to: Micros

New time.

Custom

An application-level record from NodeContext::log.

Fields

node: NodeId

Logging node.

message: String

Free-form message.

Trait Implementations

impl Clone for Event

fn clone(&self) -> Event

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Event

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Event

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Event

impl PartialEq for Event

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for Event

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Event