Class AuditorCheckAllLedgersTask
java.lang.Object
org.apache.bookkeeper.replication.AuditorTask
org.apache.bookkeeper.replication.AuditorCheckAllLedgersTask
- All Implemented Interfaces:
Runnable
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.bookkeeper.replication.AuditorTask
AuditorTask.ShutdownTaskHandler -
Field Summary
Fields inherited from class org.apache.bookkeeper.replication.AuditorTask
admin, auditorStats, conf, ledgerManager, ledgerUnderreplicationManager -
Constructor Summary
ConstructorsConstructorDescriptionAuditorCheckAllLedgersTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, BiConsumer<AtomicBoolean, Throwable> hasAuditCheckTask) -
Method Summary
Methods inherited from class org.apache.bookkeeper.replication.AuditorTask
getAvailableBookies, getBookKeeper, getBookKeeperAdmin, hasBookieCheckTask, isLedgerReplicationEnabled, publishSuspectedLedgersAsync, run, submitShutdownTask
-
Constructor Details
-
AuditorCheckAllLedgersTask
AuditorCheckAllLedgersTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, BiConsumer<AtomicBoolean, Throwable> hasAuditCheckTask) throws ReplicationException.UnavailableException
-
-
Method Details
-
runTask
protected void runTask()- Specified by:
runTaskin classAuditorTask
-
shutdown
public void shutdown()- Specified by:
shutdownin classAuditorTask
-
checkAllLedgers
List all the ledgers and check them individually. This should not be run very often.
-