Struct RemoteRouterConfig 

pub struct RemoteRouterConfig {
    pub nodes: Arc<Vec<Address>>,
    pub strategy: RemoteRouterStrategy,
    pub endpoint_manager: EndpointManager,
    /* private fields */
}

Fields

nodes: Arc<Vec<Address>>

strategy: RemoteRouterStrategy

endpoint_manager: EndpointManager

Implementations

impl RemoteRouterConfig

pub fn new( nodes: Vec<Address>, strategy: RemoteRouterStrategy, endpoint_manager: EndpointManager, ) -> Self

pub fn with_adaptive_picker(self, picker: AdaptivePicker) -> Self

Install an adaptive picker for RemoteRouterStrategy::Adaptive. Cluster-metrics callers wire AdaptiveLoadBalancer here:

router.with_adaptive_picker(Arc::new(move |cands| {
    let refs: Vec<&str> = cands.iter().map(String::as_str).collect();
    lb.pick(&refs).map(str::to_string)
}));

pub fn pick(&self, key: Option<&str>) -> Option<&Address>

Pick the next remote node for the message identified by key (use None for round-robin / counter-driven selection).

pub fn routee_path(&self, base: &str, key: Option<&str>) -> Option<ActorPath>

Build a fully-qualified routee path on the picked remote node.

Trait Implementations

impl Clone for RemoteRouterConfig

fn clone(&self) -> RemoteRouterConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.