Struct ActiveCorrelation 

pub struct ActiveCorrelation {
    pub current_step: usize,
    pub context: SequenceContext,
    pub started_at: Instant,
    pub step_timeout: Option<Instant>,
}

An active correlation being tracked

Fields

current_step: usize

Current step index in the sequence

context: SequenceContext

Context with captured events

started_at: Instant

When this correlation was started

step_timeout: Option<Instant>

Timeout for current step (if any)

Implementations

impl ActiveCorrelation

pub fn new() -> Self

pub fn advance(&mut self, event: Event, alias: Option<&str>)

pub fn is_timed_out(&self) -> bool

pub fn set_timeout(&mut self, duration: Duration)

Trait Implementations

impl Debug for ActiveCorrelation

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

Formats the value using the given formatter.

impl Default for ActiveCorrelation

fn default() -> Self

Returns the “default value” for a type.