Struct CollatorConfig 

pub struct CollatorConfig {
    pub emit_messages: bool,
    pub emit_exchanges: bool,
    pub max_buf_size: usize,
    pub timeout_ns: u64,
    pub max_body_size: usize,
}

Configuration for what the collator emits

Fields

emit_messages: bool

Emit Message events when individual requests/responses are parsed

emit_exchanges: bool

Emit Exchange events when request/response pairs complete

max_buf_size: usize

Maximum buffer size per chunk

timeout_ns: u64

Connection timeout for cleanup in nanoseconds

max_body_size: usize

Maximum accumulated body size per direction before the connection is reset. Prevents unbounded memory growth from stalled or malicious connections. Default: 10 MiB.

Implementations

impl CollatorConfig

pub fn messages_only() -> Self

Create config that only emits messages (for immediate adjudication)

pub fn exchanges_only() -> Self

Create config that only emits exchanges (for monitoring/APM)

Trait Implementations

impl Clone for CollatorConfig

fn clone(&self) -> CollatorConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CollatorConfig

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

Formats the value using the given formatter.

impl Default for CollatorConfig

fn default() -> Self

Returns the “default value” for a type.