Enum HubMessage 

pub enum HubMessage {
    AuthSuccess {
        sensor_id: String,
        tenant_id: String,
        capabilities: Vec<String>,
        protocol_version: Option<String>,
    },
    AuthFailed {
        error: String,
    },
    SignalAck {
        sequence_id: u64,
    },
    BatchAck {
        count: u32,
        sequence_id: u64,
    },
    Ping {
        timestamp: i64,
    },
    Error {
        error: String,
        code: Option<String>,
    },
    BlocklistSnapshot {
        entries: Vec<BlocklistEntry>,
        sequence_id: u64,
    },
    BlocklistUpdate {
        updates: Vec<BlocklistUpdate>,
        sequence_id: u64,
    },
    ConfigUpdate {
        config: Value,
        version: String,
    },
    RulesUpdate {
        rules: Value,
        version: String,
    },
    PushConfig {
        command_id: String,
        payload: ConfigPayload,
    },
    PushRules {
        command_id: String,
        payload: Value,
    },
    Restart {
        command_id: String,
        payload: Value,
    },
    CollectDiagnostics {
        command_id: String,
        payload: Value,
    },
    Update {
        command_id: String,
        payload: Value,
    },
    SyncBlocklist {
        command_id: String,
        payload: Value,
    },
    TunnelOpen {
        tunnel_id: String,
        target_host: String,
        target_port: u16,
    },
    TunnelClose {
        tunnel_id: String,
    },
    TunnelData {
        tunnel_id: String,
        data: String,
    },
}

Messages from hub to sensor.

Variants

AuthSuccess

Authentication success

Fields

sensor_id: String

tenant_id: String

capabilities: Vec<String>

protocol_version: Option<String>

Protocol version negotiated by the hub.

AuthFailed

Authentication failed

Fields

error: String

SignalAck

Signal acknowledged

Fields

sequence_id: u64

BatchAck

Batch acknowledged

Fields

count: u32

sequence_id: u64

Ping

Ping (requires pong response)

Fields

timestamp: i64

Error

Error from hub

Fields

error: String

code: Option<String>

BlocklistSnapshot

Full blocklist snapshot

Fields

entries: Vec<BlocklistEntry>

sequence_id: u64

BlocklistUpdate

Incremental blocklist update

Fields

updates: Vec<BlocklistUpdate>

sequence_id: u64

ConfigUpdate

Configuration update (Legacy/Direct)

Fields

config: Value

version: String

RulesUpdate

Rules update

Fields

rules: Value

version: String

PushConfig

Push Config Command (via CommandSender)

Fields

command_id: String

payload: ConfigPayload

PushRules

Push Rules Command (via CommandSender)

Fields

command_id: String

payload: Value

Restart

Restart Command (via CommandSender)

Fields

command_id: String

payload: Value

CollectDiagnostics

Collect Diagnostics Command (via CommandSender)

Fields

command_id: String

payload: Value

Update

Update Command (via CommandSender)

Fields

command_id: String

payload: Value

SyncBlocklist

Sync Blocklist Command (via CommandSender)

Fields

command_id: String

payload: Value

TunnelOpen

Tunnel open request from hub

Fields

tunnel_id: String

target_host: String

target_port: u16

TunnelClose

Tunnel close request from hub

Fields

tunnel_id: String

TunnelData

Tunnel data from hub

Fields

tunnel_id: String

data: String

Implementations

impl HubMessage

pub fn from_json(json: &str) -> Result<Self, Error>

Parse from JSON string.

Trait Implementations

impl Clone for HubMessage

fn clone(&self) -> HubMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HubMessage

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for HubMessage

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for HubMessage

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

where __S: Serializer,

Serialize this value into the given Serde serializer.