Struct TelemetryData 

pub struct TelemetryData {
    pub device_id: i32,
    pub device_name: String,
    pub timestamp: DateTime<Utc>,
    pub values: Vec<PointValue>,
    pub metadata: HashMap<String, Value>,
}

Northward envelope protocol types (re-exported at crate root). Telemetry data message

Fields

device_id: i32

Device identifier

device_name: String

Device name

timestamp: DateTime<Utc>

Timestamp of the data

values: Vec<PointValue>

Telemetry values as point-id keyed updates.

point_id is the primary key for all hot-path operations.

metadata: HashMap<String, Value>

Additional metadata

Implementations

impl TelemetryData

pub fn new( device_id: i32, device_name: impl Into<String>, values: Vec<PointValue>, ) -> Self

Create new telemetry data

pub fn with_metadata(self, metadata: HashMap<String, Value>) -> Self

Add metadata to the telemetry data

pub fn to_json_bytes(&self) -> Result<Bytes, Error>

Serialize to JSON bytes with zero-copy optimization

Trait Implementations

impl Clone for TelemetryData

fn clone(&self) -> TelemetryData

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TelemetryData

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TelemetryData

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TelemetryData

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

where __S: Serializer,

Serialize this value into the given Serde serializer.