Struct NodeConfig 

pub struct NodeConfig {
    pub dataflow_id: DataflowId,
    pub node_id: NodeId,
    pub run_config: NodeRunConfig,
    pub daemon_communication: Option<DaemonCommunication>,
    pub dataflow_descriptor: Value,
    pub dynamic: bool,
    pub write_events_to: Option<PathBuf>,
    pub restart_count: u32,
    pub output_routing: Option<BTreeMap<DataId, OutputRouting>>,
}

Fields

dataflow_id: DataflowId

node_id: NodeId

run_config: NodeRunConfig

daemon_communication: Option<DaemonCommunication>

dataflow_descriptor: Value

dynamic: bool

write_events_to: Option<PathBuf>

restart_count: u32

Number of times this node has been restarted. 0 on first run.

output_routing: Option<BTreeMap<DataId, OutputRouting>>

Per-output data-plane routing for the startup handshake, computed by the daemon from the actual placement of the dataflow’s nodes at spawn time (the descriptor’s deploy section is intent, not placement — label scheduling can resolve differently).

None means the node was spawned by an older daemon that doesn’t provide routing; the node then keeps every output on the reliable daemon path (correct, just without the direct-zenoh fast path).

Trait Implementations

impl Clone for NodeConfig

fn clone(&self) -> NodeConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for NodeConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for NodeConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.