Struct FanoutConfig 

pub struct FanoutConfig {
    pub brokers: Vec<String>,
    pub topic: String,
    pub tls: Option<CaptureTlsConfig>,
    pub body_encoding: FanoutBodyEncoding,
    pub async_default: bool,
    pub expand_delete_by_query: bool,
}

Async fan-out write queue settings: where resolved write ops are enqueued for a downstream applier (docs/04 §9, ADR-010). Plain data (no broker types), so the config crate stays free of any Kafka client.

Fields

brokers: Vec<String>

The Kafka bootstrap brokers (host:port), at least one.

topic: String

The topic each op envelope is produced to.

tls: Option<CaptureTlsConfig>

TLS to the brokers, or None for a plaintext broker connection.

body_encoding: FanoutBodyEncoding

How the document body is encoded in the envelope (default CBOR).

async_default: bool

Whether async is the deployment-default write mode (default false): false = sync unless a request sends X-Write-Mode: async; true = async unless a request sends X-Write-Mode: sync.

expand_delete_by_query: bool

Whether _delete_by_query may be expanded into per-match deletes in async mode (default false). It reads the match set and enqueues a delete each, so it is opt-in (docs/04 §9).

Trait Implementations

impl Clone for FanoutConfig

fn clone(&self) -> FanoutConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FanoutConfig

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

Formats the value using the given formatter.

impl Eq for FanoutConfig

impl PartialEq for FanoutConfig

fn eq(&self, other: &FanoutConfig) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for FanoutConfig