Uses of Interface
org.apache.storm.nimbus.ILeaderElector

Packages that use ILeaderElector

Package	Description
org.apache.storm
org.apache.storm.blobstore
org.apache.storm.daemon.nimbus
org.apache.storm.hdfs.blobstore
org.apache.storm.nimbus
org.apache.storm.testing
org.apache.storm.utils
org.apache.storm.zookeeper

Uses of ILeaderElector in org.apache.storm

Methods in org.apache.storm with parameters of type ILeaderElector

Modifier and Type	Method and Description
LocalCluster.Builder	LocalCluster.Builder.withLeaderElector(ILeaderElector leaderElector) Use the following leaderElector instead of the one in the config.

Uses of ILeaderElector in org.apache.storm.blobstore

Methods in org.apache.storm.blobstore with parameters of type ILeaderElector

Modifier and Type	Method and Description
void	LocalFsBlobStore.prepare(Map<String,Object> conf, String overrideBase, NimbusInfo nimbusInfo, ILeaderElector leaderElector)
abstract void	BlobStore.prepare(Map<String,Object> conf, String baseDir, NimbusInfo nimbusInfo, ILeaderElector leaderElector) Allows us to initialize the blob store.
void	LocalFsBlobStore.setLeaderElector(ILeaderElector leaderElector) Sets leader elector (only used by LocalFsBlobStore to help sync blobs between Nimbi.
abstract void	BlobStore.setLeaderElector(ILeaderElector leaderElector) Sets leader elector (only used by LocalFsBlobStore to help sync blobs between Nimbi.

Uses of ILeaderElector in org.apache.storm.daemon.nimbus

Constructors in org.apache.storm.daemon.nimbus with parameters of type ILeaderElector

Constructor and Description
Nimbus(Map<String,Object> conf, INimbus inimbus, IStormClusterState stormClusterState, NimbusInfo hostPortInfo, BlobStore blobStore, ILeaderElector leaderElector, IGroupMappingServiceProvider groupMapper, StormMetricsRegistry metricsRegistry)
Nimbus(Map<String,Object> conf, INimbus inimbus, IStormClusterState stormClusterState, NimbusInfo hostPortInfo, BlobStore blobStore, TopoCache topoCache, ILeaderElector leaderElector, IGroupMappingServiceProvider groupMapper, StormMetricsRegistry metricsRegistry)

Uses of ILeaderElector in org.apache.storm.hdfs.blobstore

Methods in org.apache.storm.hdfs.blobstore with parameters of type ILeaderElector

Modifier and Type	Method and Description
void	HdfsBlobStore.prepare(Map<String,Object> conf, String overrideBase, NimbusInfo nimbusInfo, ILeaderElector leaderElector)
void	HdfsBlobStore.setLeaderElector(ILeaderElector leaderElector) Sets leader elector (only used by LocalFsBlobStore to help sync blobs between Nimbi.

Uses of ILeaderElector in org.apache.storm.nimbus

Constructors in org.apache.storm.nimbus with parameters of type ILeaderElector

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 .

Uses of ILeaderElector in org.apache.storm.testing

Classes in org.apache.storm.testing that implement ILeaderElector

Modifier and Type	Class and Description
class	MockLeaderElector

Uses of ILeaderElector in org.apache.storm.utils

Methods in org.apache.storm.utils with parameters of type ILeaderElector

Modifier and Type	Method and Description
static BlobStore	ServerUtils.getNimbusBlobStore(Map<String,Object> conf, NimbusInfo nimbusInfo, ILeaderElector leaderElector)
static BlobStore	ServerUtils.getNimbusBlobStore(Map<String,Object> conf, String baseDir, NimbusInfo nimbusInfo, ILeaderElector leaderElector)

Uses of ILeaderElector in org.apache.storm.zookeeper

Classes in org.apache.storm.zookeeper that implement ILeaderElector

Modifier and Type	Class and Description
class	LeaderElectorImp

Methods in org.apache.storm.zookeeper that return ILeaderElector

Modifier and Type	Method and Description
static ILeaderElector	Zookeeper.zkLeaderElector(Map<String,Object> conf, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, BlobStore blobStore, TopoCache tc, IStormClusterState clusterState, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, StormMetricsRegistry metricsRegistry) Get master leader elector.
protected ILeaderElector	Zookeeper.zkLeaderElectorImpl(Map<String,Object> conf, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zk, BlobStore blobStore, TopoCache tc, IStormClusterState clusterState, List<org.apache.storm.shade.org.apache.zookeeper.data.ACL> acls, StormMetricsRegistry metricsRegistry)

Methods in org.apache.storm.zookeeper with parameters of type ILeaderElector

Modifier and Type	Method and Description
org.apache.storm.shade.org.apache.curator.framework.recipes.leader.LeaderLatchListener	LeaderListenerCallbackFactory.create(ILeaderElector elector)