wactorz_mqtt/
lib.rs

1//! # wactorz-mqtt
2//!
3//! Async MQTT transport for AgentFlow.
4//!
5//! Provides:
6//! - [`MqttClient`] — thin async wrapper around `rumqttc::AsyncClient`
7//! - [`topics`] — well-known topic string constants and builders
8//!
9//! All AgentFlow MQTT topics follow the pattern:
10//! `agents/{agent_id}/{event}` and `system/{event}`
11
12pub mod client;
13pub mod topics;
14
15pub use client::{MqttClient, MqttConfig, MqttEvent};