dataflow_rs/engine/
message.rs

1use chrono::{DateTime, Utc};
2use datalogic_rs::DataValue;
3
4#[derive(Debug, Clone)]
5pub struct Message<'a> {
6    pub id: String,
7    pub data: DataValue<'a>,
8    pub payload: DataValue<'a>,
9    pub metadata: DataValue<'a>,
10    pub temp_data: DataValue<'a>,
11    pub audit_trail: Vec<AuditTrail<'a>>,
12}
13
14#[derive(Debug, Clone)]
15pub struct AuditTrail<'a> {
16    pub workflow_id: String,
17    pub task_id: String,
18    pub timestamp: DateTime<Utc>,
19    pub changes: Vec<Change<'a>>,
20}
21
22#[derive(Debug, Clone)]
23pub struct Change<'a> {
24    pub path: String,
25    pub old_value: DataValue<'a>,
26    pub new_value: DataValue<'a>,
27}

dataflow_rs/engine/message.rs

dataflow_rs/engine/
message.rs