Struct XlxMonitor 

pub(crate) struct XlxMonitor {
    socket: UdpSocket,
    peer: SocketAddr,
    reflector: String,
}

A UDP client connected to a single XLX reflector’s monitor port.

Manages the UDP socket lifecycle and provides async methods for receiving parsed monitor messages. Create via XlxMonitor::connect and receive events via XlxMonitor::recv.

On drop, a best-effort "bye" datagram is sent to the reflector so it can clean up its client tracking state promptly.

Fields

socket: UdpSocket

The bound UDP socket, connected to the reflector’s monitor port.

peer: SocketAddr

The reflector’s monitor endpoint (ip:10001).

reflector: String

Reflector callsign for logging and database correlation.

Implementations

impl XlxMonitor

pub(crate) async fn connect( ip: IpAddr, reflector: String, ) -> Result<Self, Error>

Connects to a reflector’s XLX monitor port and sends the "hello" handshake.

Binds a new UDP socket on an ephemeral port, “connects” it to the reflector’s monitor address (so that subsequent send/recv calls are scoped to this peer), and sends the initial "hello" datagram.

The reflector will respond with three JSON datagrams (reflector info, nodes snapshot, stations snapshot) which can be read via recv.

Errors

Returns io::Error if socket binding or the initial send fails.

pub(crate) async fn recv(&self) -> Option<MonitorMessage>

Receives the next monitor message from the reflector.

Blocks (asynchronously) until a UDP datagram arrives or the 30-second timeout expires. Returns:

• Some(message) — a successfully parsed MonitorMessage.
• None — the timeout expired (no data received within 30 seconds), or the received datagram was not valid JSON and could not be parsed at all (not even as Unknown).

The caller should treat repeated None returns as a signal that the reflector is unresponsive and consider reconnecting.

pub(crate) const fn peer(&self) -> SocketAddr

Returns the peer socket address (ip:10001).

Trait Implementations

impl Debug for XlxMonitor

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

Formats the value using the given formatter.

impl Drop for XlxMonitor

fn drop(&mut self)

Best-effort "bye" on drop.

Uses try_send (non-async, non-blocking) because Drop cannot be async. If the send fails (e.g., the socket is already closed or the runtime is shutting down), the failure is silently ignored — the reflector will eventually time out the client entry on its own.