public class PushReplicationManagerMetrics extends Object implements AutoCloseable
Modifier and Type | Field and Description |
---|---|
static String |
EVENT_PROCESSING_FAILURE |
static String |
EVENT_QUEUE_PROCESSING_TIME_MS |
static String |
FOLLOWERS_NOT_CATCHING_UP |
static String |
METRIC_GROUP_NAME |
static String |
METRIC_TYPE_NAME |
org.apache.kafka.common.metrics.Metrics |
metrics |
static String |
PUSH_MANAGER_MEMORY_BYTES_USED |
static String |
PUSH_SESSION_END_COUNT |
static String |
STOPPING_PUSH_SESSIONS |
Constructor and Description |
---|
PushReplicationManagerMetrics(org.apache.kafka.common.metrics.Metrics metrics,
com.yammer.metrics.core.Meter replicationBytesOutMeter,
ReplicationQuotaRecorder replicationQuotaRecorder) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.kafka.common.metrics.KafkaMetric |
eventQueueProcessingTimeMetric(String histogramMetricSuffix) |
void |
incrementEventProcessingFailureCount() |
void |
incrementFollowersNotCatchingUpCount() |
void |
incrementPushSessionEndCount(PushSessionEndReason pushSessionEndReason) |
void |
recordAppendRecordsRequest(org.apache.kafka.common.message.AppendRecordsRequestData requestData) |
void |
registerMemoryBytesUsedGauge(com.yammer.metrics.core.Gauge<Long> memoryBytesUsedGauge) |
void |
registerStoppingPushSessionSupplier(Supplier<Integer> supplier) |
void |
updateEventQueueProcessingTime(long queueTimeMs) |
public static final String METRIC_GROUP_NAME
public static final String METRIC_TYPE_NAME
public static final String EVENT_PROCESSING_FAILURE
public static final String EVENT_QUEUE_PROCESSING_TIME_MS
public static final String PUSH_MANAGER_MEMORY_BYTES_USED
public static final String PUSH_SESSION_END_COUNT
public static final String STOPPING_PUSH_SESSIONS
public static final String FOLLOWERS_NOT_CATCHING_UP
public final org.apache.kafka.common.metrics.Metrics metrics
public PushReplicationManagerMetrics(org.apache.kafka.common.metrics.Metrics metrics, com.yammer.metrics.core.Meter replicationBytesOutMeter, ReplicationQuotaRecorder replicationQuotaRecorder)
public void recordAppendRecordsRequest(org.apache.kafka.common.message.AppendRecordsRequestData requestData)
public void updateEventQueueProcessingTime(long queueTimeMs)
public void incrementPushSessionEndCount(PushSessionEndReason pushSessionEndReason)
public void incrementEventProcessingFailureCount()
public void incrementFollowersNotCatchingUpCount()
public void registerMemoryBytesUsedGauge(com.yammer.metrics.core.Gauge<Long> memoryBytesUsedGauge)
public void registerStoppingPushSessionSupplier(Supplier<Integer> supplier)
public void close()
close
in interface AutoCloseable
public org.apache.kafka.common.metrics.KafkaMetric eventQueueProcessingTimeMetric(String histogramMetricSuffix)