Struct MoaModel 

pub struct MoaModel { /* private fields */ }

Mixture-of-Agents single-fanout aggregation model.

References fan out in parallel (non-streaming) → outputs are spliced into the aggregator prompt → the aggregator produces the final result. One generate_text / stream_text call, no agent loop.

Implementations

impl MoaModel

pub fn new( references: Vec<ChildModel>, aggregator: ChildModel, config: MoaConfig, ) -> Self

Trait Implementations

impl LanguageModel for MoaModel

fn provider(&self) -> &str

Provider name, e.g. "openai".

fn model_id(&self) -> &str

Model identifier, e.g. "gpt-4o".

fn retry_config(&self) -> RetryConfig

Provider/model retry settings used when the caller does not override the retry count.

fn do_generate<'life0, 'life1, 'async_trait>( &'life0 self, options: &'life1 CallOptions, ) -> Pin<Box<dyn Future<Output = Result<GenerateResult, AiMuxError>> + Send + 'async_trait>>

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

Generate a complete (non-streaming) response.

fn do_stream<'life0, 'life1, 'async_trait>( &'life0 self, options: &'life1 CallOptions, ) -> Pin<Box<dyn Future<Output = Result<StreamResult, AiMuxError>> + Send + 'async_trait>>

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

Generate a streaming response.

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

Specification version (always "v4").

fn config_snapshot(&self) -> ProviderRecord

RFC-0023: 配置侧快照供录制。默认返回最小信息(provider/model_id); 各 provider 覆盖以提供 base_url/profile/api_key 来源等完整配置。 透明 decorator(TraceLayer 等)必须覆盖并转发 inner 快照。