Package org.apache.bookkeeper.replication

Class AuditorTask

java.lang.Object

org.apache.bookkeeper.replication.AuditorTask

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

AuditorBookieCheckTask, AuditorCheckAllLedgersTask, AuditorPlacementPolicyCheckTask, AuditorReplicasCheckTask

abstract class AuditorTask
extends Object
implements Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static interface	AuditorTask.ShutdownTaskHandler	ShutdownTaskHandler used to shutdown auditor executor.

Field Summary

Fields

Modifier and Type	Field	Description
protected BookKeeperAdmin	admin
protected AuditorStats	auditorStats
protected final ServerConfiguration	conf
protected LedgerManager	ledgerManager
protected LedgerUnderreplicationManager	ledgerUnderreplicationManager

Constructor Summary

Constructors

Constructor	Description
AuditorTask(ServerConfiguration conf, AuditorStats auditorStats, BookKeeperAdmin admin, LedgerManager ledgerManager, LedgerUnderreplicationManager ledgerUnderreplicationManager, AuditorTask.ShutdownTaskHandler shutdownTaskHandler, BiConsumer<AtomicBoolean,Throwable> hasAuditCheckTask)

Method Summary

Modifier and Type	Method	Description
protected List<String>	getAvailableBookies()
(package private) BookKeeper	getBookKeeper(ServerConfiguration conf)	Get BookKeeper client according to configuration.
(package private) BookKeeperAdmin	getBookKeeperAdmin(BookKeeper bookKeeper)	Get BookKeeper admin according to bookKeeper client.
protected boolean	hasBookieCheckTask()
protected boolean	isLedgerReplicationEnabled()
protected CompletableFuture<?>	publishSuspectedLedgersAsync(Collection<String> missingBookies, Set<Long> ledgers)
void	run()
protected abstract void	runTask()
abstract void	shutdown()
protected void	submitShutdownTask()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

conf

protected final ServerConfiguration conf

auditorStats

protected AuditorStats auditorStats

admin

protected BookKeeperAdmin admin

ledgerManager

protected LedgerManager ledgerManager

ledgerUnderreplicationManager

protected LedgerUnderreplicationManager ledgerUnderreplicationManager

Constructor Details

AuditorTask

AuditorTask(ServerConfiguration conf,
 AuditorStats auditorStats,
 BookKeeperAdmin admin,
 LedgerManager ledgerManager,
 LedgerUnderreplicationManager ledgerUnderreplicationManager,
 AuditorTask.ShutdownTaskHandler shutdownTaskHandler,
 BiConsumer<AtomicBoolean,Throwable> hasAuditCheckTask)

Method Details

run

public void run()

Specified by:

run in interface Runnable

runTask

protected abstract void runTask()

isLedgerReplicationEnabled

protected boolean isLedgerReplicationEnabled()
                                      throws ReplicationException.UnavailableException

Throws:

ReplicationException.UnavailableException

publishSuspectedLedgersAsync

protected CompletableFuture<?> publishSuspectedLedgersAsync(Collection<String> missingBookies,
 Set<Long> ledgers)

getAvailableBookies

protected List<String> getAvailableBookies()
                                    throws BKException

Throws:

BKException

getBookKeeper

BookKeeper getBookKeeper(ServerConfiguration conf)
                  throws IOException,
InterruptedException

Get BookKeeper client according to configuration.

Parameters:

conf -

Returns:

Throws:

IOException

InterruptedException

getBookKeeperAdmin

BookKeeperAdmin getBookKeeperAdmin(BookKeeper bookKeeper)

Get BookKeeper admin according to bookKeeper client.

Parameters:

bookKeeper -

Returns:

submitShutdownTask

protected void submitShutdownTask()

shutdown

public abstract void shutdown()

hasBookieCheckTask

protected boolean hasBookieCheckTask()