Struct OutOfOrderConfig 

pub struct OutOfOrderConfig {
    pub max_lateness: Duration,
    pub buffer_capacity: usize,
    pub late_event_strategy: LateEventStrategy,
    pub enable_watermarks: bool,
    pub watermark_interval: Duration,
    pub allowed_out_of_orderness: Duration,
    pub enable_sequence_tracking: bool,
    pub gap_filling_strategy: GapFillingStrategy,
    pub enable_deduplication: bool,
    pub deduplication_window: Duration,
    pub emit_strategy: EmitStrategy,
}

Configuration for out-of-order handling

Fields

max_lateness: Duration

Maximum time to wait for late events

buffer_capacity: usize

Buffer capacity (number of events)

late_event_strategy: LateEventStrategy

Strategy for handling late events

enable_watermarks: bool

Enable watermark tracking

watermark_interval: Duration

Watermark update interval

allowed_out_of_orderness: Duration

Allowed out-of-orderness

enable_sequence_tracking: bool

Enable sequence number tracking

gap_filling_strategy: GapFillingStrategy

Gap filling strategy

enable_deduplication: bool

Enable event deduplication

deduplication_window: Duration

Deduplication window

emit_strategy: EmitStrategy

Emit strategy

Trait Implementations

impl Clone for OutOfOrderConfig

fn clone(&self) -> OutOfOrderConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OutOfOrderConfig

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

Formats the value using the given formatter.

impl Default for OutOfOrderConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for OutOfOrderConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for OutOfOrderConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.