Trait mz_timely_util::replay::MzReplay

pub trait MzReplay<T, C, A>: Sized
where
    T: Timestamp,
    A: ActivatorTrait,
{
    // Required method
    fn mz_replay<S: Scope<Timestamp = T>, CB, L>(
        self,
        scope: &mut S,
        name: &str,
        period: Duration,
        activator: A,
        logic: L,
    ) -> (StreamCore<S, CB::Container>, Rc<dyn Any>)
       where CB: ContainerBuilder,
             L: FnMut(Session<'_, T, CB, PushCounter<T, CB::Container, Tee<T, CB::Container>>>, &C) + 'static;
}

Replay a capture stream into a scope with the same timestamp.

Required Methods

fn mz_replay<S: Scope<Timestamp = T>, CB, L>( self, scope: &mut S, name: &str, period: Duration, activator: A, logic: L, ) -> (StreamCore<S, CB::Container>, Rc<dyn Any>)

where CB: ContainerBuilder, L: FnMut(Session<'_, T, CB, PushCounter<T, CB::Container, Tee<T, CB::Container>>>, &C) + 'static,

Replays self into the provided scope, as a StreamCore<S, CB::Container> and provides a cancellation token. Uses the supplied container builder CB to form containers.

The period argument allows the specification of a re-activation period, where the operator will re-activate itself every so often.

• scope: The Scope to replay into.
• name: Human-readable debug name of the Timely operator.
• period: Reschedule the operator once the period has elapsed. Provide Duration::MAX to disable periodic scheduling.
• activator: An activator to trigger the operator.

Object Safety

This trait is not object safe.

Implementors

impl<T, C, I, A> MzReplay<T, C, A> for I

where T: Timestamp, C: Container, I: IntoIterator, I::Item: EventIterator<T, C> + 'static, A: ActivatorTrait + 'static,