Package org.apache.hadoop.ozone.container.common.transport.server.ratis

Class CSMMetrics

java.lang.Object
org.apache.hadoop.ozone.container.common.transport.server.ratis.CSMMetrics
@Private @Metrics(about="Container State Machine Metrics", context="dfs") public class CSMMetrics extends Object
This class is for maintaining Container State Machine statistics.

  • Field Details

    • SOURCE_NAME

      public static final String SOURCE_NAME

  • Constructor Details

    • CSMMetrics

      public CSMMetrics(org.apache.ratis.protocol.RaftGroupId gid)

  • Method Details

    • create

      public static CSMMetrics create(org.apache.ratis.protocol.RaftGroupId gid)

    • getRaftGroupId

      @Metric public String getRaftGroupId()

    • incNumWriteStateMachineOps

      public void incNumWriteStateMachineOps()

    • incNumQueryStateMachineOps

      public void incNumQueryStateMachineOps()

    • incNumReadStateMachineOps

      public void incNumReadStateMachineOps()

    • incNumApplyTransactionsOps

      public void incNumApplyTransactionsOps()

    • incNumWriteStateMachineFails

      public void incNumWriteStateMachineFails()

    • incNumWriteDataFails

      public void incNumWriteDataFails()

    • incNumQueryStateMachineFails

      public void incNumQueryStateMachineFails()

    • incNumBytesWrittenCount

      public void incNumBytesWrittenCount(long value)

    • incNumBytesCommittedCount

      public void incNumBytesCommittedCount(long value)

    • incNumReadStateMachineFails

      public void incNumReadStateMachineFails()

    • incNumReadStateMachineMissCount

      public void incNumReadStateMachineMissCount()

    • incNumApplyTransactionsFails

      public void incNumApplyTransactionsFails()

    • getNumWriteStateMachineOps

      public long getNumWriteStateMachineOps()

    • getNumQueryStateMachineOps

      public long getNumQueryStateMachineOps()

    • getNumApplyTransactionsOps

      public long getNumApplyTransactionsOps()

    • getNumWriteStateMachineFails

      public long getNumWriteStateMachineFails()

    • getNumWriteDataFails

      public long getNumWriteDataFails()

    • getNumQueryStateMachineFails

      public long getNumQueryStateMachineFails()

    • getNumApplyTransactionsFails

      public long getNumApplyTransactionsFails()

    • getNumReadStateMachineFails

      public long getNumReadStateMachineFails()

    • getNumReadStateMachineMissCount

      public long getNumReadStateMachineMissCount()

    • getNumReadStateMachineOps

      public long getNumReadStateMachineOps()

    • getNumBytesWrittenCount

      public long getNumBytesWrittenCount()

    • getNumBytesCommittedCount

      public long getNumBytesCommittedCount()

    • incPipelineLatencyMs

      public void incPipelineLatencyMs(org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.Type type, long latencyMillis)

    • recordQueueingDelay

      public void recordQueueingDelay(org.apache.hadoop.hdds.protocol.datanode.proto.ContainerProtos.Type type, long latencyNanos)

    • incNumStartTransactionVerifyFailures

      public void incNumStartTransactionVerifyFailures()

    • incNumContainerNotOpenVerifyFailures

      public void incNumContainerNotOpenVerifyFailures()

    • recordApplyTransactionCompletionNs

      public void recordApplyTransactionCompletionNs(long latencyNanos)

    • recordWriteStateMachineCompletionNs

      public void recordWriteStateMachineCompletionNs(long latencyNanos)

    • recordWriteStateMachineQueueingLatencyNs

      public void recordWriteStateMachineQueueingLatencyNs(long latencyNanos)

    • recordUntilApplyTransactionNs

      public void recordUntilApplyTransactionNs(long latencyNanos)

    • recordStartTransactionCompleteNs

      public void recordStartTransactionCompleteNs(long latencyNanos)

    • incNumDataCacheMiss

      public void incNumDataCacheMiss()

    • incNumDataCacheHit

      public void incNumDataCacheHit()

    • incNumEvictedCacheCount

      public void incNumEvictedCacheCount()

    • incPendingApplyTransactions

      public void incPendingApplyTransactions()

    • decPendingApplyTransactions

      public void decPendingApplyTransactions()

    • unRegister

      public void unRegister()