Struct StreamFaultPlan 

pub struct StreamFaultPlan { /* private fields */ }

An ordered list of faults to apply to a stream’s item sequence.

Implementations

impl StreamFaultPlan

pub fn new(faults: Vec<StreamFaultSpec>) -> Self

Builds a plan from an ordered list of fault specs.

pub fn faults(&self) -> &[StreamFaultSpec]

Returns the plan’s fault specs in application order.

pub fn apply(&self, items: &[StreamItem]) -> StreamFaultResult

Applies every fault in order to a copy of items.

Item-level faults rewrite the sequence; transport-level faults are recorded as diagnostics without altering items. Returns the rewritten items together with one diagnostic symbol per applied fault.

pub fn to_expr(&self) -> Expr

Renders the plan as an Expr list of fault/count maps.

Trait Implementations

impl Clone for StreamFaultPlan

fn clone(&self) -> StreamFaultPlan

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamFaultPlan

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

Formats the value using the given formatter.

impl Default for StreamFaultPlan

fn default() -> StreamFaultPlan

Returns the “default value” for a type.

impl Eq for StreamFaultPlan

impl PartialEq for StreamFaultPlan

fn eq(&self, other: &StreamFaultPlan) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for StreamFaultPlan