public interface MetricsReplicationSourceSource
Modifier and Type | Field and Description |
---|---|
static String |
SOURCE_AGE_OF_LAST_SHIPPED_OP |
static String |
SOURCE_CLOSED_LOGS_WITH_UNKNOWN_LENGTH |
static String |
SOURCE_COMPLETED_LOGS |
static String |
SOURCE_COMPLETED_RECOVERY_QUEUES |
static String |
SOURCE_LOG_EDITS_FILTERED |
static String |
SOURCE_LOG_READ_IN_BYTES |
static String |
SOURCE_LOG_READ_IN_EDITS |
static String |
SOURCE_REPEATED_LOG_FILE_BYTES |
static String |
SOURCE_RESTARTED_LOG_READING |
static String |
SOURCE_SHIPPED_BATCHES |
static String |
SOURCE_SHIPPED_KBS |
static String |
SOURCE_SHIPPED_OPS |
static String |
SOURCE_SIZE_OF_LOG_QUEUE |
static String |
SOURCE_UNCLEANLY_CLOSED_IGNORED_IN_BYTES |
static String |
SOURCE_UNCLEANLY_CLOSED_LOGS |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
void |
decrSizeOfLogQueue(int size) |
long |
getLastShippedAge() |
void |
incrBatchesShipped(int batches) |
void |
incrBytesSkippedInUncleanlyClosedWALs(long bytes) |
void |
incrCompletedRecoveryQueue() |
void |
incrCompletedWAL() |
void |
incrLogEditsFiltered(long size) |
void |
incrLogReadInBytes(long size) |
void |
incrLogReadInEdits(long size) |
void |
incrOpsShipped(long ops) |
void |
incrRepeatedFileBytes(long bytes) |
void |
incrRestartedWALReading() |
void |
incrShippedKBs(long size) |
void |
incrSizeOfLogQueue(int size) |
void |
incrUncleanlyClosedWALs() |
void |
incrUnknownFileLengthForClosedWAL() |
void |
setLastShippedAge(long age) |
void |
setSizeOfLogQueue(int size) |
static final String SOURCE_SIZE_OF_LOG_QUEUE
static final String SOURCE_AGE_OF_LAST_SHIPPED_OP
static final String SOURCE_SHIPPED_BATCHES
static final String SOURCE_SHIPPED_KBS
static final String SOURCE_SHIPPED_OPS
static final String SOURCE_LOG_READ_IN_BYTES
static final String SOURCE_LOG_READ_IN_EDITS
static final String SOURCE_LOG_EDITS_FILTERED
static final String SOURCE_CLOSED_LOGS_WITH_UNKNOWN_LENGTH
static final String SOURCE_UNCLEANLY_CLOSED_LOGS
static final String SOURCE_UNCLEANLY_CLOSED_IGNORED_IN_BYTES
static final String SOURCE_RESTARTED_LOG_READING
static final String SOURCE_REPEATED_LOG_FILE_BYTES
static final String SOURCE_COMPLETED_LOGS
static final String SOURCE_COMPLETED_RECOVERY_QUEUES
void setLastShippedAge(long age)
void setSizeOfLogQueue(int size)
void incrSizeOfLogQueue(int size)
void decrSizeOfLogQueue(int size)
void incrLogEditsFiltered(long size)
void incrBatchesShipped(int batches)
void incrOpsShipped(long ops)
void incrShippedKBs(long size)
void incrLogReadInBytes(long size)
void incrLogReadInEdits(long size)
void clear()
long getLastShippedAge()
void incrUnknownFileLengthForClosedWAL()
void incrUncleanlyClosedWALs()
void incrBytesSkippedInUncleanlyClosedWALs(long bytes)
void incrRestartedWALReading()
void incrRepeatedFileBytes(long bytes)
void incrCompletedWAL()
void incrCompletedRecoveryQueue()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.