Module messagebus 

Local MessageBus for inter-agent communication.

Provides agent registration, point-to-point messaging, terminal injection, and broadcast — all over localhost with no cloud dependency.

Structs

AgentConnection 🔒

Internal agent connection state.

AgentInfo

Info about a connected agent.

BusMessage

MessageBus

Enums

MessageType

Priority

Constants

MAX_OFFLINE_QUEUE 🔒

Maximum messages queued per offline agent.

MAX_READ_LIMIT 🔒

Maximum messages returned per read_messages call.

MESSAGE_TTL_SECS 🔒

Message time-to-live in seconds (1 hour).