public class LeaderListenerCallback extends Object
A callback function when nimbus gains leadership.
Constructor and Description |
---|
LeaderListenerCallback(Map conf,
org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk,
BlobStore blobStore,
ILeaderElector leaderElector,
TopoCache tc,
IStormClusterState clusterState,
List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls,
StormMetricsRegistry metricsRegistry)
Constructor for .
|
Modifier and Type | Method and Description |
---|---|
void |
leaderCallBack()
Invoke when gains leadership.
|
void |
notLeaderCallback()
Invoke when lost leadership.
|
public LeaderListenerCallback(Map conf, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, BlobStore blobStore, ILeaderElector leaderElector, TopoCache tc, IStormClusterState clusterState, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, StormMetricsRegistry metricsRegistry)
Constructor for .
conf
- configzk
- zookeeper CuratorFramework clientblobStore
- BlobStoreleaderElector
- Leader electortc
- TopoCacheclusterState
- IStormClusterStateacls
- zookeeper aclsCopyright © 2022 The Apache Software Foundation. All rights reserved.