Struct AdaptivePipeline 

pub struct AdaptivePipeline { /* private fields */ }

Deterministic outcome-to-directive policy engine.

Example

use termivar_scanner::AdaptivePipeline;

let pipeline = AdaptivePipeline::with_standard_policies()?;
assert_eq!(pipeline.len(), 3);

Implementations

impl AdaptivePipeline

pub fn new() -> Self

Creates an empty policy engine with deterministic fallback behavior.

pub fn with_standard_policies() -> Result<Self, AdaptivePipelineError>

Creates policies for common HTTP control-flow signals.

• 403 schedules http.403-bypass;
• 404 schedules http.enumeration;
• 429 throttles for two seconds and retries the current action.

The pipeline only proposes directives. A crate::DecisionLoop grants execution authority separately: scheduled actions must be registered, satisfy current planner policy, and be submitted with an explicit host suppression context. These example action IDs are not implicit executor registrations.

pub fn register( &mut self, rule: AdaptationRule, ) -> Result<AdaptiveRuleWrite, AdaptivePipelineError>

Registers an idempotent policy rule.

pub fn len(&self) -> usize

Returns the number of registered policies.

pub fn is_empty(&self) -> bool

Returns whether no policies are registered.

pub fn decide( &self, outcome: &Outcome, snapshot: &KnowledgeSnapshot, ledger: &AdaptationLedger, limits: AdaptationLimits, ) -> Result<AdaptiveDecision, AdaptivePipelineError>

Produces a pure decision without changing the supplied ledger.

pub fn decide_with_suppressed_actions( &self, outcome: &Outcome, snapshot: &KnowledgeSnapshot, ledger: &AdaptationLedger, limits: AdaptationLimits, suppressed_actions: &BTreeSet<String>, ) -> Result<AdaptiveDecision, AdaptivePipelineError>

Produces a pure decision while excluding actions suppressed by external policy.

The set may be derived from an crate::ExperienceStore, operator policy, or another scheduler concern. Ledger suppressions are always merged with the supplied set.

pub fn decide_and_record( &self, outcome: &Outcome, snapshot: &KnowledgeSnapshot, ledger: &mut AdaptationLedger, limits: AdaptationLimits, ) -> Result<AdaptiveDecision, AdaptivePipelineError>

Produces and atomically records one in-order adaptive decision.

pub fn decide_and_record_with_suppressed_actions( &self, outcome: &Outcome, snapshot: &KnowledgeSnapshot, ledger: &mut AdaptationLedger, limits: AdaptationLimits, suppressed_actions: &BTreeSet<String>, ) -> Result<AdaptiveDecision, AdaptivePipelineError>

Produces and records a decision with explicit policy suppressions.

Trait Implementations

impl Clone for AdaptivePipeline

fn clone(&self) -> AdaptivePipeline

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AdaptivePipeline

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

Formats the value using the given formatter.

impl Default for AdaptivePipeline

fn default() -> AdaptivePipeline

Returns the “default value” for a type.