@Internal public class ChangeStreamMetrics extends java.lang.Object implements java.io.Serializable
Modifier and Type | Field and Description |
---|---|
static Counter |
CHANGE_STREAM_MUTATION_GC_COUNT
Counter for the total number of ChangeStreamMutations that are initiated by garbage collection
(not user initiated) identified during the execution of the Connector.
|
static Counter |
CHANGE_STREAM_MUTATION_USER_COUNT
Counter for the total number of ChangeStreamMutations that are initiated by users (not garbage
collection) identified during the execution of the Connector.
|
static Counter |
CLOSESTREAM_COUNT
Counter for the total number of heartbeats identified during the execution of the Connector.
|
static Counter |
HEARTBEAT_COUNT
Counter for the total number of heartbeats identified during the execution of the Connector.
|
static Counter |
LIST_PARTITIONS_COUNT
Counter for the total number of partitions identified during the execution of the Connector.
|
static Counter |
PARTITION_MERGE_COUNT
Counter for the total number of partition merges identified during the execution of the
Connector.
|
static Counter |
PARTITION_SPLIT_COUNT
Counter for the total number of partition splits / moves identified during the execution of the
Connector.
|
static Counter |
PARTITION_STREAM_COUNT
Counter for the total number of active partitions being streamed.
|
static Distribution |
PROCESSING_DELAY_FROM_COMMIT_TIMESTAMP
Distribution for measuring processing delay from commit timestamp.
|
Constructor and Description |
---|
ChangeStreamMetrics() |
Modifier and Type | Method and Description |
---|---|
void |
decPartitionStreamCount()
Decrements the
PARTITION_STREAM_COUNT
by 1. |
void |
incChangeStreamMutationGcCounter()
Increments the
CHANGE_STREAM_MUTATION_GC_COUNT
by 1 if the metric is enabled. |
void |
incChangeStreamMutationUserCounter()
Increments the
CHANGE_STREAM_MUTATION_USER_COUNT
by 1 if the metric is enabled. |
void |
incClosestreamCount()
Increments the
CLOSESTREAM_COUNT by 1
if the metric is enabled. |
void |
incHeartbeatCount()
Increments the
HEARTBEAT_COUNT by 1 if
the metric is enabled. |
void |
incListPartitionsCount()
Increments the
LIST_PARTITIONS_COUNT by
1 if the metric is enabled. |
void |
incPartitionMergeCount()
Increments the
PARTITION_MERGE_COUNT by
1 if the metric is enabled. |
void |
incPartitionSplitCount()
Increments the
PARTITION_SPLIT_COUNT by
1 if the metric is enabled. |
void |
incPartitionStreamCount()
Increments the
PARTITION_STREAM_COUNT
by 1. |
void |
updateProcessingDelayFromCommitTimestamp(long durationInMilli)
Adds measurement of an instance for the
PROCESSING_DELAY_FROM_COMMIT_TIMESTAMP . |
public static final Counter LIST_PARTITIONS_COUNT
public static final Counter PARTITION_SPLIT_COUNT
public static final Counter PARTITION_MERGE_COUNT
public static final Counter HEARTBEAT_COUNT
public static final Counter CLOSESTREAM_COUNT
public static final Counter CHANGE_STREAM_MUTATION_USER_COUNT
public static final Counter CHANGE_STREAM_MUTATION_GC_COUNT
public static final Distribution PROCESSING_DELAY_FROM_COMMIT_TIMESTAMP
public static final Counter PARTITION_STREAM_COUNT
public void incListPartitionsCount()
LIST_PARTITIONS_COUNT
by
1 if the metric is enabled.public void incPartitionSplitCount()
PARTITION_SPLIT_COUNT
by
1 if the metric is enabled.public void incPartitionMergeCount()
PARTITION_MERGE_COUNT
by
1 if the metric is enabled.public void incHeartbeatCount()
HEARTBEAT_COUNT
by 1 if
the metric is enabled.public void incClosestreamCount()
CLOSESTREAM_COUNT
by 1
if the metric is enabled.public void incChangeStreamMutationUserCounter()
CHANGE_STREAM_MUTATION_USER_COUNT
by 1 if the metric is enabled.public void incChangeStreamMutationGcCounter()
CHANGE_STREAM_MUTATION_GC_COUNT
by 1 if the metric is enabled.public void incPartitionStreamCount()
PARTITION_STREAM_COUNT
by 1.public void decPartitionStreamCount()
PARTITION_STREAM_COUNT
by 1.public void updateProcessingDelayFromCommitTimestamp(long durationInMilli)
PROCESSING_DELAY_FROM_COMMIT_TIMESTAMP
.