Struct HostConnectivityUpdatedPayload 

#[non_exhaustive]
pub struct HostConnectivityUpdatedPayload {
    pub tenant_id: Uuid,
    pub updates: Vec<HostConnectivityUpdate>,
}

Controller → MQTT service: agent connectivity changed for one or more hosts.

Published to NATS with target_capability = "update_tracking" so that the MQTT service on whichever controller the agent is connected to broadcasts the connectivity state to all MQTT services across the cluster. This is the canonical source of truth for {prefix}/hosts/{h}/connectivity/state.

Multi-controller safety: published by the controller that owns the agent WebSocket connection (the only one with authoritative live state). All other controllers receive this via NATS and update their caches.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

tenant_id: Uuid

Tenant this update belongs to.

updates: Vec<HostConnectivityUpdate>

One entry per host whose connectivity changed.

Implementations

impl HostConnectivityUpdatedPayload

pub fn new(tenant_id: Uuid, updates: Vec<HostConnectivityUpdate>) -> Self

Creates a new payload.

Trait Implementations

impl Clone for HostConnectivityUpdatedPayload

fn clone(&self) -> HostConnectivityUpdatedPayload

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HostConnectivityUpdatedPayload

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for HostConnectivityUpdatedPayload

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for HostConnectivityUpdatedPayload

impl PartialEq for HostConnectivityUpdatedPayload

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for HostConnectivityUpdatedPayload

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 HostConnectivityUpdatedPayload

impl WireValidate for HostConnectivityUpdatedPayload

fn wire_validate(&self) -> Result<(), WireValidationError>

Validate that all fields are within wire protocol size limits.