Enum ControlRequestReply 

pub enum ControlRequestReply {
    Error(String),
    CoordinatorStopped,
    HelloOk {
        dora_version: Version,
    },
    DataflowBuildTriggered {
        build_id: BuildId,
    },
    DataflowBuildFinished {
        build_id: BuildId,
        result: Result<(), String>,
    },
    DataflowStartTriggered {
        uuid: Uuid,
    },
    DataflowSpawned {
        uuid: Uuid,
    },
    DataflowReloaded {
        uuid: Uuid,
    },
    DataflowStopped {
        uuid: Uuid,
        result: DataflowResult,
    },
    DataflowRestarted {
        old_uuid: Uuid,
        new_uuid: Uuid,
    },
    DataflowList(DataflowList),
    CleanResult {
        cleaned: DataflowList,
        failed: Vec<CleanFailure>,
    },
    DataflowInfo {
        uuid: Uuid,
        name: Option<String>,
        descriptor: Descriptor,
    },
    DestroyOk,
    DaemonConnected(bool),
    ConnectedDaemons(Vec<DaemonInfo>),
    Logs(Vec<u8>),
    CliAndDefaultDaemonIps {
        default_daemon: Option<IpAddr>,
        cli: Option<IpAddr>,
    },
    NodeInfoList(Vec<NodeInfo>),
    TopicSubscribed {
        subscription_id: Uuid,
        protocol_version: Option<u16>,
    },
    TraceList(Vec<TraceSummary>),
    TraceSpans(Vec<TraceSpan>),
    NodeRestarted {
        dataflow_id: Uuid,
        node_id: NodeId,
    },
    NodeStopped {
        dataflow_id: Uuid,
        node_id: NodeId,
    },
    TopicPublished,
    NodeAdded {
        dataflow_id: Uuid,
        node_id: NodeId,
    },
    NodeRemoved {
        dataflow_id: Uuid,
        node_id: NodeId,
    },
    NodeReplaced {
        dataflow_id: Uuid,
        node_id: NodeId,
    },
    MappingAdded {
        dataflow_id: Uuid,
        source_node: NodeId,
        source_output: DataId,
        target_node: NodeId,
        target_input: DataId,
    },
    MappingRemoved {
        dataflow_id: Uuid,
        source_node: NodeId,
        source_output: DataId,
        target_node: NodeId,
        target_input: DataId,
    },
    ParamList {
        params: Vec<(String, Value)>,
    },
    ParamValue {
        key: String,
        value: Value,
    },
    ParamSet,
    ParamDeleted,
}

Variants

Error(String)

CoordinatorStopped

HelloOk

Response to ControlRequest::Hello. Carries the coordinator’s own dora crate version so the CLI can display it on version mismatches and in debug output (dora-rs/adora#151).

Fields

dora_version: Version

DataflowBuildTriggered

Fields

build_id: BuildId

DataflowBuildFinished

Fields

build_id: BuildId

result: Result<(), String>

DataflowStartTriggered

Fields

uuid: Uuid

DataflowSpawned

Fields

uuid: Uuid

DataflowReloaded

Fields

uuid: Uuid

DataflowStopped

Fields

uuid: Uuid

result: DataflowResult

DataflowRestarted

Fields

old_uuid: Uuid

new_uuid: Uuid

DataflowList(DataflowList)

CleanResult

Response to ControlRequest::Clean.

cleaned lists dataflows the coordinator successfully removed from both in-memory state and the persisted store (with the cascade-delete of associated dora param rows). failed lists dataflows that were eligible but whose persisted-store delete errored: their in-memory entries are preserved so a later dora clean can retry. The CLI needs both lists to tell “nothing eligible” apart from “all candidates failed to clean”.

Fields

cleaned: DataflowList

failed: Vec<CleanFailure>

DataflowInfo

Fields

uuid: Uuid

name: Option<String>

descriptor: Descriptor

DestroyOk

DaemonConnected(bool)

ConnectedDaemons(Vec<DaemonInfo>)

Logs(Vec<u8>)

CliAndDefaultDaemonIps

Fields

default_daemon: Option<IpAddr>

cli: Option<IpAddr>

NodeInfoList(Vec<NodeInfo>)

TopicSubscribed

Fields

subscription_id: Uuid

protocol_version: Option<u16>

Binary-frame encoding the coordinator will send, see TOPIC_DATA_PROTOCOL_VERSION.

None means the coordinator predates the handshake and therefore sends bincode frames; the client rejects the subscription rather than misparse them as postcard.

TraceList(Vec<TraceSummary>)

TraceSpans(Vec<TraceSpan>)

NodeRestarted

Fields

dataflow_id: Uuid

node_id: NodeId

NodeStopped

Fields

dataflow_id: Uuid

node_id: NodeId

TopicPublished

NodeAdded

Fields

dataflow_id: Uuid

node_id: NodeId

NodeRemoved

Fields

dataflow_id: Uuid

node_id: NodeId

NodeReplaced

Fields

dataflow_id: Uuid

node_id: NodeId

MappingAdded

Fields

dataflow_id: Uuid

source_node: NodeId

source_output: DataId

target_node: NodeId

target_input: DataId

MappingRemoved

Fields

dataflow_id: Uuid

source_node: NodeId

source_output: DataId

target_node: NodeId

target_input: DataId

ParamList

Fields

params: Vec<(String, Value)>

ParamValue

Fields

key: String

value: Value

ParamSet

ParamDeleted

Trait Implementations

impl Clone for ControlRequestReply

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ControlRequestReply

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ControlRequestReply

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ControlRequestReply

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

where __S: Serializer,

Serialize this value into the given Serde serializer.