Package org.apache.bookkeeper.meta

Class NullMetadataBookieDriver.NullLedgerAuditorManager

java.lang.Object

org.apache.bookkeeper.meta.NullMetadataBookieDriver.NullLedgerAuditorManager

All Implemented Interfaces:

AutoCloseable, LedgerAuditorManager

Enclosing class:

NullMetadataBookieDriver

public static class NullMetadataBookieDriver.NullLedgerAuditorManager
extends Object
implements LedgerAuditorManager

A no-op implementation of LedgerAuditorManager.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.bookkeeper.meta.LedgerAuditorManager

LedgerAuditorManager.AuditorEvent

Constructor Summary

Constructors

Constructor	Description
NullLedgerAuditorManager()

Method Summary

Modifier and Type	Method	Description
void	close()
BookieId	getCurrentAuditor()	Return the information regarding the current auditor.
void	tryToBecomeAuditor(String bookieId, Consumer<LedgerAuditorManager.AuditorEvent> listener)	Try to become the auditor.

Methods inherited from class java.lang.Object

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

Constructor Details

NullLedgerAuditorManager

public NullLedgerAuditorManager()

Method Details

tryToBecomeAuditor

public void tryToBecomeAuditor(String bookieId,
 Consumer<LedgerAuditorManager.AuditorEvent> listener)
                        throws IOException,
InterruptedException

Description copied from interface: LedgerAuditorManager

Try to become the auditor. If there's already another auditor, it will wait until this current instance has become the auditor.

Specified by:

tryToBecomeAuditor in interface LedgerAuditorManager

Parameters:

bookieId - the identifier for current bookie

listener - listener that will receive AuditorEvent notifications

Throws:

IOException

InterruptedException

getCurrentAuditor

public BookieId getCurrentAuditor()
                           throws IOException,
InterruptedException

Description copied from interface: LedgerAuditorManager

Return the information regarding the current auditor.

Specified by:

getCurrentAuditor in interface LedgerAuditorManager

Returns:

Throws:

IOException

InterruptedException

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception