Struct CompositeExecutor 

pub struct CompositeExecutor<A: ToolExecutor, B: ToolExecutor> { /* private fields */ }

Chains two ToolExecutor implementations with first-match-wins dispatch.

For each method, first is tried first. If it returns Ok(None) (i.e. it does not handle the input), second is tried. If first returns an Err, the error propagates immediately without consulting second.

Use this to compose a chain of specialized executors at startup instead of a dynamic Vec<Box<dyn ...>>. Nest multiple CompositeExecutors to handle more than two backends.

Tool definitions from both executors are merged, with first taking precedence when both define a tool with the same ID.

Example

use zeph_tools::{
    CompositeExecutor, ShellExecutor, WebScrapeExecutor,
    config::{ShellConfig, ScrapeConfig},
};

let shell = ShellExecutor::new(&ShellConfig::default());
let scrape = WebScrapeExecutor::new(&ScrapeConfig::default());
let executor = CompositeExecutor::new(shell, scrape);
// executor handles both bash blocks and scrape/fetch tool calls.

Implementations

impl<A: ToolExecutor, B: ToolExecutor> CompositeExecutor<A, B>

pub fn new(first: A, second: B) -> Self

Create a new CompositeExecutor wrapping first and second.

Trait Implementations

impl<A: Debug + ToolExecutor, B: Debug + ToolExecutor> Debug for CompositeExecutor<A, B>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<A: ToolExecutor, B: ToolExecutor> ToolExecutor for CompositeExecutor<A, B>

async fn execute(&self, response: &str) -> Result<Option<ToolOutput>, ToolError>

Parse response for fenced tool blocks and execute them.

async fn execute_confirmed( &self, response: &str, ) -> Result<Option<ToolOutput>, ToolError>

Execute bypassing confirmation checks (called after user approves).

fn tool_definitions(&self) -> Vec<ToolDef>

Return the tool definitions this executor can handle.

async fn execute_tool_call( &self, call: &ToolCall, ) -> Result<Option<ToolOutput>, ToolError>

Execute a structured tool call. Returns Ok(None) if call.tool_id is not handled.

fn is_tool_retryable(&self, tool_id: &str) -> bool

Whether the executor can safely retry this tool call on a transient error.

fn execute_tool_call_confirmed( &self, call: &ToolCall, ) -> impl Future<Output = Result<Option<ToolOutput>, ToolError>> + Send

Execute a structured tool call bypassing confirmation checks.

fn set_skill_env(&self, _env: Option<HashMap<String, String>>)

Inject environment variables for the currently active skill. No-op by default.

fn set_effective_trust(&self, _level: SkillTrustLevel)

Set the effective trust level for the currently active skill. No-op by default.