How draiven-io/agentic-bus works
Agentic Bus is a Liquid Interfaces Protocol coordination runtime: a requester submits natural-language intent, the coordinator discovers and negotiates with agents, governs and composes a plan, executes it, validates the result when required, and dissolves the live session. The README documents the lifecycle and dashboard capabilities; sampled source confirms session state, negotiation, IBAC, validation, authentication, and persistence behavior. Some subsystem wiring is therefore shown only where the README explicitly establishes it.
Main entry points: runtime.py Coordinator runtime · transport WebSocket transport · agents Provider agents · engine.py Discovery and negotiation
Components 23
Coordination lifecycle
- Coordinator runtime
agentic_bus/coordinator/runtime.py - WebSocket transport
agentic_bus/core/transport - Session manager
agentic_bus/core/session/manager.py - Intent processing
agentic_bus/coordinator/intent/processor.py - Capability registry
agentic_bus/core/registry/capability_registry.py - Discovery and negotiation
agentic_bus/coordinator/negotiation/engine.py - Plan graph builder
agentic_bus/coordinator/graph/builder.py - Execution supervisor
agentic_bus/coordinator/execution/supervisor.py - Answer validation
agentic_bus/coordinator/validation/engine.py
Agent participation
- Provider agents
agentic_bus/agents - MCP bridge
agentic_bus/agents/mcp_bridge.py - Managed agents
agentic_bus/agents/managed_server.py
Governance and identity
- IBAC engine
agentic_bus/core/ibac/engine.py - Agent authentication
agentic_bus/core/auth/agent_auth.py
Administration and records
- Admin REST API
agentic_bus/coordinator/admin/api.py - Admin service
agentic_bus/coordinator/admin/service.py - Persistent records
agentic_bus/core/persistence/database.py - Session archive
agentic_bus/core/persistence/session_archive_repository.py - Telemetry tracing
agentic_bus/core/telemetry/tracing.py
Dashboard
- Admin dashboard
ui/src/app
Other components
- Requester
- Admin user
- LLM provider
Connections 28
- Requester → WebSocket transport: submits intent
- WebSocket transport → Coordinator runtime: dispatches messages
- Coordinator runtime → Session manager: opens session
- Coordinator runtime → Intent processing: processes intent
- Coordinator runtime → Discovery and negotiation: discovers and negotiates
- Discovery and negotiation → Capability registry: queries capabilities
- Coordinator runtime → IBAC engine: checks authorization
- Coordinator runtime → Plan graph builder: composes plan
- Coordinator runtime → Execution supervisor: supervises execution
- Execution supervisor → WebSocket transport: dispatches steps
- WebSocket transport → Provider agents: exchanges messages
- Provider agents → WebSocket transport: returns offers and results
- Coordinator runtime → Answer validation: validates output
- Answer validation → Provider agents: requests validation
- Coordinator runtime → Session manager: dissolves session
- Coordinator runtime → Session archive: archives snapshot
- Session archive → Persistent records: writes archive
- Admin REST API → Admin service: dispatches operations
- Admin dashboard → Admin REST API: calls REST API
- Admin user → Admin dashboard: manages bus
- Admin service → Persistent records: manages records
- Admin service → IBAC engine: manages rules
- Agent authentication → Coordinator runtime: admits peers
- Managed agents → Provider agents: participate as providers
- MCP bridge → Provider agents: exposes MCP tools
- Discovery and negotiation → LLM provider: scores candidates
- IBAC engine → LLM provider: evaluates intent
- Coordinator runtime → Telemetry tracing: records traces