Package org.apache.bookkeeper.meta

Class NullMetadataBookieDriver.NullRegistrationManager

java.lang.Object

org.apache.bookkeeper.meta.NullMetadataBookieDriver.NullRegistrationManager

All Implemented Interfaces:

AutoCloseable, RegistrationManager

Enclosing class:

NullMetadataBookieDriver

public static class NullMetadataBookieDriver.NullRegistrationManager
extends Object
implements RegistrationManager

A no-op implementation of RegistrationManager.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.bookkeeper.discover.RegistrationManager

RegistrationManager.RegistrationListener

Constructor Summary

Constructors

Constructor	Description
NullRegistrationManager()

Method Summary

Modifier and Type	Method	Description
void	addRegistrationListener(RegistrationManager.RegistrationListener listener)	Add a listener to be triggered when an registration event occurs.
void	close()
boolean	format()	Do format boolean.
String	getClusterInstanceId()	Return the cluster instance id.
boolean	initNewCluster()	Initializes new cluster by creating required znodes for the cluster.
boolean	isBookieRegistered(BookieId bookieId)	Checks if Bookie with the given BookieId is registered as readwrite or readonly bookie.
boolean	nukeExistingCluster()	Nukes existing cluster metadata.
boolean	prepareFormat()	Prepare ledgers root node, availableNode, readonly node..
Versioned<byte[]>	readCookie(BookieId bookieId)	Read the cookie data, which will be used for verifying the integrity of the bookie environment.
void	registerBookie(BookieId bookieId, boolean readOnly, BookieServiceInfo bookieService)	Registering the bookie server as bookieId.
void	removeCookie(BookieId bookieId, Version version)	Remove the cookie data.
void	unregisterBookie(BookieId bookieId, boolean readOnly)	Unregistering the bookie server as bookieId.
void	writeCookie(BookieId bookieId, Versioned<byte[]> cookieData)	Write the cookie data, which will be used for verifying the integrity of the bookie environment.

Methods inherited from class java.lang.Object

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

Constructor Details

NullRegistrationManager

public NullRegistrationManager()

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface RegistrationManager

getClusterInstanceId

public String getClusterInstanceId()

Description copied from interface: RegistrationManager

Return the cluster instance id.

Specified by:

getClusterInstanceId in interface RegistrationManager

Returns:

the cluster instance id.

registerBookie

public void registerBookie(BookieId bookieId,
 boolean readOnly,
 BookieServiceInfo bookieService)

Description copied from interface: RegistrationManager

Registering the bookie server as bookieId.

Specified by:

registerBookie in interface RegistrationManager

Parameters:

bookieId - bookie id

readOnly - whether to register it as writable or readonly

bookieService - information about services exposed by the Bookie

unregisterBookie

public void unregisterBookie(BookieId bookieId,
 boolean readOnly)

Description copied from interface: RegistrationManager

Unregistering the bookie server as bookieId.

Specified by:

unregisterBookie in interface RegistrationManager

Parameters:

bookieId - bookie id

readOnly - whether to register it as writable or readonly

isBookieRegistered

public boolean isBookieRegistered(BookieId bookieId)

Description copied from interface: RegistrationManager

Checks if Bookie with the given BookieId is registered as readwrite or readonly bookie.

Specified by:

isBookieRegistered in interface RegistrationManager

Parameters:

bookieId - bookie id

Returns:

returns true if a bookie with bookieid is currently registered as readwrite or readonly bookie.

writeCookie

public void writeCookie(BookieId bookieId,
 Versioned<byte[]> cookieData)
                 throws BookieException

Description copied from interface: RegistrationManager

Write the cookie data, which will be used for verifying the integrity of the bookie environment.

Specified by:

writeCookie in interface RegistrationManager

Parameters:

bookieId - bookie id

cookieData - cookie data

Throws:

BookieException - when fail to write cookie

readCookie

public Versioned<byte[]> readCookie(BookieId bookieId)
                             throws BookieException

Description copied from interface: RegistrationManager

Read the cookie data, which will be used for verifying the integrity of the bookie environment.

Specified by:

readCookie in interface RegistrationManager

Parameters:

bookieId - bookie id

Returns:

versioned cookie data

Throws:

BookieException - when fail to read cookie

removeCookie

public void removeCookie(BookieId bookieId,
 Version version)

Description copied from interface: RegistrationManager

Remove the cookie data.

Specified by:

removeCookie in interface RegistrationManager

Parameters:

bookieId - bookie id

version - version of the cookie data

prepareFormat

public boolean prepareFormat()

Description copied from interface: RegistrationManager

Prepare ledgers root node, availableNode, readonly node..

Specified by:

prepareFormat in interface RegistrationManager

Returns:

Returns true if old data exists, false if not.

initNewCluster

public boolean initNewCluster()

Description copied from interface: RegistrationManager

Initializes new cluster by creating required znodes for the cluster. If ledgersrootpath is already existing then it will error out.

Specified by:

initNewCluster in interface RegistrationManager

Returns:

returns true if new cluster is successfully created or false if it failed to initialize.

format

public boolean format()

Description copied from interface: RegistrationManager

Do format boolean.

Specified by:

format in interface RegistrationManager

Returns:

Returns true if success do format, false if not.

nukeExistingCluster

public boolean nukeExistingCluster()

Description copied from interface: RegistrationManager

Nukes existing cluster metadata.

Specified by:

nukeExistingCluster in interface RegistrationManager

Returns:

returns true if cluster metadata is successfully nuked or false if it failed to nuke the cluster metadata.

addRegistrationListener

public void addRegistrationListener(RegistrationManager.RegistrationListener listener)

Description copied from interface: RegistrationManager

Add a listener to be triggered when an registration event occurs.

Specified by:

addRegistrationListener in interface RegistrationManager

Parameters:

listener - the listener to be added