Struct HandlerRegistry

Source

pub struct HandlerRegistry { /* private fields */ }

Expand description

Registry of named handlers and agents for pipeline execution.

Implementations§

Source §

impl HandlerRegistry

Source

pub fn new() -> Self

Source

pub fn register_metadata(&mut self, meta: HandlerMetadata)

Register handler metadata for validation and introspection.

Source

pub fn get_metadata(&self, name: &str) -> Option<&HandlerMetadata>

Look up metadata for a registered handler by name.

Source

pub fn handler<F, Fut>(&mut self, name: impl Into<String>, f: F)
where F: Fn(Value) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<HandlerOutput, CruxErr>> + Send + 'static,

Register a handler that returns HandlerOutput directly.

Use this when the handler needs to control confidence. The returned HandlerOutput may carry confidence: Some(f32) or confidence: None. When confidence is None, {{ steps.<name>.confidence }} in templates will return an ExprError::NoConfidence error — it does NOT silently resolve to 1.0. Only an explicit Some(score) is template-accessible.

Prefer handler_value when confidence is irrelevant.

Source

pub fn handler_value<F, Fut>(&mut self, name: impl Into<String>, f: F)
where F: Fn(Value) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Value, CruxErr>> + Send + 'static,

Register a handler that returns a plain Value, without a confidence score.

Convenience wrapper over handler. The Value is auto-wrapped via HandlerOutput::from(value), which sets confidence = None. Accessing {{ steps.<name>.confidence }} in templates will fail with ExprError::NoConfidence — handler_value steps cannot be used as input to route_on_confidence.

Use this for handlers where confidence is not meaningful. Use handler when the handler must emit a real confidence score.

Source

pub fn handler_value_with_metadata<F, Fut>( &mut self, meta: HandlerMetadata, f: F, )
where F: Fn(Value) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Value, CruxErr>> + Send + 'static,

Register a plain-value handler together with its HandlerMetadata.

Combines handler_value and register_metadata in one call. The metadata name is used as the handler name — the two must match.

Source

pub fn agent<A>(&mut self, name: impl Into<String>)
where A: Agent<Input = Value, Output = Value>,

Register a cruxx Agent by name for delegation.

The agent’s run method will be called with a fresh CruxCtx.

Source

pub fn agent_fn<F, Fut>(&mut self, name: impl Into<String>, f: F)
where F: Fn(Value) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Value, CruxErr>> + Send + 'static,

Register a named agent using a plain async closure.

Unlike agent, this does not require a concrete Agent impl — any async Fn(Value) -> Result<Value, CruxErr> is accepted. This is the preferred way to register pipeline-level delegate targets programmatically.

Source