Uses of Class
org.apache.storm.nimbus.NimbusInfo

Packages that use NimbusInfo

Package	Description
org.apache.storm.blobstore
org.apache.storm.cluster
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 NimbusInfo in org.apache.storm.blobstore

Methods in org.apache.storm.blobstore that return types with arguments of type NimbusInfo

Modifier and Type	Method	Description
static Set<NimbusInfo>	BlobStoreUtils.getNimbodesWithLatestSequenceNumberOfBlob(org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, String key)

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

Modifier and Type	Method	Description
static void	BlobStoreUtils.createStateInZookeeper(Map<String,Object> conf, String key, NimbusInfo nimbusInfo)
abstract void	BlobStore.prepare(Map<String,Object> conf, String baseDir, NimbusInfo nimbusInfo, ILeaderElector leaderElector)	Allows us to initialize the blob store.
void	LocalFsBlobStore.prepare(Map<String,Object> conf, String overrideBase, NimbusInfo nimbusInfo, ILeaderElector leaderElector)
void	LocalFsBlobStoreSynchronizer.setNimbusInfo(NimbusInfo nimbusInfo)
static void	BlobStoreUtils.updateKeyForBlobStore(Map<String,Object> conf, BlobStore blobStore, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient, String key, NimbusInfo nimbusDetails)

Method parameters in org.apache.storm.blobstore with type arguments of type NimbusInfo

Modifier and Type	Method	Description
static boolean	BlobStoreUtils.downloadMissingBlob(Map<String,Object> conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos)
static boolean	BlobStoreUtils.downloadUpdatedBlob(Map<String,Object> conf, BlobStore blobStore, String key, Set<NimbusInfo> nimbusInfos)

Constructors in org.apache.storm.blobstore with parameters of type NimbusInfo

Modifier	Constructor	Description
	KeySequenceNumber(String key, NimbusInfo nimbusInfo)

Uses of NimbusInfo in org.apache.storm.cluster

Methods in org.apache.storm.cluster that return NimbusInfo

Modifier and Type	Method	Description
NimbusInfo	IStormClusterState.getLeader(Runnable callback)	Get leader info from state store, which was written when a master gains leadership.
NimbusInfo	StormClusterStateImpl.getLeader(Runnable callback)

Methods in org.apache.storm.cluster with parameters of type NimbusInfo

Modifier and Type	Method	Description
void	IStormClusterState.setupBlob(String key, NimbusInfo nimbusInfo, Integer versionInfo)
void	StormClusterStateImpl.setupBlob(String key, NimbusInfo nimbusInfo, Integer versionInfo)

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

Methods in org.apache.storm.daemon.nimbus with parameters of type NimbusInfo

Modifier and Type	Method	Description
static int	Nimbus.getVersionForKey(String key, NimbusInfo nimbusInfo, org.apache.storm.shade.org.apache.curator.framework.CuratorFramework zkClient)

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

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

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

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

Modifier and Type	Method	Description
void	HdfsBlobStore.prepare(Map<String,Object> conf, String overrideBase, NimbusInfo nimbusInfo, ILeaderElector leaderElector)

Uses of NimbusInfo in org.apache.storm.nimbus

Methods in org.apache.storm.nimbus that return NimbusInfo

Modifier and Type	Method	Description
static NimbusInfo	NimbusInfo.fromConf(Map<String,Object> conf)
NimbusInfo	ILeaderElector.getLeader()	Get the current leader's address.
static NimbusInfo	NimbusInfo.parse(String nimbusInfo)

Methods in org.apache.storm.nimbus that return types with arguments of type NimbusInfo

Modifier and Type	Method	Description
List<NimbusInfo>	ILeaderElector.getAllNimbuses()	Get list of current nimbus addresses.

Uses of NimbusInfo in org.apache.storm.testing

Methods in org.apache.storm.testing that return NimbusInfo

Modifier and Type	Method	Description
NimbusInfo	MockLeaderElector.getLeader()

Methods in org.apache.storm.testing that return types with arguments of type NimbusInfo

Modifier and Type	Method	Description
List<NimbusInfo>	MockLeaderElector.getAllNimbuses()

Uses of NimbusInfo in org.apache.storm.utils

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

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

Uses of NimbusInfo in org.apache.storm.zookeeper

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

Modifier and Type	Method	Description
NimbusInfo	LeaderElectorImp.getLeader()
static NimbusInfo	Zookeeper.toNimbusInfo(org.apache.storm.shade.org.apache.curator.framework.recipes.leader.Participant participant)

Methods in org.apache.storm.zookeeper that return types with arguments of type NimbusInfo

Modifier and Type	Method	Description
List<NimbusInfo>	LeaderElectorImp.getAllNimbuses()