Package org.apache.bookkeeper.meta

Class ZkLedgerAuditorManager

java.lang.Object

org.apache.bookkeeper.meta.ZkLedgerAuditorManager

All Implemented Interfaces:

AutoCloseable, LedgerAuditorManager

public class ZkLedgerAuditorManager
extends Object
implements LedgerAuditorManager

ZK based implementation of LedgerAuditorManager.

Nested Class Summary

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

LedgerAuditorManager.AuditorEvent

Constructor Summary

Constructors

Constructor	Description
ZkLedgerAuditorManager(org.apache.zookeeper.ZooKeeper zkc, ServerConfiguration conf, StatsLogger statsLogger)

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

ZkLedgerAuditorManager

public ZkLedgerAuditorManager(org.apache.zookeeper.ZooKeeper zkc,
 ServerConfiguration conf,
 StatsLogger statsLogger)

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