Skip to main content

CompositeExecutor

Struct CompositeExecutor 

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

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, 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§

Source§

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

Source

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

Create a new CompositeExecutor wrapping first and second.

Trait Implementations§

Source§

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

Source§

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

Formats the value using the given formatter. Read more
Source§

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

Source§

fn requires_confirmation(&self, call: &ToolCall) -> bool

Return true when either inner executor requires confirmation for call.

Mirrors the OR-forwarding used by Self::is_tool_retryable and Self::is_tool_speculatable — without this override the base ToolExecutor::requires_confirmation default (false) silently bypasses confirmation gating for any executor composed under CompositeExecutor. See #5900.

Source§

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

Forward the active skill’s env injection to BOTH inner executors.

The base ToolExecutor::set_skill_env is a no-op, so without this override the composition tree built in agent_setup silently swallows env injection — the underlying ShellExecutor never sees GITHUB_TOKEN etc. Each layer ignores the call if it does not own a skill_env slot; layers that do (e.g. ShellExecutor) update their state. See #3869.

Source§

fn set_effective_trust(&self, level: SkillTrustLevel)

Forward the active skill’s trust level to BOTH inner executors.

Mirrors Self::set_skill_env: without this override, TrustGateExecutor never observes a non-Trusted level when composed under CompositeExecutor, leaving quarantine enforcement effectively bypassed. See #3869.

Source§

fn checkpoint_undo(&self, n: usize) -> CheckpointActionResult

Delegate undo to the first inner executor that supports checkpoints.

Source§

fn checkpoint_redo(&self) -> CheckpointActionResult

Delegate redo to the first inner executor that supports checkpoints.

Source§

fn checkpoint_list(&self) -> CheckpointListResult

Delegate list to the first inner executor that supports checkpoints.

Source§

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

Parse response for fenced tool blocks and execute them. Read more
Source§

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

Execute bypassing confirmation checks (called after user approves). Read more
Source§

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

Return the tool definitions this executor can handle. Read more
Source§

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. Read more
Source§

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

Execute a structured tool call bypassing confirmation checks. Read more
Source§

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

Whether the executor can safely retry this tool call on a transient error. Read more
Source§

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

Whether a tool call can be safely dispatched speculatively (before the LLM finishes). Read more

Auto Trait Implementations§

§

impl<A, B> Freeze for CompositeExecutor<A, B>
where A: Freeze, B: Freeze,

§

impl<A, B> RefUnwindSafe for CompositeExecutor<A, B>

§

impl<A, B> Send for CompositeExecutor<A, B>

§

impl<A, B> Sync for CompositeExecutor<A, B>

§

impl<A, B> Unpin for CompositeExecutor<A, B>
where A: Unpin, B: Unpin,

§

impl<A, B> UnsafeUnpin for CompositeExecutor<A, B>
where A: UnsafeUnpin, B: UnsafeUnpin,

§

impl<A, B> UnwindSafe for CompositeExecutor<A, B>
where A: UnwindSafe, B: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> ErasedToolExecutor for T
where T: ToolExecutor,

Source§

fn execute_erased<'a>( &'a self, response: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Option<ToolOutput>, ToolError>> + Send + 'a>>

Source§

fn execute_confirmed_erased<'a>( &'a self, response: &'a str, ) -> Pin<Box<dyn Future<Output = Result<Option<ToolOutput>, ToolError>> + Send + 'a>>

Source§

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

Source§

fn execute_tool_call_erased<'a>( &'a self, call: &'a ToolCall, ) -> Pin<Box<dyn Future<Output = Result<Option<ToolOutput>, ToolError>> + Send + 'a>>

Source§

fn execute_tool_call_confirmed_erased<'a>( &'a self, call: &'a ToolCall, ) -> Pin<Box<dyn Future<Output = Result<Option<ToolOutput>, ToolError>> + Send + 'a>>

Required (no default). TrustGateExecutor-style wrappers that override ToolExecutor::execute_tool_call_confirmed reach it through the blanket impl below. Other implementors should fall back to execute_tool_call_erased (normal enforcement path) unless they need to replicate confirmed-path-specific behavior (e.g. a fallback that only applies on the unconfirmed path must be mirrored explicitly, not assumed). See erased_tool_executor_no_inner_defaults! for leaf executors with no wrapped inner.
Source§

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

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

fn set_effective_trust(&self, level: SkillTrustLevel)

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

fn checkpoint_undo_erased(&self, n: usize) -> CheckpointActionResult

Undo the last n checkpointed write commands. Read more
Source§

fn checkpoint_redo_erased(&self) -> CheckpointActionResult

Redo the last undone checkpoint. Read more
Source§

fn checkpoint_list_erased(&self) -> CheckpointListResult

List the current undo stack entries and redo depth. Read more
Source§

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

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

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

Whether a tool call can be safely dispatched speculatively. Read more
Source§

fn requires_confirmation_erased(&self, call: &ToolCall) -> bool

Return true when call would require user confirmation before execution. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<L> LayerExt<L> for L

Source§

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

Applies the layer to a service and wraps it in Layered.
Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Sized + Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more