Struct StickySessionBalancer 

pub struct StickySessionBalancer { /* private fields */ }

Cookie-based sticky session load balancer

This balancer wraps a fallback load balancer and adds session affinity based on cookies. When a client has a valid affinity cookie, requests are routed to the same backend. Otherwise, the fallback balancer is used and a new cookie is set.

Implementations

impl StickySessionBalancer

pub fn new( targets: Vec<UpstreamTarget>, config: StickySessionRuntimeConfig, fallback: Arc<dyn LoadBalancer>, ) -> Self

Create a new sticky session balancer

pub fn generate_cookie_value(&self, target_index: usize) -> String

Generate signed cookie value for target

pub fn generate_set_cookie_header(&self, target_index: usize) -> String

Generate full Set-Cookie header value

pub fn cookie_name(&self) -> &str

Get the cookie name

pub fn config(&self) -> &StickySessionRuntimeConfig

Get the config for Set-Cookie header generation

Trait Implementations

impl LoadBalancer for StickySessionBalancer

fn select<'life0, 'life1, 'async_trait>( &'life0 self, context: Option<&'life1 RequestContext>, ) -> Pin<Box<dyn Future<Output = SentinelResult<TargetSelection>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Select next upstream target

fn report_health<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 str, healthy: bool, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Report target health status

fn healthy_targets<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Vec<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get all healthy targets

fn release<'life0, 'life1, 'async_trait>( &'life0 self, selection: &'life1 TargetSelection, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Release connection (for connection tracking)

fn report_result<'life0, 'life1, 'async_trait>( &'life0 self, selection: &'life1 TargetSelection, success: bool, latency: Option<Duration>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Report request result (for adaptive algorithms)

fn report_result_with_latency<'life0, 'life1, 'async_trait>( &'life0 self, address: &'life1 str, success: bool, latency: Option<Duration>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Report request result by address with latency (for adaptive algorithms)