Struct Runtime 

pub struct Runtime<M: Model, H: Hook> {
    pub model: M,
    pub hook: H,
    /* private fields */
}

The walrus runtime — agent registry, session store, and hook orchestration.

Agents are stored as plain immutable values. Sessions own conversation history behind per-session Arc<Mutex<Session>>. The sessions map uses RwLock for concurrent access without requiring &mut self.

Fields

model: M

hook: H

Implementations

impl<M: Model + Send + Sync + Clone + 'static, H: Hook + 'static> Runtime<M, H>

pub async fn new(model: M, hook: H, tool_tx: Option<ToolSender>) -> Self

Create a new runtime with the given model and hook backend.

Calls hook.on_register_tools() to populate the schema registry. Pass tool_tx to enable tool dispatch from agents; None means agents have no tool dispatch (e.g. CLI without a daemon).

pub fn register_tool(&mut self, tool: Tool)

Register a tool schema.

pub fn unregister_tool(&mut self, name: &str) -> bool

Remove a tool schema by name. Returns true if it existed.

pub fn add_agent(&mut self, config: AgentConfig)

Register an agent from its configuration.

Calls hook.on_build_agent(config) to enrich the config, then builds the agent with a filtered schema snapshot and the runtime’s tool_tx.

pub fn agent(&self, name: &str) -> Option<AgentConfig>

Get a registered agent’s config by name (cloned).

pub fn agents(&self) -> Vec<AgentConfig>

Get all registered agent configs (cloned, alphabetical order).

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

Get a reference to an agent by name.

pub async fn create_session(&self, agent: &str, created_by: &str) -> Result<u64>

Create a new session for the given agent. Returns the session ID.

pub async fn close_session(&self, id: u64) -> bool

Close (remove) a session by ID. Returns true if it existed.

pub async fn session(&self, id: u64) -> Option<Arc<Mutex<Session>>>

Get a session mutex by ID.

pub async fn sessions(&self) -> Vec<Arc<Mutex<Session>>>

Get all session mutexes (for iteration/listing).

pub async fn send_to( &self, session_id: u64, content: &str, sender: &str, ) -> Result<AgentResponse>

Send a message to a session and run to completion.

Locks the session, looks up the agent, pushes the user message, delegates to agent.run(), and forwards events to hook.on_event().

pub fn stream_to( &self, session_id: u64, content: &str, sender: &str, ) -> impl Stream<Item = AgentEvent> + '_

Send a message to a session and stream response events.

Locks the session, looks up the agent, pushes the user message, and streams events forwarded to hook.on_event().