Package org.apache.curator.framework.imps

Class ReconfigBuilderImpl

java.lang.Object

org.apache.curator.framework.imps.ReconfigBuilderImpl

All Implemented Interfaces:

Backgroundable<ErrorListenerReconfigBuilderMain>, ErrorListenerReconfigBuilderMain, Joinable<LeaveStatConfigEnsembleable>, Leaveable<JoinStatConfigEnsembleable>, Membersable<StatConfigureEnsembleable>, ReconfigBuilder, ReconfigBuilderMain

public class ReconfigBuilderImpl
extends Object
implements ReconfigBuilder, ErrorListenerReconfigBuilderMain

Constructor Summary

Constructors

Constructor	Description
ReconfigBuilderImpl(CuratorFrameworkBase client)
ReconfigBuilderImpl(CuratorFrameworkBase client, Backgrounding backgrounding, org.apache.zookeeper.data.Stat responseStat, long fromConfig, List<String> newMembers, List<String> joining, List<String> leaving)

Method Summary

Modifier and Type	Method	Description
byte[]	forEnsemble()
CuratorEventType	getBackgroundEventType()
ErrorListenerReconfigBuilderMain	inBackground()	Perform the action in the background
ErrorListenerReconfigBuilderMain	inBackground(Object context)	Perform the action in the background
ErrorListenerReconfigBuilderMain	inBackground(BackgroundCallback callback)	Perform the action in the background
ErrorListenerReconfigBuilderMain	inBackground(BackgroundCallback callback, Object context)	Perform the action in the background
ErrorListenerReconfigBuilderMain	inBackground(BackgroundCallback callback, Object context, Executor executor)	Perform the action in the background
ErrorListenerReconfigBuilderMain	inBackground(BackgroundCallback callback, Executor executor)	Perform the action in the background
LeaveStatConfigEnsembleable	joining(String... server)	Adds one or more servers to joining the ensemble.
LeaveStatConfigEnsembleable	joining(List<String> servers)	Adds one or more servers to joining the ensemble.
JoinStatConfigEnsembleable	leaving(String... server)	Sets one or more servers to leaving the ensemble.
JoinStatConfigEnsembleable	leaving(List<String> servers)	Sets one or more servers to leaving the ensemble.
void	performBackgroundOperation(org.apache.curator.framework.imps.OperationAndData<Void> data)
StatConfigureEnsembleable	withNewMembers(String... server)	Sets one or more members that are meant to be the ensemble.
StatConfigureEnsembleable	withNewMembers(List<String> servers)	Sets one or more members that are meant to be the ensemble.
ReconfigBuilderMain	withUnhandledErrorListener(UnhandledErrorListener listener)	Set an error listener for this background operation.

Methods inherited from class java.lang.Object

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

Constructor Details

ReconfigBuilderImpl

public ReconfigBuilderImpl(CuratorFrameworkBase client)

ReconfigBuilderImpl

public ReconfigBuilderImpl(CuratorFrameworkBase client,
 Backgrounding backgrounding,
 org.apache.zookeeper.data.Stat responseStat,
 long fromConfig,
 List<String> newMembers,
 List<String> joining,
 List<String> leaving)

Method Details

forEnsemble

public byte[] forEnsemble()
                   throws Exception

Throws:

Exception

inBackground

public ErrorListenerReconfigBuilderMain inBackground()

Description copied from interface: Backgroundable

Perform the action in the background

Specified by:

inBackground in interface Backgroundable<ErrorListenerReconfigBuilderMain>

Returns:

this

inBackground

public ErrorListenerReconfigBuilderMain inBackground(Object context)

Description copied from interface: Backgroundable

Perform the action in the background

Specified by:

inBackground in interface Backgroundable<ErrorListenerReconfigBuilderMain>

Parameters:

context - context object - will be available from the event sent to the listener

Returns:

this

inBackground

public ErrorListenerReconfigBuilderMain inBackground(BackgroundCallback callback)

Description copied from interface: Backgroundable

Perform the action in the background

Specified by:

inBackground in interface Backgroundable<ErrorListenerReconfigBuilderMain>

Parameters:

callback - a functor that will get called when the operation has completed

Returns:

this

inBackground

public ErrorListenerReconfigBuilderMain inBackground(BackgroundCallback callback,
 Object context)

Description copied from interface: Backgroundable

Perform the action in the background

Specified by:

inBackground in interface Backgroundable<ErrorListenerReconfigBuilderMain>

Parameters:

callback - a functor that will get called when the operation has completed

context - context object - will be available from the event sent to the listener

Returns:

this

inBackground

public ErrorListenerReconfigBuilderMain inBackground(BackgroundCallback callback,
 Executor executor)

Description copied from interface: Backgroundable

Perform the action in the background

Specified by:

inBackground in interface Backgroundable<ErrorListenerReconfigBuilderMain>

Parameters:

callback - a functor that will get called when the operation has completed

executor - executor to use for the background call

Returns:

this

inBackground

public ErrorListenerReconfigBuilderMain inBackground(BackgroundCallback callback,
 Object context,
 Executor executor)

Description copied from interface: Backgroundable

Perform the action in the background

Specified by:

inBackground in interface Backgroundable<ErrorListenerReconfigBuilderMain>

Parameters:

callback - a functor that will get called when the operation has completed

context - context object - will be available from the event sent to the listener

executor - executor to use for the background call

Returns:

this

withUnhandledErrorListener

public ReconfigBuilderMain withUnhandledErrorListener(UnhandledErrorListener listener)

Description copied from interface: ErrorListenerReconfigBuilderMain

Set an error listener for this background operation. If an exception occurs while processing the call in the background, this listener will be called.

Specified by:

withUnhandledErrorListener in interface ErrorListenerReconfigBuilderMain

Parameters:

listener - the listener

Returns:

this for chaining

withNewMembers

public StatConfigureEnsembleable withNewMembers(String... server)

Description copied from interface: Membersable

Sets one or more members that are meant to be the ensemble. The expected format is server.[id]=[hostname]:[peer port]:[election port]:[type];[client port]

Specified by:

withNewMembers in interface Membersable<StatConfigureEnsembleable>

Parameters:

server - The server joining.

Returns:

this

withNewMembers

public StatConfigureEnsembleable withNewMembers(List<String> servers)

Description copied from interface: Membersable

Sets one or more members that are meant to be the ensemble. The expected format is server.[id]=[hostname]:[peer port]:[election port]:[type];[client port]

Specified by:

withNewMembers in interface Membersable<StatConfigureEnsembleable>

Parameters:

servers - The servers joining.

Returns:

this

joining

public LeaveStatConfigEnsembleable joining(String... server)

Description copied from interface: Joinable

Adds one or more servers to joining the ensemble. The expected format is server.[id]=[hostname]:[peer port]:[election port]:[type];[client port]

Specified by:

joining in interface Joinable<LeaveStatConfigEnsembleable>

Parameters:

server - The server joining.

Returns:

this

joining

public LeaveStatConfigEnsembleable joining(List<String> servers)

Description copied from interface: Joinable

Adds one or more servers to joining the ensemble. The expected format is server.[id]=[hostname]:[peer port]:[election port]:[type];[client port]

Specified by:

joining in interface Joinable<LeaveStatConfigEnsembleable>

Parameters:

servers - The servers joining.

Returns:

this

leaving

public JoinStatConfigEnsembleable leaving(String... server)

Description copied from interface: Leaveable

Sets one or more servers to leaving the ensemble.

Specified by:

leaving in interface Leaveable<JoinStatConfigEnsembleable>

Parameters:

server - The server ids

Returns:

this

leaving

public JoinStatConfigEnsembleable leaving(List<String> servers)

Description copied from interface: Leaveable

Sets one or more servers to leaving the ensemble.

Specified by:

leaving in interface Leaveable<JoinStatConfigEnsembleable>

Parameters:

servers - The server ids

Returns:

this

getBackgroundEventType

public CuratorEventType getBackgroundEventType()

performBackgroundOperation

public void performBackgroundOperation(org.apache.curator.framework.imps.OperationAndData<Void> data)
                                throws Exception

Throws:

Exception