# draiven-io/agentic-bus architecture

> Architecture diagram of the GitHub repository draiven-io/agentic-bus, generated by GitDiagram from its file tree, README and a sample of source files (last updated 2026-09-25). It is an AI-made overview: check details against the source.

- Interactive diagram: https://gitdiagram.com/draiven-io/agentic-bus
- Repository: https://github.com/draiven-io/agentic-bus

## Overview

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: [`agentic_bus/coordinator/runtime.py`](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/runtime.py) (Coordinator runtime), [`agentic_bus/core/transport`](https://github.com/draiven-io/agentic-bus/tree/main/agentic_bus/core/transport) (WebSocket transport), [`agentic_bus/agents`](https://github.com/draiven-io/agentic-bus/tree/main/agentic_bus/agents) (Provider agents), [`agentic_bus/coordinator/negotiation/engine.py`](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/negotiation/engine.py) (Discovery and negotiation)

## Diagram (Mermaid)

```mermaid
flowchart TD

subgraph group_coordination["Coordination lifecycle"]
  node_runtime["Coordinator runtime<br/>[runtime.py]"]
  node_transport["WebSocket transport"]
  node_session["Session manager<br/>[manager.py]"]
  node_intent["Intent processing<br/>[processor.py]"]
  node_registry["Capability registry"]
  node_negotiation["Discovery and negotiation<br/>[engine.py]"]
  node_graph_builder["Plan graph builder<br/>[builder.py]"]
  node_supervisor["Execution supervisor<br/>[supervisor.py]"]
  node_validation["Answer validation<br/>[engine.py]"]
end

subgraph group_agents["Agent participation"]
  node_agents["Provider agents"]
  node_mcp["MCP bridge<br/>[mcp_bridge.py]"]
  node_managed_agents["Managed agents<br/>[managed_server.py]"]
end

subgraph group_governance["Governance and identity"]
  node_ibac["IBAC engine<br/>[engine.py]"]
  node_auth["Agent authentication<br/>[agent_auth.py]"]
end

subgraph group_operations["Administration and records"]
  node_admin_api["Admin REST API<br/>[api.py]"]
  node_admin_service["Admin service<br/>[service.py]"]
  node_database[("Persistent records<br/>[database.py]")]
  node_archive["Session archive"]
  node_telemetry["Telemetry tracing<br/>[tracing.py]"]
end

subgraph group_dashboard["Dashboard"]
  node_ui["Admin dashboard"]
end

node_requester(("Requester"))
node_dashboard_user(("Admin user"))
node_llm{{"LLM provider"}}

node_requester -->|"submits intent"| node_transport
node_transport -->|"dispatches messages"| node_runtime
node_runtime -->|"opens session"| node_session
node_runtime -->|"processes intent"| node_intent
node_runtime -->|"discovers and negotiates"| node_negotiation
node_negotiation -->|"queries capabilities"| node_registry
node_runtime -->|"checks authorization"| node_ibac
node_runtime -->|"composes plan"| node_graph_builder
node_runtime -->|"supervises execution"| node_supervisor
node_supervisor -->|"dispatches steps"| node_transport
node_transport -->|"exchanges messages"| node_agents
node_agents -->|"returns offers and results"| node_transport
node_runtime -->|"validates output"| node_validation
node_validation -->|"requests validation"| node_agents
node_runtime -->|"dissolves session"| node_session
node_runtime -->|"archives snapshot"| node_archive
node_archive -->|"writes archive"| node_database
node_admin_api -->|"dispatches operations"| node_admin_service
node_ui -->|"calls REST API"| node_admin_api
node_dashboard_user -->|"manages bus"| node_ui
node_admin_service -->|"manages records"| node_database
node_admin_service -->|"manages rules"| node_ibac
node_auth -->|"admits peers"| node_runtime
node_managed_agents -->|"participate as providers"| node_agents
node_mcp -->|"exposes MCP tools"| node_agents
node_negotiation -.->|"scores candidates"| node_llm
node_ibac -.->|"evaluates intent"| node_llm
node_runtime -->|"records traces"| node_telemetry

click node_runtime "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/runtime.py"
click node_transport "https://github.com/draiven-io/agentic-bus/tree/main/agentic_bus/core/transport"
click node_session "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/core/session/manager.py"
click node_intent "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/intent/processor.py"
click node_registry "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/core/registry/capability_registry.py"
click node_negotiation "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/negotiation/engine.py"
click node_graph_builder "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/graph/builder.py"
click node_supervisor "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/execution/supervisor.py"
click node_validation "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/validation/engine.py"
click node_agents "https://github.com/draiven-io/agentic-bus/tree/main/agentic_bus/agents"
click node_mcp "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/agents/mcp_bridge.py"
click node_managed_agents "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/agents/managed_server.py"
click node_ibac "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/core/ibac/engine.py"
click node_auth "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/core/auth/agent_auth.py"
click node_admin_api "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/admin/api.py"
click node_admin_service "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/admin/service.py"
click node_database "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/core/persistence/database.py"
click node_archive "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/core/persistence/session_archive_repository.py"
click node_telemetry "https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/core/telemetry/tracing.py"
click node_ui "https://github.com/draiven-io/agentic-bus/tree/main/ui/src/app"

classDef toneNeutral fill:#f8fafc,stroke:#334155,stroke-width:1.5px,color:#0f172a
classDef toneBlue fill:#dbeafe,stroke:#2563eb,stroke-width:1.5px,color:#172554
classDef toneAmber fill:#fef3c7,stroke:#d97706,stroke-width:1.5px,color:#78350f
classDef toneMint fill:#dcfce7,stroke:#16a34a,stroke-width:1.5px,color:#14532d
classDef toneRose fill:#ffe4e6,stroke:#e11d48,stroke-width:1.5px,color:#881337
classDef toneIndigo fill:#e0e7ff,stroke:#4f46e5,stroke-width:1.5px,color:#312e81
classDef toneTeal fill:#ccfbf1,stroke:#0f766e,stroke-width:1.5px,color:#134e4a
class node_runtime,node_transport,node_session,node_intent,node_registry,node_negotiation,node_graph_builder,node_supervisor,node_validation,node_dashboard_user toneBlue
class node_agents,node_mcp,node_managed_agents toneAmber
class node_ibac,node_auth,node_requester toneMint
class node_admin_api,node_admin_service,node_database,node_archive,node_telemetry toneRose
class node_ui,node_llm toneIndigo
```

## Components

### Coordination lifecycle

- [Coordinator runtime](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/runtime.py): `agentic_bus/coordinator/runtime.py`
- [WebSocket transport](https://github.com/draiven-io/agentic-bus/tree/main/agentic_bus/core/transport): `agentic_bus/core/transport`
- [Session manager](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/core/session/manager.py): `agentic_bus/core/session/manager.py`
- [Intent processing](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/intent/processor.py): `agentic_bus/coordinator/intent/processor.py`
- [Capability registry](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/core/registry/capability_registry.py): `agentic_bus/core/registry/capability_registry.py`
- [Discovery and negotiation](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/negotiation/engine.py): `agentic_bus/coordinator/negotiation/engine.py`
- [Plan graph builder](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/graph/builder.py): `agentic_bus/coordinator/graph/builder.py`
- [Execution supervisor](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/execution/supervisor.py): `agentic_bus/coordinator/execution/supervisor.py`
- [Answer validation](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/validation/engine.py): `agentic_bus/coordinator/validation/engine.py`

### Agent participation

- [Provider agents](https://github.com/draiven-io/agentic-bus/tree/main/agentic_bus/agents): `agentic_bus/agents`
- [MCP bridge](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/agents/mcp_bridge.py): `agentic_bus/agents/mcp_bridge.py`
- [Managed agents](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/agents/managed_server.py): `agentic_bus/agents/managed_server.py`

### Governance and identity

- [IBAC engine](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/core/ibac/engine.py): `agentic_bus/core/ibac/engine.py`
- [Agent authentication](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/core/auth/agent_auth.py): `agentic_bus/core/auth/agent_auth.py`

### Administration and records

- [Admin REST API](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/admin/api.py): `agentic_bus/coordinator/admin/api.py`
- [Admin service](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/coordinator/admin/service.py): `agentic_bus/coordinator/admin/service.py`
- [Persistent records](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/core/persistence/database.py): `agentic_bus/core/persistence/database.py`
- [Session archive](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/core/persistence/session_archive_repository.py): `agentic_bus/core/persistence/session_archive_repository.py`
- [Telemetry tracing](https://github.com/draiven-io/agentic-bus/blob/main/agentic_bus/core/telemetry/tracing.py): `agentic_bus/core/telemetry/tracing.py`

### Dashboard

- [Admin dashboard](https://github.com/draiven-io/agentic-bus/tree/main/ui/src/app): `ui/src/app`

### Other components

- **Requester**
- **Admin user**
- **LLM provider**

## Connections

- 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