Struct ConsistentHashBalancer 

pub struct ConsistentHashBalancer { /* private fields */ }

Consistent hash load balancer with virtual nodes and bounded loads

Implementations

impl ConsistentHashBalancer

pub fn new(targets: Vec<UpstreamTarget>, config: ConsistentHashConfig) -> Self

pub fn extract_hash_key(&self, context: &RequestContext) -> Option<String>

Extract hash key from request context

pub fn acquire_connection(&self, target_index: usize)

Track connection acquisition

pub fn release_connection(&self, target_index: usize)

Track connection release

Trait Implementations

impl LoadBalancer for ConsistentHashBalancer

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 when request completes

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 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)