Expand description
HTTP endpoint handlers for the local MessageBus.
Routes: POST /api/bus/register - Register an agent POST /api/bus/send - Send a message to an agent POST /api/bus/inject - Inject into an agentβs terminal (jekt) POST /api/bus/broadcast - Broadcast to all agents GET /api/bus/messages - Read queued messages (polling fallback) GET /api/bus/agents - List connected agents POST /api/bus/messages/delete - Delete messages by ID
StructsΒ§
- Broadcast
Request π - Delete
Messages πRequest - Inject
Request π - Read
Messages πQuery - Register
Request π - Send
Request π
FunctionsΒ§
- default_
limit π - handle_
broadcast π - POST /api/bus/broadcast
- handle_
delete_ πmessages - POST /api/bus/messages/delete
- handle_
inject π - POST /api/bus/inject
- handle_
list_ πagents - GET /api/bus/agents
- handle_
read_ πmessages - GET /api/bus/messages?agent_id=β¦&limit=β¦
- handle_
register π - POST /api/bus/register
- handle_
send π - POST /api/bus/send
- parse_
priority π