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.
- Alphabetic
- By Inheritance
- ClusterMetricsExtension
- Extension
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
- new ClusterMetricsExtension(system: ExtendedActorSystem)
Value Members
-
val
settings: ClusterMetricsSettings
Metrics extension configuration.
-
def
subscribe(metricsListener: ActorRef): Unit
Subscribe user metrics listener actor unto ClusterMetricsEvent events published by extension on the system event bus.
-
val
supervisor: ActorRef
Supervisor actor.
Supervisor actor. Accepts subtypes of CollectionControlMessages to manage metrics collection at runtime.
-
def
unsubscribe(metricsListenter: ActorRef): Unit
Unsubscribe user metrics listener actor from ClusterMetricsEvent events published by extension on the system event bus.