Struct ChannelSteering 

pub struct ChannelSteering { /* private fields */ }

tokio::sync::mpsc-backed steering source. Producer side (SteeringHandle) lets external code call .steer(message) from anywhere; consumer side implements SteeringSource and drains the channel each batch.

Implementations

impl ChannelSteering

pub fn new() -> (Arc<Self>, SteeringHandle)

Trait Implementations

impl Plugin for ChannelSteering

fn name(&self) -> &'static str

Stable identifier for logs and telemetry.

fn capabilities(&self) -> PluginCapabilities

Which capabilities this plugin implements. Default: none — meaning pure observation by inheriting from EventObserver. Override and return the relevant set when adding behavior.

impl SteeringSource for ChannelSteering

fn next_steering_messages<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Vec<AgentMessage>> + Send + 'async_trait>>

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