Struct DefaultPipeline 

pub struct DefaultPipeline { /* private fields */ }

Default pipeline: ToolPolicy hooks + timeout + output truncation.

Implementations

impl DefaultPipeline

pub fn new( tool_policy: Option<Arc<dyn ToolPolicy>>, tool_timeout_ms: Option<u64>, max_output_chars: Option<usize>, ) -> Self

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

Trait Implementations

impl Clone for DefaultPipeline

fn clone(&self) -> DefaultPipeline

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl ToolExecutionPipeline for DefaultPipeline

fn execute<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tool: &'life1 dyn Tool, args: &'life2 Value, ctx: &'life3 ToolContext, ) -> Pin<Box<dyn Future<Output = AgentResult<ToolOutput>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,