anysystem 0.2.0

A framework for deterministic simulation and testing of distributed systems
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

//! Simulation events.

use serde::Serialize;

use crate::Message;

/// Message is received.
#[derive(Clone, Serialize)]
pub struct MessageReceived {
    /// Message identifier.
    pub id: u64,
    /// Received message.
    pub msg: Message,
    /// Name of sender process.
    pub src: String,
    /// Name of sender node.
    pub src_node: String,
    /// Name of destination process.
    pub dst: String,
    /// Name of destination node.
    pub dst_node: String,
}

/// Timer is fired.
#[derive(Clone, Serialize)]
pub struct TimerFired {
    /// Name of process that set the timer.
    pub proc: String,
    /// Timer name.
    pub timer: String,
}