public class RestoreMetricsManager extends Object
Constructor and Description |
---|
RestoreMetricsManager(org.apache.kafka.common.metrics.Metrics metrics,
String clusterId) |
Modifier and Type | Method and Description |
---|---|
void |
endRestoreRecord() |
long |
readGauge(String metricName) |
void |
record(String metricName,
long value) |
void |
recordReplayedEventMetrics(TierRecordType recordType,
Boolean appendSucceeded) |
void |
recordRestoreFetchFtpsFailures(long value) |
void |
recordRestoreListVersionsFailures(long value) |
void |
recordRestoreObjectCopyFailures(long value) |
void |
recordRestoreOverallRate()
calculate restore overall rate (bytes / second):
restore_bytes_success / duration_of_restore_in_second
|
org.apache.kafka.common.metrics.Sensor |
restoreFetchFtpsMs() |
org.apache.kafka.common.metrics.Sensor |
restoreFetchTierTopicSnapshotMs() |
org.apache.kafka.common.metrics.Sensor |
restoreListVersionsMs() |
org.apache.kafka.common.metrics.Sensor |
restoreObjectCopyMs() |
void |
startRestoreRecord() |
void |
update(String metricName,
long value) |
public static final String RESTORE_STARTED
public static final String RESTORE_IN_PROGRESS
public static final String RESTORE_END_WITH_SUCCESS
public static final String RESTORE_END_WITH_FAILURE
public static final String RESTORE_PARTITIONS_WAITING_COUNT
public static final String RESTORE_PARTITIONS_IN_PROGRESS_COUNT
public static final String RESTORE_PARTITIONS_FAILED_COUNT
public static final String RESTORE_PARTITIONS_COMPLETED_COUNT
public static final String RESTORE_FILES_SUCCESS
public static final String RESTORE_FILES_FAILED
public static final String RESTORE_SEGMENTS_SUCCESS
public static final String RESTORE_SEGMENTS_FAILED
public static final String RESTORE_BYTES_SUCCESS
public static final String RESTORE_BYTES_FAILED
public static final String RESTORE_TIME_TO_REPLAY_EVENTS_MS
public static final String RESTORE_EVENTS_REPLAYED_COUNT
public static final String RESTORE_EVENTS_REPLAY_FAILED_COUNT
public static final String RESTORE_EVENTS_COMMIT_AND_SWAP_COUNT
public static final String RESTORE_EVENTS_FORCE_RESTORE_OR_UNFREEZE_COUNT
public static final String RESTORE_EVENTS_SEGMENTS_TO_RESTORE_COUNT
public static final String RESTORE_EVENTS_SEGMENTS_TO_DELETE_COUNT
public static final String RESTORE_TIME_TO_BUILD_FTPS_STATES_FROM_SNAPSHOTS_MS
public static final String RESTORE_OVERALL_RATE_BYTES_PER_SECOND
public static final String RESTORE_OBJECT_COPY_MS
public static final String RESTORE_LIST_VERSIONS_MS
public static final String RESTORE_FETCH_FTPS_MS
public static final String RESTORE_FETCH_TIER_TOPIC_SNAPSHOT_MS
public static final String RESTORE_OBJECT_COPY_FAILURES
public static final String RESTORE_LIST_VERSIONS_FAILURES
public static final String RESTORE_FETCH_FTPS_FAILURES
public RestoreMetricsManager(org.apache.kafka.common.metrics.Metrics metrics, String clusterId)
public void record(String metricName, long value)
public void update(String metricName, long value)
public long readGauge(String metricName)
public org.apache.kafka.common.metrics.Sensor restoreObjectCopyMs()
public org.apache.kafka.common.metrics.Sensor restoreListVersionsMs()
public org.apache.kafka.common.metrics.Sensor restoreFetchFtpsMs()
public org.apache.kafka.common.metrics.Sensor restoreFetchTierTopicSnapshotMs()
public void recordReplayedEventMetrics(TierRecordType recordType, Boolean appendSucceeded)
public void startRestoreRecord()
public void endRestoreRecord()
public void recordRestoreOverallRate()
public void recordRestoreObjectCopyFailures(long value)
public void recordRestoreListVersionsFailures(long value)
public void recordRestoreFetchFtpsFailures(long value)