Enum DaemonEvent 

pub enum DaemonEvent {
    BuildResult {
        build_id: BuildId,
        result: Result<(), String>,
    },
    SpawnResult {
        dataflow_id: DataflowId,
        result: Result<(), String>,
    },
    AllNodesReady {
        dataflow_id: DataflowId,
        exited_before_subscribe: Vec<NodeId>,
    },
    AllNodesFinished {
        dataflow_id: DataflowId,
        result: DataflowDaemonResult,
    },
    Heartbeat,
    Log(LogMessage),
    Exit,
    NodeMetrics {
        dataflow_id: DataflowId,
        metrics: BTreeMap<NodeId, NodeMetrics>,
    },
}

Variants

BuildResult

Fields

build_id: BuildId

result: Result<(), String>

SpawnResult

Fields

dataflow_id: DataflowId

result: Result<(), String>

AllNodesReady

Fields

dataflow_id: DataflowId

exited_before_subscribe: Vec<NodeId>

AllNodesFinished

Fields

dataflow_id: DataflowId

result: DataflowDaemonResult

Heartbeat

Log(LogMessage)

Exit

NodeMetrics

Fields

dataflow_id: DataflowId

metrics: BTreeMap<NodeId, NodeMetrics>

Trait Implementations

impl Debug for DaemonEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for DaemonEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for DaemonEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.