public class BlockingEnvelopeMap.BlockingEnvelopeMapMetrics
extends java.lang.Object
Constructor and Description |
---|
BlockingEnvelopeMapMetrics(java.lang.String group,
MetricsRegistry metricsRegistry) |
Modifier and Type | Method and Description |
---|---|
void |
incBlockingPoll(SystemStreamPartition systemStreamPartition) |
void |
incBlockingTimeoutPoll(SystemStreamPartition systemStreamPartition) |
void |
incPoll() |
void |
initMetrics(SystemStreamPartition systemStreamPartition) |
void |
setNoMoreMessages(SystemStreamPartition systemStreamPartition,
boolean noMoreMessages) |
public BlockingEnvelopeMapMetrics(java.lang.String group, MetricsRegistry metricsRegistry)
public void initMetrics(SystemStreamPartition systemStreamPartition)
public void setNoMoreMessages(SystemStreamPartition systemStreamPartition, boolean noMoreMessages)
public void incBlockingPoll(SystemStreamPartition systemStreamPartition)
public void incBlockingTimeoutPoll(SystemStreamPartition systemStreamPartition)
public void incPoll()