Struct ReactOperator 

pub struct ReactOperator<P: Provider> { /* private fields */ }

A full-featured Operator implementation with a ReAct loop.

Generic over P: Provider (not object-safe). The object-safe boundary is layer0::Operator, which ReactOperator<P> implements via #[async_trait].

Implementations

impl<P: Provider> ReactOperator<P>

pub fn new( provider: P, tools: ToolRegistry, context_strategy: Box<dyn ContextStrategy>, hooks: HookRegistry, state_reader: Arc<dyn StateReader>, config: ReactConfig, ) -> Self

Create a new ReactOperator with all dependencies.

pub fn with_planner(self, planner: Box<dyn ToolExecutionPlanner>) -> Self

Opt-in: set a custom tool execution planner.

pub fn with_concurrency_decider( self, decider: Box<dyn ConcurrencyDecider>, ) -> Self

Opt-in: set a custom concurrency decider.

pub fn with_metadata_concurrency(self) -> Self

Opt-in: use tool metadata to decide concurrency.

pub fn with_steering(self, s: Arc<dyn SteeringSource>) -> Self

Opt-in: attach a steering source.

Trait Implementations

impl<P: Provider + 'static> Operator for ReactOperator<P>

fn execute<'life0, 'async_trait>( &'life0 self, input: OperatorInput, ) -> Pin<Box<dyn Future<Output = Result<OperatorOutput, OperatorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute a single operator invocation.