c

akka.cluster.metrics

NodeMetrics

final case class NodeMetrics(address: Address, timestamp: Long, metrics: Set[Metric] = Set.empty[Metric]) extends Product with Serializable

The snapshot of current sampled health metrics for any monitored process. Collected and gossipped at regular intervals for dynamic cluster management strategies.

Equality of NodeMetrics is based on its address.

address

akka.actor.Address of the node the metrics are gathered at

timestamp

the time of sampling, in milliseconds since midnight, January 1, 1970 UTC

metrics

the set of sampled akka.cluster.metrics.Metric

Annotations
@SerialVersionUID()
Source
Metric.scala
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. NodeMetrics
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. AnyRef
  7. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new NodeMetrics(address: Address, timestamp: Long, metrics: Set[Metric] = Set.empty[Metric])

    address

    akka.actor.Address of the node the metrics are gathered at

    timestamp

    the time of sampling, in milliseconds since midnight, January 1, 1970 UTC

    metrics

    the set of sampled akka.cluster.metrics.Metric

Value Members

  1. val address: Address
  2. def equals(obj: Any): Boolean
    Definition Classes
    NodeMetrics → Equals → AnyRef → Any
  3. def getMetrics: Iterable[Metric]

    Java API

  4. def hashCode(): Int
    Definition Classes
    NodeMetrics → AnyRef → Any
  5. def merge(that: NodeMetrics): NodeMetrics

    Returns the most recent data.

  6. def metric(key: String): Option[Metric]
  7. val metrics: Set[Metric]
  8. def sameAs(that: NodeMetrics): Boolean

    Returns true if that address is the same as this

  9. val timestamp: Long
  10. def update(that: NodeMetrics): NodeMetrics

    Returns the most recent data with EWMA averaging.