dora_message/
daemon_to_daemon.rs

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