Module messagebus

Module messagebus 

Source
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Β§

BroadcastRequest πŸ”’
DeleteMessagesRequest πŸ”’
InjectRequest πŸ”’
ReadMessagesQuery πŸ”’
RegisterRequest πŸ”’
SendRequest πŸ”’

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 πŸ”’