public class RestoreMetricsManager extends Object
Modifier and Type | Field and Description |
---|---|
static String |
RESTORE_BYTES_FAILED |
static String |
RESTORE_BYTES_SUCCESS |
static String |
RESTORE_END_WITH_FAILURE |
static String |
RESTORE_END_WITH_SUCCESS |
static String |
RESTORE_FETCH_FTPS_MS |
static String |
RESTORE_FILES_FAILED |
static String |
RESTORE_FILES_SUCCESS |
static String |
RESTORE_IN_PROGRESS
The cluster(job) level restore status metrics
RESTORE_IN_PROGRESS:
= 1, restore job is running
= 0, restore job not running
RESTORE_END_WITH_SUCCESS
= 1, restore job ended with status as success
= 0, restore job not end yet or ended with status as failure
RESTORE_END_WITH_FAILURE
= 1, restore job ended with status as failure
= 0, restore job not end yet or ended with status as success
|
static String |
RESTORE_LIST_VERSIONS_MS |
static String |
RESTORE_OBJECT_COPY_MS |
static String |
RESTORE_OVERALL_RATE_BYTES_PER_SECOND |
static String |
RESTORE_PARTITIONS_COMPLETED_COUNT |
static String |
RESTORE_PARTITIONS_FAILED_COUNT |
static String |
RESTORE_PARTITIONS_IN_PROGRESS_COUNT |
static String |
RESTORE_PARTITIONS_WAITING_COUNT |
static String |
RESTORE_SEGMENTS_FAILED |
static String |
RESTORE_SEGMENTS_SUCCESS |
static String |
RESTORE_STARTED |
Constructor and Description |
---|
RestoreMetricsManager(org.apache.kafka.common.metrics.Metrics metrics,
String clusterId) |
Modifier and Type | Method and Description |
---|---|
void |
endRestoreRecord() |
void |
record(String metricName,
long value) |
org.apache.kafka.common.metrics.Sensor |
restoreFetchFtpsMs() |
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_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 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 org.apache.kafka.common.metrics.Sensor restoreObjectCopyMs()
public org.apache.kafka.common.metrics.Sensor restoreListVersionsMs()
public org.apache.kafka.common.metrics.Sensor restoreFetchFtpsMs()
public void startRestoreRecord()
public void endRestoreRecord()