Struct CanaryLayer 

pub struct CanaryLayer { /* private fields */ }

Weighted traffic-splitting proxy middleware.

Clone is cheap and shares state — all clones distribute traffic against the same underlying [CanaryState], so a CanaryLayer::update on one clone is immediately visible to a clone already wrapped into a running Application (see the module docs for the clone-before-wrapping pattern).

Implementations

impl CanaryLayer

pub fn new(backends: Vec<WeightedBackend>) -> Self

Build a CanaryLayer from the given weighted backends.

Backends with weight == 0 are ignored. Equivalent to CanaryLayer::from_parts(backends, vec![]).

pub fn with_pools(pools: Vec<WeightedPool>) -> Self

Build a CanaryLayer whose groups are all dynamically-discovered BackendPools rather than fixed URLs. Equivalent to CanaryLayer::from_parts(vec![], pools).

pub fn from_parts( backends: Vec<WeightedBackend>, pools: Vec<WeightedPool>, ) -> Self

Build a CanaryLayer from a mix of fixed backends and dynamic pools.

pub fn add_pool(self, pool: BackendPool, weight: u32) -> Self

Append one more dynamically-discovered group to an already-built layer (e.g. adding a canary BackendPool alongside stable backends passed to CanaryLayer::new). A weight of 0 is a no-op.

This is a builder method for use before .wrap(...) — for changing an already-wrapped, already-running layer’s configuration, use CanaryLayer::update instead.

pub fn update(&self, backends: Vec<WeightedBackend>, pools: Vec<WeightedPool>)

Replace the entire backend/pool configuration in place — the runtime equivalent of building a fresh layer with CanaryLayer::from_parts, except every existing clone of this layer (including one already wrapped into a running Application) picks up the change on its very next request. No restart required.

pub fn path_prefix(self, prefix: impl Into<String>) -> Self

Only proxy requests whose URI starts with prefix; pass others through.

pub fn connect_timeout_ms(self, ms: u64) -> Self

Override the TCP connect timeout (default: 5 000 ms).

pub fn read_timeout_ms(self, ms: u64) -> Self

Override the response read timeout (default: 30 000 ms).

Trait Implementations

impl Clone for CanaryLayer

fn clone(&self) -> CanaryLayer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Middleware for CanaryLayer

fn handle( &self, request: &Request, connection: &ConnectionInfo, next: &dyn Application, ) -> Result<Response, String>