Struct AgentRunner 

pub struct AgentRunner { /* private fields */ }

AgentRunner composes multiple runners into a single unified stream with optional global analyzers applied to the merged stream

Implementations

impl AgentRunner

pub fn new() -> Self

Create a new AgentRunner

pub fn add_runner(self, runner: Box<dyn Runner>) -> Self

Add a pre-configured runner with its analyzer chain

pub fn add_global_analyzer(self, analyzer: Box<dyn Analyzer>) -> Self

Add analyzer that will be applied to the merged stream

pub fn runner_count(&self) -> usize

Get the number of configured runners

pub fn analyzer_count(&self) -> usize

Get the number of configured global analyzers

Trait Implementations

impl Default for AgentRunner

fn default() -> AgentRunner

Returns the “default value” for a type.

impl Runner for AgentRunner

fn run<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<EventStream, RunnerError>> + Send + 'async_trait>>

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

Run the data collection and return a stream of events

fn add_analyzer(self, analyzer: Box<dyn Analyzer>) -> Self

Add an analyzer to this runner’s processing chain