Struct ConfigConvergenceConfig 

pub struct ConfigConvergenceConfig {
    pub enabled: bool,
    pub backend: String,
    pub redis_url: Option<String>,
    pub key_prefix: String,
    pub poll_interval_ms: u64,
    pub drift_check_interval_ms: u64,
    pub fail_open: bool,
}

Config convergence config (DW-054, gateway.config_convergence).

When present and the ent cargo feature is compiled in AND a valid license with the config_convergence feature claim is loaded, the gateway publishes its config generation to a shared backend and polls for generations published by other instances, converging to the highest generation within poll_interval_ms. The backend is the seam for etcd/Consul (deferred); v1 ships a Redis implementation. The coordinator runs ALONGSIDE the local file watcher: a local file change triggers a local reload plus a publish to the backend; a remote change (detected by polling) triggers a remote reload. Both go through compile_and_publish. When the ent feature is NOT compiled in, or the license lacks the claim, the block is accepted but inert (the local file watcher runs alone).

Fields

enabled: bool

Master switch. Default false: convergence is inert and the gateway serves only its local config (the local file watcher still runs). When true (and licensed), the coordinator publishes and polls.

backend: String

Convergence backend type. v1 ships "redis"; etcd and Consul are deferred behind the ConfigConvergenceBackend trait (the value is the seam a future backend plugs into). Validation rejects any value other than "redis".

redis_url: Option<String>

Redis connection URL (e.g. redis://127.0.0.1:6379), required when backend = "redis". The connection is established once at startup and pooled via a multiplexed ConnectionManager.

key_prefix: String

Prefix for convergence keys in Redis (default dwara:config). Instance generations live under {prefix}:instances and config bodies under {prefix}:config.

poll_interval_ms: u64

How often to poll the backend for generations published by other instances, in milliseconds (default 1000; validated to 100..=60 000). The done-when targets sub-second convergence; lower values converge faster at the cost of backend load.

drift_check_interval_ms: u64

How often to read all instances’ generations and report drift, in milliseconds (default 5000; validated to 1 000..=300 000). Drift is reported (structured log + metric) when instances serve different config hashes.

fail_open: bool

Fail-open behavior when the convergence backend is unreachable (default true): true keeps serving the local config generation (convergence pauses until the backend recovers); false refuses to start at cold start when the backend cannot be reached. Fail-open is the safer default for availability – a backend outage should not take down the gateway.

Trait Implementations

impl Clone for ConfigConvergenceConfig

fn clone(&self) -> ConfigConvergenceConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConfigConvergenceConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ConfigConvergenceConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl JsonSchema for ConfigConvergenceConfig

fn schema_name() -> Cow<'static, str>

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn inline_schema() -> bool

Whether JSON Schemas generated for this type should be included directly in parent schemas, rather than being re-used where possible using the $ref keyword.

impl PartialEq for ConfigConvergenceConfig

fn eq(&self, other: &ConfigConvergenceConfig) -> 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 Serialize for ConfigConvergenceConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for ConfigConvergenceConfig