Uses of Interface
org.apache.storm.cluster.IStormClusterState

Packages that use IStormClusterState

Package	Description
org.apache.storm
org.apache.storm.cluster
org.apache.storm.daemon.nimbus
org.apache.storm.daemon.supervisor
org.apache.storm.daemon.supervisor.timer
org.apache.storm.daemon.worker
org.apache.storm.executor
org.apache.storm.executor.error
org.apache.storm.nimbus
org.apache.storm.security.auth.workertoken
org.apache.storm.stats
org.apache.storm.zookeeper

Uses of IStormClusterState in org.apache.storm

Methods in org.apache.storm that return IStormClusterState

Modifier and Type	Method and Description
IStormClusterState	LocalCluster.getClusterState()
IStormClusterState	ILocalCluster.getClusterState() This is intended for internal testing only.

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

Modifier and Type	Method and Description
LocalCluster.Builder	LocalCluster.Builder.withClusterState(IStormClusterState clusterState) Use the following clusterState instead of the one in the config.

Uses of IStormClusterState in org.apache.storm.cluster

Classes in org.apache.storm.cluster that implement IStormClusterState

Modifier and Type	Class and Description
class	StormClusterStateImpl

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

Modifier and Type	Method and Description
static IStormClusterState	ClusterUtils.mkStormClusterState(Object stateStorage, ClusterStateContext context)
static IStormClusterState	ClusterUtils.mkStormClusterState(Object stateStorage, ILocalAssignmentsBackend backend, ClusterStateContext context)
IStormClusterState	ClusterUtils.mkStormClusterStateImpl(Object stateStorage, ILocalAssignmentsBackend backend, ClusterStateContext context)

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

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

Modifier and Type	Method and Description
static Set<String>	Nimbus.topoIdsToClean(IStormClusterState state, BlobStore store, Map<String,Object> conf)

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

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 IStormClusterState in org.apache.storm.daemon.supervisor

Methods in org.apache.storm.daemon.supervisor that return IStormClusterState

Modifier and Type	Method and Description
IStormClusterState	Supervisor.getStormClusterState()

Methods in org.apache.storm.daemon.supervisor with parameters of type IStormClusterState

Modifier and Type	Method and Description
protected Map<String,Assignment>	ReadClusterState.getAssignmentsSnapshot(IStormClusterState stormClusterState)
protected Map<String,List<ProfileRequest>>	ReadClusterState.getProfileActions(IStormClusterState stormClusterState, List<String> stormIds)

Constructors in org.apache.storm.daemon.supervisor with parameters of type IStormClusterState

Constructor and Description

Slot(AsyncLocalizer localizer, Map<String,Object> conf, ContainerLauncher containerLauncher, String host, int port, LocalState localState, IStormClusterState clusterState, ISupervisor supervisor, AtomicReference<Map<Long,LocalAssignment>> cachedCurrentAssignments, OnlyLatestExecutor<Integer> metricsExec, WorkerMetricsProcessor metricsProcessor, org.apache.storm.daemon.supervisor.SlotMetrics slotMetrics)

Uses of IStormClusterState in org.apache.storm.daemon.supervisor.timer

Methods in org.apache.storm.daemon.supervisor.timer with parameters of type IStormClusterState

Modifier and Type	Method and Description
void	SynchronizeAssignments.getAssignmentsFromMaster(Map conf, IStormClusterState clusterState, String node) Used by Supervisor to fetch assignments when start up.

Uses of IStormClusterState in org.apache.storm.daemon.worker

Constructors in org.apache.storm.daemon.worker with parameters of type IStormClusterState

Constructor and Description
WorkerState(Map<String,Object> conf, IContext mqContext, String topologyId, String assignmentId, Supplier<SupervisorIfaceFactory> supervisorIfaceSupplier, int port, String workerId, Map<String,Object> topologyConf, IStateStorage stateStorage, IStormClusterState stormClusterState, Collection<IAutoCredentials> autoCredentials, StormMetricRegistry metricRegistry)

Uses of IStormClusterState in org.apache.storm.executor

Fields in org.apache.storm.executor declared as IStormClusterState

Modifier and Type	Field and Description
protected IStormClusterState	Executor.stormClusterState

Methods in org.apache.storm.executor that return IStormClusterState

Modifier and Type	Method and Description
IStormClusterState	Executor.getStormClusterState()

Uses of IStormClusterState in org.apache.storm.executor.error

Constructors in org.apache.storm.executor.error with parameters of type IStormClusterState

Constructor and Description
ReportError(Map<String,Object> topoConf, IStormClusterState stormClusterState, String stormId, String componentId, WorkerTopologyContext workerTopologyContext)

Uses of IStormClusterState in org.apache.storm.nimbus

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

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 IStormClusterState in org.apache.storm.security.auth.workertoken

Constructors in org.apache.storm.security.auth.workertoken with parameters of type IStormClusterState

Constructor and Description
WorkerTokenManager(Map<String,Object> daemonConf, IStormClusterState state) Constructor.

Uses of IStormClusterState in org.apache.storm.stats

Methods in org.apache.storm.stats with parameters of type IStormClusterState

Modifier and Type	Method and Description
static TopologyPageInfo	StatsUtil.aggTopoExecsStats(String topologyId, Map exec2nodePort, Map task2component, Map<List<Integer>,Map<String,Object>> beats, StormTopology topology, String window, boolean includeSys, IStormClusterState clusterState) aggregate topo executors stats.

Uses of IStormClusterState in org.apache.storm.zookeeper

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

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)

Constructors in org.apache.storm.zookeeper with parameters of type IStormClusterState

Constructor and Description
LeaderListenerCallbackFactory(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)