Class NodeMetrics

  • All Implemented Interfaces:
    java.io.Serializable, scala.Equals, scala.Product, scala.Serializable

    public final class NodeMetrics
    extends java.lang.Object
    implements scala.Product, scala.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.

    param: address Address of the node the metrics are gathered at param: timestamp the time of sampling, in milliseconds since midnight, January 1, 1970 UTC param: metrics the set of sampled Metric

    See Also:
    Serialized Form
    • Constructor Detail

      • NodeMetrics

        public NodeMetrics​(Address address,
                           long timestamp,
                           scala.collection.immutable.Set<Metric> metrics)
    • Method Detail

      • $lessinit$greater$default$3

        public static scala.collection.immutable.Set<Metric> $lessinit$greater$default$3()
      • apply

        public static NodeMetrics apply​(Address address,
                                        long timestamp,
                                        scala.collection.immutable.Set<Metric> metrics)
      • apply$default$3

        public static scala.collection.immutable.Set<Metric> apply$default$3()
      • unapply

        public static scala.Option<scala.Tuple3<Address,​java.lang.Object,​scala.collection.immutable.Set<Metric>>> unapply​(NodeMetrics x$0)
      • address

        public Address address()
      • timestamp

        public long timestamp()
      • metrics

        public scala.collection.immutable.Set<Metric> metrics()
      • merge

        public NodeMetrics merge​(NodeMetrics that)
        Returns the most recent data.
        Parameters:
        that - (undocumented)
        Returns:
        (undocumented)
      • update

        public NodeMetrics update​(NodeMetrics that)
        Returns the most recent data with EWMA averaging.
        Parameters:
        that - (undocumented)
        Returns:
        (undocumented)
      • metric

        public scala.Option<Metric> metric​(java.lang.String key)
      • getMetrics

        public java.lang.Iterable<Metric> getMetrics()
        Java API
        Returns:
        (undocumented)
      • sameAs

        public boolean sameAs​(NodeMetrics that)
        Returns true if that address is the same as this
        Parameters:
        that - (undocumented)
        Returns:
        (undocumented)
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object obj)
        Specified by:
        equals in interface scala.Equals
        Overrides:
        equals in class java.lang.Object
      • copy$default$1

        public Address copy$default$1()
      • copy$default$2

        public long copy$default$2()
      • copy$default$3

        public scala.collection.immutable.Set<Metric> copy$default$3()
      • productPrefix

        public java.lang.String productPrefix()
        Specified by:
        productPrefix in interface scala.Product
      • productArity

        public int productArity()
        Specified by:
        productArity in interface scala.Product
      • productElement

        public java.lang.Object productElement​(int x$1)
        Specified by:
        productElement in interface scala.Product
      • productIterator

        public scala.collection.Iterator<java.lang.Object> productIterator()
        Specified by:
        productIterator in interface scala.Product
      • canEqual

        public boolean canEqual​(java.lang.Object x$1)
        Specified by:
        canEqual in interface scala.Equals
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object