Struct Env 

pub struct Env<H: Host = NoHost> {
    pub host: H,
    /* private fields */
}

Fields

host: H

Host providing server-specific functionality.

Implementations

impl<H: Host> Env<H>

pub fn new( skills: SkillHandler, mcp: McpHandler, cwd: PathBuf, memory: Option<Memory>, host: H, ) -> Self

Create a new Env with the given backends.

pub fn memory(&self) -> Option<&Memory>

Access memory.

pub fn mcp_servers(&self) -> Vec<(String, Vec<String>)>

List connected MCP servers with their tool names.

pub fn register_scope(&mut self, name: String, config: &AgentConfig)

Register an agent’s scope for dispatch enforcement.

pub async fn dispatch_tool( &self, name: &str, args: &str, agent: &str, sender: &str, conversation_id: Option<u64>, ) -> Result<String, String>

Route a tool call by name to the appropriate handler.

impl<H: Host> Env<H>

pub async fn dispatch_mcp( &self, args: &str, agent: &str, ) -> Result<String, String>

impl<H: Host> Env<H>

pub async fn dispatch_recall(&self, args: &str) -> Result<String, String>

pub async fn dispatch_remember(&self, args: &str) -> Result<String, String>

pub async fn dispatch_forget(&self, args: &str) -> Result<String, String>

pub async fn dispatch_memory(&self, args: &str) -> Result<String, String>

impl<H: Host> Env<H>

pub async fn dispatch_edit( &self, args: &str, conversation_id: Option<u64>, ) -> Result<String, String>

impl<H: Host> Env<H>

pub async fn dispatch_read( &self, args: &str, conversation_id: Option<u64>, ) -> Result<String, String>

impl<H: Host> Env<H>

pub async fn dispatch_bash( &self, args: &str, conversation_id: Option<u64>, ) -> Result<String, String>

Dispatch a bash tool call — run a command directly.

A non-zero exit code is not an Err — the shell ran successfully and the JSON payload describes the outcome. Only dispatcher-level failures (spawn error, wait error, timeout) become Err.

impl<H: Host> Env<H>

pub async fn dispatch_skill( &self, args: &str, agent: &str, ) -> Result<String, String>

Trait Implementations

impl<H: Host + 'static> Hook for Env<H>

fn on_build_agent(&self, config: AgentConfig) -> AgentConfig

Called by Runtime::add_agent() before building the Agent.

fn preprocess(&self, agent: &str, content: &str) -> String

Called by Runtime to preprocess user content before it becomes a message.

fn on_before_run( &self, agent: &str, conversation_id: u64, history: &[HistoryEntry], ) -> Vec<HistoryEntry>

Called by Runtime before each agent run (send_to / stream_to).

async fn on_register_tools(&self, tools: &mut ToolRegistry)

Called by Runtime::new() to register tool schemas into the registry.

fn on_event(&self, agent: &str, conversation_id: u64, event: &AgentEvent)

Called by Runtime after each agent step during execution.