Struct Reactor 

pub struct Reactor { /* private fields */ }

The main reactor for event processing

Implementations

impl Reactor

pub fn new(config: ReactorConfig) -> Result<Self, ReactorError>

Creates a new reactor with the given configuration

Errors

Currently does not return any errors, but may in the future if initialization fails

pub fn add_operator(&mut self, operator: Box<dyn Operator>)

Register an operator in the processing chain

pub fn set_sink(&mut self, sink: Box<dyn Sink>)

Set the output sink for the reactor

pub fn shutdown_handle(&self) -> Arc<AtomicBool>

Get a handle to the shutdown flag

pub fn submit(&mut self, event: Event) -> Result<(), ReactorError>

Submit an event for processing

Errors

Returns ReactorError::QueueFull if the event queue is at capacity

pub fn submit_batch(&mut self, events: Vec<Event>) -> Result<(), ReactorError>

Submit multiple events for processing

Errors

Returns ReactorError::QueueFull if there’s insufficient capacity for all events

pub fn poll_into(&mut self, output: &mut Vec<Output>)

Run one iteration, appending outputs to a caller-provided buffer.

The caller can reuse the same Vec across iterations, retaining its capacity and avoiding per-poll allocation.

pub fn advance_watermark(&mut self, timestamp: i64)

Advances the watermark to the given timestamp.

Called when an external watermark message arrives (e.g., from TPC coordination). Updates the reactor’s event time tracking and watermark generator state. Any resulting watermark output will be included in the next poll() result.

pub fn trigger_checkpoint(&mut self) -> Vec<OperatorState>

Triggers a checkpoint by snapshotting all operator states.

Called when a CheckpointRequest arrives from the control plane. Collects the serialized state from each operator and returns it for persistence by Ring 1.

pub fn trigger_checkpoint_into(&mut self, buf: &mut Vec<OperatorState>)

Triggers a checkpoint, appending operator states into a reusable buffer.

Like trigger_checkpoint but avoids allocating a new Vec on every call — the caller provides a buffer whose capacity is reused across checkpoint cycles.

pub fn events_processed(&self) -> u64

Get the number of events processed

pub fn queue_size(&self) -> usize

Get the number of events in the queue

pub fn set_cpu_affinity(&self) -> Result<(), ReactorError>

Set CPU affinity if configured

Errors

Returns ReactorError if CPU affinity cannot be set (platform-specific)

pub fn run(&mut self) -> Result<(), ReactorError>

Runs the event loop continuously until shutdown

Errors

Returns ReactorError if CPU affinity cannot be set or if shutdown fails

pub fn shutdown(&mut self) -> Result<(), ReactorError>

Stops the reactor gracefully

Errors

Currently does not return any errors, but may in the future if shutdown fails