Class PulsarAdapterMetrics

java.lang.Object
io.nosqlbench.adapter.pulsar.util.PulsarAdapterMetrics
public class PulsarAdapterMetrics extends Object

  • Constructor Details

  • Method Details

    • initPulsarAdapterInstrumentation

      public void initPulsarAdapterInstrumentation()

    • getMsgErrOutOfSeqCounter

      public com.codahale.metrics.Counter getMsgErrOutOfSeqCounter()

    • getMsgErrLossCounter

      public com.codahale.metrics.Counter getMsgErrLossCounter()

    • getMsgErrDuplicateCounter

      public com.codahale.metrics.Counter getMsgErrDuplicateCounter()

    • getMessageSizeHistogram

      public com.codahale.metrics.Histogram getMessageSizeHistogram()

    • getE2eMsgProcLatencyHistogram

      public com.codahale.metrics.Histogram getE2eMsgProcLatencyHistogram()

    • getPayloadRttHistogram

      public com.codahale.metrics.Histogram getPayloadRttHistogram()

    • getBindTimer

      public com.codahale.metrics.Timer getBindTimer()

    • getExecuteTimer

      public com.codahale.metrics.Timer getExecuteTimer()

    • getCreateTransactionTimer

      public com.codahale.metrics.Timer getCreateTransactionTimer()

    • getCommitTransactionTimer

      public com.codahale.metrics.Timer getCommitTransactionTimer()

    • registerProducerApiMetrics

      public void registerProducerApiMetrics(org.apache.pulsar.client.api.Producer<?> producer)

    • registerConsumerApiMetrics

      public void registerConsumerApiMetrics(org.apache.pulsar.client.api.Consumer<?> consumer, String pulsarApiMetricsPrefix)