Skip to main content

OperatorDescriptor

Trait OperatorDescriptor 

Source
pub trait OperatorDescriptor {
    // Required methods
    fn id(&self) -> &str;
    fn uses_wall_clock(&self) -> bool;
    fn uses_random(&self) -> bool;
    fn has_external_side_effects(&self) -> bool;
}
Expand description

Trait describing an operator’s determinism properties.

Used by DeterminismValidator to check whether operators in an exactly-once pipeline are deterministic (same input + same state = same output). Non-deterministic operators break the replay-based exactly-once guarantee.

Required Methods§

Source

fn id(&self) -> &str

Unique operator identifier.

Source

fn uses_wall_clock(&self) -> bool

Whether the operator reads wall-clock / processing time.

Source

fn uses_random(&self) -> bool

Whether the operator uses randomness (e.g., rand::random()).

Source

fn has_external_side_effects(&self) -> bool

Whether the operator has external side effects (e.g., HTTP calls).

Implementors§