Class AssignmentStats.NodeStats

java.lang.Object
org.elasticsearch.xpack.core.ml.inference.assignment.AssignmentStats.NodeStats
All Implemented Interfaces:
Writeable, org.elasticsearch.xcontent.ToXContent, org.elasticsearch.xcontent.ToXContentObject
Enclosing class:
AssignmentStats

public static class AssignmentStats.NodeStats extends Object implements org.elasticsearch.xcontent.ToXContentObject, Writeable
  • Constructor Details

  • Method Details

    • forStartedState

      public static AssignmentStats.NodeStats forStartedState(DiscoveryNode node, long inferenceCount, Double avgInferenceTime, Double avgInferenceTimeExcludingCacheHit, int pendingCount, int errorCount, long cacheHitCount, int rejectedExecutionCount, int timeoutCount, Instant lastAccess, Instant startTime, Integer threadsPerAllocation, Integer numberOfAllocations, long peakThroughput, long throughputLastPeriod, Double avgInferenceTimeLastPeriod, long cacheHitCountLastPeriod)
    • forNotStartedState

      public static AssignmentStats.NodeStats forNotStartedState(DiscoveryNode node, RoutingState state, String reason)
    • getNode

      public DiscoveryNode getNode()
    • getRoutingState

      public RoutingStateAndReason getRoutingState()
    • getInferenceCount

      public Optional<Long> getInferenceCount()
    • getAvgInferenceTime

      public Optional<Double> getAvgInferenceTime()
    • getAvgInferenceTimeExcludingCacheHit

      public Optional<Double> getAvgInferenceTimeExcludingCacheHit()
    • getLastAccess

      public Instant getLastAccess()
    • getPendingCount

      public Integer getPendingCount()
    • getErrorCount

      public int getErrorCount()
    • getCacheHitCount

      public Optional<Long> getCacheHitCount()
    • getRejectedExecutionCount

      public int getRejectedExecutionCount()
    • getTimeoutCount

      public int getTimeoutCount()
    • getStartTime

      public Instant getStartTime()
    • getThreadsPerAllocation

      public Integer getThreadsPerAllocation()
    • getNumberOfAllocations

      public Integer getNumberOfAllocations()
    • getPeakThroughput

      public long getPeakThroughput()
    • getThroughputLastPeriod

      public long getThroughputLastPeriod()
    • getAvgInferenceTimeLastPeriod

      public Double getAvgInferenceTimeLastPeriod()
    • getCacheHitCountLastPeriod

      public Optional<Long> getCacheHitCountLastPeriod()
    • toXContent

      public org.elasticsearch.xcontent.XContentBuilder toXContent(org.elasticsearch.xcontent.XContentBuilder builder, org.elasticsearch.xcontent.ToXContent.Params params) throws IOException
      Specified by:
      toXContent in interface org.elasticsearch.xcontent.ToXContent
      Throws:
      IOException
    • writeTo

      public void writeTo(StreamOutput out) throws IOException
      Specified by:
      writeTo in interface Writeable
      Throws:
      IOException
    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object
    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object