Struct StepChain 

pub struct StepChain { /* private fields */ }

Ordered chain of TransformSteps applied sequentially to each record.

If any step returns Ok(false), the record is dropped from the output. If any step returns Err, the entire chain short-circuits.

Implementations

impl StepChain

pub fn new(steps: Vec<Box<dyn TransformStep>>) -> Self

pub fn apply_one(&self, data: &mut Value) -> Result<bool, OversyncError>

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn filter_rows( &self, rows: Vec<RawRow>, ) -> Result<Vec<RawRow>, OversyncError>

Filter rows pre-delta: applies steps to each RawRow.row_data, keeping only rows where all steps return true.

Trait Implementations

impl Debug for StepChain

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

Formats the value using the given formatter.

impl TransformHook for StepChain

fn transform<'life0, 'async_trait>( &'life0 self, envelopes: Vec<EventEnvelope>, ) -> Pin<Box<dyn Future<Output = Result<Vec<EventEnvelope>, OversyncError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,