akka.cluster

routing

package routing

Content Hierarchy Learn more about scaladoc diagrams
Visibility
  1. Public
  2. All

Type Members

  1. final case class AdaptiveLoadBalancingGroup(metricsSelector: MetricsSelector = MixMetricsSelector, paths: Iterable[String] = immutable.this.Nil, routerDispatcher: String = ...) extends Group with Product with Serializable

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

  2. final case class AdaptiveLoadBalancingPool(metricsSelector: MetricsSelector = MixMetricsSelector, nrOfInstances: Int = 0, supervisorStrategy: SupervisorStrategy = ..., routerDispatcher: String = ..., usePoolDispatcher: Boolean = false) extends Pool with Product with Serializable

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

  3. final case class AdaptiveLoadBalancingRoutingLogic(system: ActorSystem, metricsSelector: MetricsSelector = MixMetricsSelector) extends RoutingLogic with NoSerializationVerificationNeeded with Product with Serializable

    Load balancing of messages to cluster nodes based on cluster metric data.

  4. abstract class CapacityMetricsSelector extends MetricsSelector

    A MetricsSelector producing weights from remaining capacity.

  5. final case class ClusterRouterGroup(local: Group, settings: ClusterRouterGroupSettings) extends Group with ClusterRouterConfigBase with Product with Serializable

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

  6. case class ClusterRouterGroupSettings(totalInstances: Int, routeesPaths: Seq[String], allowLocalRoutees: Boolean, useRole: Option[String]) extends ClusterRouterSettingsBase with Product with Serializable

    totalInstances of cluster router must be > 0

  7. final case class ClusterRouterPool(local: Pool, settings: ClusterRouterPoolSettings) extends Pool with ClusterRouterConfigBase with Product with Serializable

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

  8. case class ClusterRouterPoolSettings(totalInstances: Int, maxInstancesPerNode: Int, allowLocalRoutees: Boolean, useRole: Option[String]) extends ClusterRouterSettingsBase with 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

  9. trait MetricsSelector extends Serializable

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

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

    MetricsSelector that combines other selectors and aggregates their capacity values.

  11. abstract class MixMetricsSelectorBase extends CapacityMetricsSelector

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

  12. 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 DeprecatedRouterConfig with PoolOverrideUnsetConfig[AdaptiveLoadBalancingRouter] with Product with Serializable

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

  13. final case class ClusterRouterConfig(local: DeprecatedRouterConfig, settings: ClusterRouterSettings) extends DeprecatedRouterConfig with ClusterRouterConfigBase with Product with Serializable

    Annotations
    @deprecated @SerialVersionUID( 1L )
    Deprecated

    (Since version 2.3) Use ClusterRouterPool or ClusterRouterGroup

  14. case class ClusterRouterSettings extends ClusterRouterSettingsBase with 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

Value Members

  1. object ClusterRouterGroupSettings extends Serializable

  2. object ClusterRouterPoolSettings 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 MetricsSelector extends Serializable

  6. object MixMetricsSelector extends MixMetricsSelectorBase

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

  7. object SystemLoadAverageMetricsSelector extends CapacityMetricsSelector with Product with Serializable

    MetricsSelector that uses the system load average metrics.

Deprecated Value Members

  1. object ClusterRouterSettings extends Serializable

    Annotations
    @deprecated
    Deprecated

    (Since version 2.3) Use ClusterRouterPoolSettings or ClusterRouterGroupSettings

Ungrouped