Enum InterDaemonEvent 

#[non_exhaustive]
pub enum InterDaemonEvent {
    Output {
        dataflow_id: DataflowId,
        node_id: NodeId,
        output_id: DataId,
        metadata: Metadata,
        data: Option<AVec<u8, ConstAlign<128>>>,
    },
    OutputClosed {
        dataflow_id: DataflowId,
        node_id: NodeId,
        output_id: DataId,
    },
    ExtensionMessage {
        dataflow_id: DataflowId,
        namespace: String,
        target_machine: Option<String>,
        payload: Vec<u8>,
    },
}

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Output

Fields

dataflow_id: DataflowId

node_id: NodeId

output_id: DataId

metadata: Metadata

data: Option<AVec<u8, ConstAlign<128>>>

OutputClosed

Fields

dataflow_id: DataflowId

node_id: NodeId

output_id: DataId

ExtensionMessage

An opaque message between the daemons of one dataflow, sent on behalf of an out-of-tree extension. dora never interprets namespace or payload — it moves the bytes and nothing else.

This is the inter-daemon half of the extension seam (the node-facing halves are crate::node_to_daemon::DaemonRequest::ExtensionRequest and the extension table). Naming the variants after any one transport would freeze that transport’s architecture into the 1.0 protocol, which is exactly what docs/extensions.md exists to avoid; a second extension needs no change here at all.

Fields

dataflow_id: DataflowId

namespace: String

Extension that owns the payload. A daemon with no extension registered under this namespace drops the message.

target_machine: Option<String>

When set, only the daemon whose machine id matches acts on the message; the others drop it. None addresses every daemon in the dataflow.

payload: Vec<u8>

Implementations

impl InterDaemonEvent

pub fn encode_size_hint(&self) -> usize

Bulk bytes this event will contribute to its encoding, for crate::encode_presized.

Not to be confused with crate::metadata::debug_frame_wire_size, which answers “how big was this on the wire” and deliberately prefers the daemon-stamped WIRE_SIZE parameter over the buffer length (#2584). This one must be the actual buffer length, since it sizes an allocation.

Trait Implementations

impl Clone for InterDaemonEvent

fn clone(&self) -> InterDaemonEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InterDaemonEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for InterDaemonEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for InterDaemonEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.