Struct AgentRuntime 

pub struct AgentRuntime { /* private fields */ }

Implementations

impl AgentRuntime

pub fn new( agent: Arc<Agent>, broker: AnyBroker, sessions: Arc<SessionManager>, ) -> Self

pub fn with_memory(self, memory: Arc<LongTermMemory>) -> Self

pub fn with_redactor(self, redactor: Arc<Redactor>) -> Self

pub fn with_processing_store( self, store: Arc<dyn ProcessingControlStore>, ) -> Self

Phase 82.13.c — install the operator pause-check store. Pass the SAME Arc boot wired into the admin RPC dispatcher so a pause RPC reaches the inbound loop on the very next message. Without this builder, the runtime processes every inbound regardless of operator pause state (legacy / tests).

pub fn with_event_emitter(self, emitter: Arc<dyn AgentEventEmitter>) -> Self

Phase 82.13.c — install the agent event emitter for firehose drop notifications when the per-scope pending queue evicts an oldest entry. Production wires the same BroadcastAgentEventEmitter Phase 82.11 already plumbs to TranscriptWriter. None keeps eviction silent (tracing only).

pub fn with_transcripts_index(self, index: Arc<TranscriptsIndex>) -> Self

pub fn with_link_extractor(self, ext: Arc<LinkExtractor>) -> Self

Attach the shared link extractor. All AgentContexts built by this runtime inherit it so llm_behavior can fetch URLs in inbound messages and build the # LINK CONTEXT block.

pub fn with_web_search_router(self, router: Arc<WebSearchRouter>) -> Self

Attach the shared web-search router. Every AgentContext built by this runtime inherits it so the web_search tool can route.

pub fn with_pairing_gate(self, gate: Arc<PairingGate>) -> Self

Attach the shared pairing gate. Consulted before the per-sender rate limiter in the intake hot path so unknown senders never reach the agent’s behavior.

pub fn with_pairing_adapters(self, registry: PairingAdapterRegistry) -> Self

Attach the pairing channel-adapter registry. Adapters registered here are looked up by source_plugin on every inbound message when the gate is active, and used to normalise sender ids before store lookup. None (default) preserves legacy zero-adapter behaviour.

pub fn with_dispatch_ctx(self, ctx: Arc<DispatchToolContext>) -> Self

Phase 67 — install the DispatchToolContext shared by every AgentContext this runtime builds. Without this the dispatch tool handlers return a friendly error.

pub fn with_plan_approval_registry( self, registry: Arc<PlanApprovalRegistry>, ) -> Self

Phase 79.1 — install a process-shared plan-mode approval registry. Production wiring creates one per process and passes it here so the broker subscriber can resolve pending approvals from inbound [plan-mode] chat messages.

pub fn with_peers(self, peers: Arc<PeerDirectory>) -> Self

pub fn with_tool_base(self, tools: Arc<ToolRegistry>) -> Self

Attach the base tool registry used by this agent so the runtime can hand each session a per-binding filtered view via its internal cache. Without this, sessions fall back to the behavior’s own registry and pay a per-turn filter cost.

pub fn snapshot_handle(&self) -> Arc<ArcSwap<RuntimeSnapshot>>

Expose the runtime’s ArcSwap<RuntimeSnapshot> so the reload coordinator can swap a freshly-built snapshot in atomically without tearing down the runtime. Cheap Arc clone — callers typically stash the handle once at boot.

pub fn swap_snapshot(&self, new: Arc<RuntimeSnapshot>)

Atomic swap of the per-agent snapshot. Readers that already hold an Arc<RuntimeSnapshot> (session tasks mid-turn) keep their copy for the lifetime of that Arc; subsequent snapshot.load() calls see the new value.

pub fn reload_sender(&self) -> Sender<ReloadCommand>

Clone the ReloadCommand sender so the coordinator can push Apply commands. One sender per agent runtime; the receiver is drained inside start().

pub fn with_credentials(self, credentials: Arc<AgentCredentialResolver>) -> Self

Attach the credential resolver. All AgentContexts built by this runtime inherit it so outbound tools can look up the agent’s bound instance instead of publishing to the legacy single-account topic.

pub fn with_breakers(self, breakers: Arc<BreakerRegistry>) -> Self

pub fn router(&self) -> Arc<AgentRouter>

pub async fn start(&self) -> Result<()>

pub async fn stop(&self)