co.cask.coopr.common.zookeeper

Class LeaderElection

java.lang.Object

co.cask.coopr.common.zookeeper.LeaderElection

All Implemented Interfaces:

org.apache.twill.common.Cancellable

public final class LeaderElection
extends Object
implements org.apache.twill.common.Cancellable

Performs leader election as specified in Zookeeper recipes.

Constructor Summary

Constructors

Constructor and Description
LeaderElection(org.apache.twill.zookeeper.ZKClient zkClient, String prefix, ElectionHandler handler)

Method Summary

Methods

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<?>	asyncCancel() Withdraw from the leader election process asynchronously.
void	cancel() Withdraw from the leader election process.

Methods inherited from class java.lang.Object

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

Constructor Detail

LeaderElection

public LeaderElection(org.apache.twill.zookeeper.ZKClient zkClient,
              String prefix,
              ElectionHandler handler)

Method Detail

cancel

public void cancel()

Withdraw from the leader election process. This method will block until cancelling is completed, meaning the ElectionHandler.follower() is returned if currently is a leader and the ZK node is removed.

Specified by:

cancel in interface org.apache.twill.common.Cancellable

asyncCancel

public com.google.common.util.concurrent.ListenableFuture<?> asyncCancel()

Withdraw from the leader election process asynchronously.

Returns:

A ListenableFuture that will be completed when cancelling is completed.