Package org.apache.bookkeeper.meta

Class NullMetadataBookieDriver.NullLedgerAuditorManager

java.lang.Object

org.apache.bookkeeper.meta.NullMetadataBookieDriver.NullLedgerAuditorManager

All Implemented Interfaces:

java.lang.AutoCloseable, LedgerAuditorManager

Enclosing class:

NullMetadataBookieDriver

public static class NullMetadataBookieDriver.NullLedgerAuditorManager
extends java.lang.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(java.lang.String bookieId, java.util.function.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 Detail

NullLedgerAuditorManager

public NullLedgerAuditorManager()

Method Detail

tryToBecomeAuditor

public void tryToBecomeAuditor(java.lang.String bookieId,
                               java.util.function.Consumer<LedgerAuditorManager.AuditorEvent> listener)
                        throws java.io.IOException,
                               java.lang.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:

java.io.IOException

java.lang.InterruptedException

getCurrentAuditor

public BookieId getCurrentAuditor()
                           throws java.io.IOException,
                                  java.lang.InterruptedException

Description copied from interface: LedgerAuditorManager

Return the information regarding the current auditor.

Specified by:

getCurrentAuditor in interface LedgerAuditorManager

Returns:

Throws:

java.io.IOException

java.lang.InterruptedException

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception