Struct MirrorConfig 

pub struct MirrorConfig {

    pub enabled: bool,
    pub sample_rate: f64,
    pub writes_only: bool,
    pub queue_size: usize,
    pub backend_host: String,
    pub backend_port: u16,
    pub backend_user: String,
    pub backend_password: Option<String>,
    pub backend_database: Option<String>,
    pub source_host: String,
    pub source_port: u16,
    pub source_user: String,
    pub source_password: Option<String>,
    pub source_database: Option<String>,
}

Traffic-mirror configuration: replay a sampled share of live (simple-query) writes to a secondary backend, asynchronously and off the client hot path.

Fields

enabled: bool

sample_rate: f64

Fraction of eligible statements to mirror, 0.0..=1.0.

writes_only: bool

Mirror only write/DDL statements (default). When false, all simple queries are mirrored.

queue_size: usize

Bounded queue depth; when full, statements are dropped (and counted) rather than blocking the client path.

backend_host: String

backend_port: u16

backend_user: String

backend_password: Option<String>

backend_database: Option<String>

source_host: String

Source (primary) connection used by POST /api/migration/snapshot to read existing data when bootstrapping the secondary. Defaults mirror the listener-side backend; set explicitly for a snapshot.

source_port: u16

source_user: String

source_password: Option<String>

source_database: Option<String>

Trait Implementations

impl Clone for MirrorConfig

fn clone(&self) -> MirrorConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MirrorConfig

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

Formats the value using the given formatter.

impl Default for MirrorConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for MirrorConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MirrorConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.