Struct WalTcpExportConfig 

pub struct WalTcpExportConfig {
    pub enabled: bool,
    pub mode: WalTcpExportMode,
    pub addr: String,
    pub auth_token: Option<String>,
    pub channel_capacity: usize,
    pub max_subscribers: usize,
    pub connect_timeout_ms: u64,
    pub write_timeout_ms: u64,
    pub reconnect_backoff_ms: u64,
    pub backpressure_on_full: bool,
}

Optional live WAL export settings.

The TCP exporter streams the same framed WAL records used on disk. It is a live feed, not a replay service; disk WAL segments remain the authoritative recovery source.

Fields

enabled: bool

Enable the TCP WAL exporter.

mode: WalTcpExportMode

TCP export mode.

addr: String

Address the exporter connects to or listens on, for example 127.0.0.1:7630.

auth_token: Option<String>

Optional plaintext authentication token.

In connect mode, the token is sent to the configured collector before WAL frames. In listen mode, subscribers must send the token before they receive WAL frames.

channel_capacity: usize

Bounded queue between the disk WAL writer and the TCP exporter.

max_subscribers: usize

Maximum accepted subscribers in listen mode.

connect_timeout_ms: u64

Maximum time spent opening one TCP connection attempt.

write_timeout_ms: u64

Maximum time spent writing a frame before reconnecting.

reconnect_backoff_ms: u64

Delay between reconnect attempts after connect or write failure.

backpressure_on_full: bool

If true, a full TCP export queue backpressures the WAL writer.

If false, frames are dropped from the live TCP export when the exporter cannot keep up; disk WAL append still continues.

Trait Implementations

impl Clone for WalTcpExportConfig

fn clone(&self) -> WalTcpExportConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WalTcpExportConfig

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

Formats the value using the given formatter.

impl Default for WalTcpExportConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for WalTcpExportConfig

where WalTcpExportConfig: Default,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for WalTcpExportConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.