Struct PredicateExecutor 

pub struct PredicateExecutor { /* private fields */ }

Budgeted predicate executor.

Implementations

impl PredicateExecutor

pub fn new(config: PredicateExecutorConfig) -> Self

pub fn with_cheap_judge( config: PredicateExecutorConfig, cheap_judge: Rc<dyn CheapJudge>, ) -> Self

pub async fn execute_slice( &self, slice: &Slice, predicates: &[Rc<dyn PredicateRunner>], ) -> PredicateExecutionReport

Evaluate predicates for a single slice using the scheduler defaults.

This is shorthand for execute_slices with a single-element queue. Even one slice still flows through the cross-slice scheduler so the aggregate per-slice envelope and lane caps apply.

pub async fn execute_slices( &self, slices: Vec<(Slice, Vec<Rc<dyn PredicateRunner>>)>, ) -> Vec<PredicateExecutionReport>

Evaluate predicates for several candidate slices fairly.

All slices share the global deterministic and semantic lane semaphores configured in PredicateSchedulerConfig. Each slice additionally owns its own per-slice lane semaphores (so one slice cannot occupy all global semantic lanes), and each slice independently tracks aggregate wall-clock against the per-kind envelopes. Once a slice exhausts an envelope, all remaining predicates of that kind for that slice short-circuit to a budget_exceeded Block.

Output preserves input slice order. Within each slice, records are sorted by predicate hash so reports are deterministic regardless of the order predicates finished.

Trait Implementations

impl Clone for PredicateExecutor

fn clone(&self) -> PredicateExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for PredicateExecutor

fn default() -> Self

Returns the “default value” for a type.