dora_message/
daemon_to_daemon.rs

1use aligned_vec::{AVec, ConstAlign};
2
3use crate::{
4    DataflowId,
5    id::{DataId, NodeId},
6    metadata::Metadata,
7};
8
9#[derive(Debug, serde::Deserialize, serde::Serialize)]
10#[allow(clippy::large_enum_variant)]
11pub enum InterDaemonEvent {
12    Output {
13        dataflow_id: DataflowId,
14        node_id: NodeId,
15        output_id: DataId,
16        metadata: Metadata,
17        data: Option<AVec<u8, ConstAlign<128>>>,
18    },
19    OutputClosed {
20        dataflow_id: DataflowId,
21        node_id: NodeId,
22        output_id: DataId,
23    },
24}