Struct CanaryLayer 

pub struct CanaryLayer { /* private fields */ }

Weighted traffic-splitting proxy middleware.

The rotation is pre-expanded so that each backend appears exactly weight times. An atomic counter selects the next entry in the rotation on every request, giving a deterministic, lock-free weighted round-robin distribution.

Implementations

impl CanaryLayer

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

Build a CanaryLayer from the given weighted backends.

Backends with weight == 0 are ignored.

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 Middleware for CanaryLayer

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