Struct RuntimeBridge 

pub struct RuntimeBridge { /* private fields */ }

The RuntimeBridge manages a simulated, in-process Symbiont runtime environment.

Implementations

impl RuntimeBridge

pub fn new() -> Self

Construct a RuntimeBridge with a deny-by-default communication policy.

Production callers should immediately follow with Self::set_comm_policy to install a policy containing the rules required for their agent topology. Inter-agent messaging will fail with PolicyDenied until rules are configured.

For tests or trusted single-tenant dev environments, use Self::new_permissive_for_dev to opt into allow-all semantics.

pub fn new_permissive_for_dev() -> Self

Construct a RuntimeBridge with a permissive (allow-all) communication policy.

This is ONLY safe for local development, tests, or single-tenant trusted environments. Never use in multi-tenant or production deployments: permissive mode allows any agent to message any other agent with no gating.

pub fn with_policy(comm_policy_gate: Arc<CommunicationPolicyGate>) -> Self

Construct a RuntimeBridge with an explicit communication policy gate.

pub fn set_inference_provider(&self, provider: Arc<dyn InferenceProvider>)

Set the inference provider for reasoning builtins.

pub fn agent_registry(&self) -> Arc<AgentRegistry>

Get the agent registry.

pub fn comm_bus(&self) -> Option<Arc<dyn CommunicationBus + Send + Sync>>

Get the communication bus (if initialized).

pub fn set_comm_policy(&self, policy: Arc<CommunicationPolicyGate>)

Replace the communication policy gate.

pub fn reasoning_context(&self) -> ReasoningBuiltinContext

Get the reasoning context for async builtins.

Includes the communication bus and policy gate if they’ve been initialized via [initialize]. The bus is used by ask, send_to, parallel, and race builtins for policy-gated, audit-logged agent-to-agent messaging.

pub async fn initialize(&self) -> Result<(), String>

Initialize the runtime bridge components asynchronously.

Sets up the lifecycle controller, context manager, and communication bus. After this returns, reasoning_context() produces a context with a live bus and policy gate, so DSL builtins like ask and send_to will route messages through the audited communication path.

pub async fn initialize_agent( &self, config: AgentConfig, ) -> Result<AgentId, String>

pub async fn check_capability( &self, agent_id: &str, capability: &Capability, ) -> Result<PolicyDecision, String>

Checks if a given capability is allowed for an agent.

pub async fn register_event_handler( &self, agent_id: &str, event_name: &str, _event_type: &str, ) -> Result<(), String>

Register an event handler for an agent (stub implementation)

pub async fn emit_event( &self, agent_id: &str, event_name: &str, _data: &Value, ) -> Result<(), String>

Emit an event from an agent (stub implementation)

Trait Implementations

impl Default for RuntimeBridge

fn default() -> Self

Returns the “default value” for a type.