Struct MiddlewareConfig 

pub struct MiddlewareConfig {
    pub before_release: Vec<MiddlewareEntry>,
    pub on_provider_response: Vec<MiddlewareEntry>,
    pub before_prompt: Vec<MiddlewareEntry>,
    pub on_completion: Vec<MiddlewareEntry>,
    pub on_job_complete: Vec<MiddlewareEntry>,
    pub moderation_model: Option<Arc<dyn AiModel>>,
}

Top-level middleware configuration from agent YAML config.

Fields

before_release: Vec<MiddlewareEntry>

Middleware that runs before buffer release (edit + release stages).

on_provider_response: Vec<MiddlewareEntry>

Middleware that runs after LLM provider returns.

before_prompt: Vec<MiddlewareEntry>

Middleware that runs before constructing the LLM prompt.

on_completion: Vec<MiddlewareEntry>

Middleware that runs after deliberation completes (per round).

on_job_complete: Vec<MiddlewareEntry>

Middleware that runs once at job-final (terminal winner known).

moderation_model: Option<Arc<dyn AiModel>>

Optional AiModel instance for LLM moderation middleware. Set at runtime (not from YAML) — call Self::with_moderation_model().

Implementations

impl MiddlewareConfig

pub fn with_moderation_model(self, model: Arc<dyn AiModel>) -> Self

Set the LLM model for moderation middleware. Called at agent startup after constructing the provider.

impl MiddlewareConfig

pub fn build_before_release_pipeline( &self, ) -> Result<MiddlewarePipeline, String>

Build a pipeline for the before_release hook point. Err if any configured middleware fails to build (fail-closed — see build_pipeline).

pub fn build_provider_response_pipeline( &self, ) -> Result<MiddlewarePipeline, String>

Build a pipeline for the on_provider_response hook point.

pub fn build_before_prompt_pipeline(&self) -> Result<MiddlewarePipeline, String>

Build a pipeline for the before_prompt hook point.

pub fn build_completion_pipeline(&self) -> Result<MiddlewarePipeline, String>

Build a pipeline for the on_completion hook point.

pub fn build_job_complete_pipeline(&self) -> Result<MiddlewarePipeline, String>

Build a pipeline for the on_job_complete hook point.

pub fn is_empty(&self) -> bool

Returns true if no middleware is configured at any hook point.

Trait Implementations

impl Clone for MiddlewareConfig

fn clone(&self) -> MiddlewareConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MiddlewareConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MiddlewareConfig

fn default() -> MiddlewareConfig

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MiddlewareConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.