akka.cluster.routing
Interface AdaptiveLoadBalancingRouterLike

All Known Implementing Classes:

AdaptiveLoadBalancingRouter

public interface AdaptiveLoadBalancingRouterLike

INTERNAL API.

This strategy is a metrics-aware router which performs load balancing of messages to cluster nodes based on cluster metric data. It consumes ClusterEvent.ClusterMetricsChanged events and the MetricsSelector creates an mix of weighted routees based on the node metrics. Messages are routed randomly to the weighted routees, i.e. nodes with lower load are more likely to be used than nodes with higher load

Method Summary

scala.PartialFunction<scala.Tuple2<ActorRef,java.lang.Object>,scala.collection.immutable.Iterable<Destination>>	createRoute(RouteeProvider routeeProvider)
MetricsSelector	metricsSelector()
int	nrOfInstances()
scala.collection.immutable.Iterable<java.lang.String>	routees()
java.lang.String	routerDispatcher()

Method Detail

metricsSelector

MetricsSelector metricsSelector()

nrOfInstances

int nrOfInstances()

routees

scala.collection.immutable.Iterable<java.lang.String> routees()

routerDispatcher

java.lang.String routerDispatcher()

createRoute

scala.PartialFunction<scala.Tuple2<ActorRef,java.lang.Object>,scala.collection.immutable.Iterable<Destination>> createRoute(RouteeProvider routeeProvider)