pulse-core 0.1.2

Core runtime and dataflow engine for Pulse — defines execution graph, operators, and streaming primitives.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};

/// Core data record with explicit event-time (event-time semantics).
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Record {
    pub event_time: DateTime<Utc>,
    pub value: serde_json::Value,
}

impl Record {
    pub fn new(event_time: DateTime<Utc>, value: serde_json::Value) -> Self {
        Self { event_time, value }
    }
    pub fn from_value<V: Into<serde_json::Value>>(v: V) -> Self {
        Self {
            event_time: chrono::Utc::now(),
            value: v.into(),
        }
    }
}