Enum WsMessage 

pub enum WsMessage {
    LoadFile {
        path: String,
    },
    InjectEvent {
        event_type: String,
        data: Value,
    },
    GetStreams,
    GetMetrics,
    LoadResult {
        success: bool,
        streams_loaded: usize,
        error: Option<String>,
    },
    Streams {
        data: Vec<StreamInfo>,
    },
    Event {
        id: String,
        event_type: String,
        timestamp: String,
        data: Value,
    },
    OutputEvent {
        event_type: String,
        data: Value,
        timestamp: String,
    },
    Metrics {
        events_processed: u64,
        output_events_emitted: u64,
        active_streams: usize,
        uptime: f64,
        memory_usage: u64,
        cpu_usage: f64,
    },
    EventInjected {
        event_type: String,
        success: bool,
    },
    Error {
        message: String,
    },
}

WebSocket message types for client-server communication

Variants

LoadFile

Load a VPL file

Fields

path: String

InjectEvent

Inject an event into the engine

Fields

event_type: String

data: Value

GetStreams

Request list of streams

GetMetrics

Request current metrics

LoadResult

Result of loading a file

Fields

success: bool

streams_loaded: usize

error: Option<String>

Streams

List of streams

Fields

data: Vec<StreamInfo>

Event

Event notification

Fields

id: String

event_type: String

timestamp: String

data: Value

OutputEvent

Output event notification

Fields

event_type: String

data: Value

timestamp: String

Metrics

Current metrics

Fields

events_processed: u64

output_events_emitted: u64

active_streams: usize

uptime: f64

memory_usage: u64

cpu_usage: f64

EventInjected

Result of event injection

Fields

event_type: String

success: bool

Error

Error message

Fields

message: String

Trait Implementations

impl Clone for WsMessage

fn clone(&self) -> WsMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WsMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for WsMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for WsMessage

fn eq(&self, other: &WsMessage) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for WsMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for WsMessage