Struct PassThroughOperator 

pub struct PassThroughOperator {
    pub id: String,
}

A simple pass-through operator for testing.

Fields

id: String

Operator ID for checkpointing.

Implementations

impl PassThroughOperator

pub fn new(id: impl Into<String>) -> Self

Creates a new pass-through operator.

Trait Implementations

impl Clone for PassThroughOperator

fn clone(&self) -> PassThroughOperator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PassThroughOperator

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

Formats the value using the given formatter.

impl Operator for PassThroughOperator

fn process( &mut self, event: &Event, _ctx: &mut OperatorContext<'_>, ) -> OutputVec

Process an incoming event

fn on_timer( &mut self, _timer: Timer, _ctx: &mut OperatorContext<'_>, ) -> OutputVec

Handle timer expiration

fn checkpoint(&self) -> OperatorState

Checkpoint the operator’s state

fn restore(&mut self, _state: OperatorState) -> Result<(), OperatorError>

Restore from a checkpoint