Struct StableFor 

pub struct StableFor {
    duration: Duration,
    current: Option<(DateTime<Utc>, Value)>,
}

Mutable step that only outputs a value once it has remained the same for a given duration.

The duration is measured using the input timestamps. Values are dropped until the same value has been seen for at least the configured duration. After that, every repetition of the value is output. A different value restarts the timer.

A timestamp that is earlier than the start of the current value is treated as if no time had passed.

input   A   A   B   B   B   B   A
time    0s  1s  2s  3s  4s  5s  6s
output  -   A   -   -   B   B   -     (duration = 1s)

Fields

duration: Duration

current: Option<(DateTime<Utc>, Value)>

Implementations

impl StableFor

pub const fn new(duration: Duration) -> Self

Creates a new instance with the given duration.

Trait Implementations

impl Clone for StableFor

fn clone(&self) -> StableFor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StableFor

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

Formats the value using the given formatter.

impl From<StableFor> for AnyStepMut

fn from(step: StableFor) -> Self

Converts to this type from the input type.

impl StepMut for StableFor

fn is_redundant(&self) -> bool

Returns true if the step is redundant.

fn transform( &mut self, timestamp: DateTime<Utc>, _attributes: &Attributes, value: &mut Value, ) -> Outcome

Transforms a value.