Struct Runtime 

pub struct Runtime { /* private fields */ }

The Agency Runtime - main entry point for running agents

Implementations

impl Runtime

pub fn new() -> AgencyResult<Self>

Create a new runtime with default configuration

pub fn with_config(config: RuntimeConfig) -> AgencyResult<Self>

Create a new runtime with custom configuration

pub fn in_memory() -> AgencyResult<Self>

Create an in-memory runtime (for testing)

pub fn register_agent(&mut self, agent: Agent)

Register an agent

pub fn get_agent(&self, name: &str) -> Option<&Arc<Agent>>

Get a registered agent

pub fn list_agents(&self) -> Vec<&str>

List registered agents

pub fn tools(&self) -> &ToolRegistry

Get the tool registry

pub fn sessions(&self) -> &SessionManager

Get the session manager

pub async fn run( &self, agent_name: &str, message: &str, options: Option<RunOptions>, ) -> AgencyResult<ExecutionResult>

Run an agent with a message

pub async fn run_stream( &self, agent_name: &str, message: &str, options: Option<RunOptions>, ) -> AgencyResult<(ExecutionResult, Receiver<AgencyEvent>)>

Run an agent with streaming events

pub async fn run_pipeline( &self, pipeline: &Pipeline, input: &str, options: Option<RunOptions>, ) -> AgencyResult<OrchestratorResult>

Run a pipeline

pub async fn run_swarm( &self, swarm: &Swarm, input: &str, options: Option<RunOptions>, ) -> AgencyResult<OrchestratorResult>

Run a swarm

pub fn create_session( &self, agent_name: &str, user_id: Option<String>, ) -> AgencyResult<Session>

Create a new session for an agent

pub fn get_session(&self, session_id: &str) -> AgencyResult<Option<Session>>

Get a session by ID

pub fn list_sessions( &self, agent_name: &str, limit: Option<u32>, ) -> AgencyResult<Vec<Session>>

List sessions for an agent

pub fn delete_session(&self, session_id: &str) -> AgencyResult<bool>

Delete a session