class ClusterMetricsExtension extends Extension

Cluster metrics extension.

Cluster metrics is primarily for load-balancing of nodes. It controls metrics sampling at a regular frequency, prepares highly variable data for further analysis by other entities, and publishes the latest cluster metrics data around the node ring and local eventStream to assist in determining the need to redirect traffic to the least-loaded nodes.

Metrics sampling is delegated to the MetricsCollector.

Smoothing of the data for each monitored process is delegated to the EWMA for exponential weighted moving average.

Source
ClusterMetricsExtension.scala
Linear Supertypes
Extension, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ClusterMetricsExtension
  2. Extension
  3. AnyRef
  4. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new ClusterMetricsExtension(system: ExtendedActorSystem)

Value Members

  1. val settings: ClusterMetricsSettings

    Metrics extension configuration.

  2. def subscribe(metricsListener: ActorRef): Unit

    Subscribe user metrics listener actor unto ClusterMetricsEvent events published by extension on the system event bus.

  3. val supervisor: ActorRef

    Supervisor actor.

    Supervisor actor. Accepts subtypes of CollectionControlMessages to manage metrics collection at runtime.

  4. def unsubscribe(metricsListenter: ActorRef): Unit

    Unsubscribe user metrics listener actor from ClusterMetricsEvent events published by extension on the system event bus.