akka.cluster

routing

package routing

Visibility
  1. Public
  2. All

Type Members

  1. case class AdaptiveLoadBalancingRouter(metricsSelector: MetricsSelector = MixMetricsSelector, nrOfInstances: Int = 0, routees: Iterable[String] = immutable.this.Nil, resizer: Option[Resizer] = scala.None, routerDispatcher: String = ..., supervisorStrategy: SupervisorStrategy = ...) extends RouterConfig with AdaptiveLoadBalancingRouterLike with OverrideUnsetConfig[AdaptiveLoadBalancingRouter] with Product with Serializable

    A Router that performs load balancing of messages to cluster nodes based on cluster metric data.

  2. trait AdaptiveLoadBalancingRouterLike extends AnyRef

    INTERNAL API.

  3. abstract class CapacityMetricsSelector extends MetricsSelector

    A MetricsSelector producing weights from remaining capacity.

  4. final case class ClusterRouterConfig(local: RouterConfig, settings: ClusterRouterSettings) extends RouterConfig with Product with Serializable

    akka.routing.RouterConfig implementation for deployment on cluster nodes.

  5. case class ClusterRouterSettings extends Product with Serializable

    totalInstances of cluster router must be > 0 maxInstancesPerNode of cluster router must be > 0 maxInstancesPerNode of cluster router must be 1 when routeesPath is defined

  6. trait MetricsSelector extends Serializable

    A MetricsSelector is responsible for producing weights from the node metrics.

  7. case class MixMetricsSelector(selectors: IndexedSeq[CapacityMetricsSelector]) extends MixMetricsSelectorBase with Product with Serializable

    MetricsSelector that combines other selectors and aggregates their capacity values.

  8. abstract class MixMetricsSelectorBase extends CapacityMetricsSelector

    Base class for MetricsSelector that combines other selectors and aggregates their capacity.

Value Members

  1. object AdaptiveLoadBalancingRouter extends Serializable

  2. object ClusterRouterSettings extends Serializable

  3. object CpuMetricsSelector extends CapacityMetricsSelector with Product with Serializable

    MetricsSelector that uses the combined CPU metrics.

  4. object HeapMetricsSelector extends CapacityMetricsSelector with Product with Serializable

    MetricsSelector that uses the heap metrics.

  5. object MixMetricsSelector extends MixMetricsSelectorBase

    Singleton instance of the default MixMetricsSelector, which uses [akka.

  6. object SystemLoadAverageMetricsSelector extends CapacityMetricsSelector with Product with Serializable

    MetricsSelector that uses the system load average metrics.

Ungrouped