Trait declarative_dataflow::timestamp::Rewind

pub trait Rewind: From<Time> {
    fn rewind(&self, slack: Self) -> Self;
}

Extension trait for timestamp types that can be safely re-wound to an earlier time. This is required for automatically advancing traces according to their configured slack.

Required methods

fn rewind(&self, slack: Self) -> Self

Returns a new timestamp corresponding to self rewound by the specified amount of slack. Calling rewind is always safe, in that no invalid times will be returned.

e.g. 0.rewind(10) -> 0 and Duration(0).rewind(Duration(1)) -> Duration(0)

Loading content...

Implementations on Foreign Types

impl Rewind for u64

fn rewind(&self, slack: Self) -> Self

impl Rewind for Duration

fn rewind(&self, slack: Self) -> Self

Loading content...

Implementors

impl Rewind for Pair<Duration, u64>

fn rewind(&self, slack: Self) -> Self

Loading content...