Struct CallExecutor 

pub struct CallExecutor { /* private fields */ }

Executes MXP Call messages by invoking registered tools and the configured ModelAdapter.

Implementations

impl CallExecutor

pub fn new(adapter: Arc<dyn ModelAdapter>, tools: Arc<ToolRegistry>) -> Self

Creates a new call executor.

pub fn set_policy(&mut self, policy: Arc<dyn PolicyEngine>)

Configures the policy engine used for governance decisions.

pub fn with_policy(self, policy: Arc<dyn PolicyEngine>) -> Self

Configures the policy engine, returning the updated executor for chaining.

pub fn policy(&self) -> Option<&Arc<dyn PolicyEngine>>

Returns the policy engine if one has been configured.

pub fn set_policy_observer(&mut self, observer: Arc<dyn PolicyObserver>)

Installs a policy observer for integration hooks.

pub fn with_policy_observer(self, observer: Arc<dyn PolicyObserver>) -> Self

Configures a policy observer, returning the updated executor for chaining.

pub fn policy_observer(&self) -> Option<&Arc<dyn PolicyObserver>>

Returns the policy observer if configured.

pub async fn execute(&self, ctx: &HandlerContext) -> HandlerResult<CallOutcome>

Executes the call pipeline using data extracted from the handler context.

Errors

Returns HandlerError when payload decoding, tool execution, or model inference fails.

Trait Implementations

impl Clone for CallExecutor

fn clone(&self) -> CallExecutor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CallExecutor

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

Formats the value using the given formatter.