Struct ReactorConfig 

pub struct ReactorConfig {
    pub batch_size: usize,
    pub cpu_affinity: Option<usize>,
    pub max_iteration_time: Duration,
    pub event_buffer_size: usize,
    pub max_out_of_orderness: i64,
}

Configuration for the reactor

Fields

batch_size: usize

Maximum events to process per poll

cpu_affinity: Option<usize>

CPU core to pin the reactor thread to (None = no pinning)

max_iteration_time: Duration

Maximum time to spend in one iteration

event_buffer_size: usize

Size of the event buffer

max_out_of_orderness: i64

Maximum out-of-orderness for watermark generation (milliseconds)

Trait Implementations

impl Clone for ReactorConfig

fn clone(&self) -> ReactorConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReactorConfig

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

Formats the value using the given formatter.

impl Default for ReactorConfig

fn default() -> Self

Returns the “default value” for a type.