# 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
  Description
  `IStormClusterState`
  ILocalCluster.`getClusterState()`
  This is intended for internal testing only.
  `IStormClusterState`
  LocalCluster.`getClusterState()`
  Methods in org.apache.storm with parameters of type IStormClusterState
  Modifier and Type
  Method
  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
  Description
  `class`
  `StormClusterStateImpl`
  Methods in org.apache.storm.cluster that return IStormClusterState
  Modifier and Type
  Method
  Description
  `static IStormClusterState`
  ClusterUtils.`mkStormClusterState(Object stateStorage, ILocalAssignmentsBackend backend, ClusterStateContext context)`
  `static IStormClusterState`
  ClusterUtils.`mkStormClusterState(Object stateStorage, 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
  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
  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 IStormClusterState in org.apache.storm.daemon.supervisor

  Methods in org.apache.storm.daemon.supervisor that return IStormClusterState
  Modifier and Type
  Method
  Description
  `IStormClusterState`
  Supervisor.`getStormClusterState()`
  Methods in org.apache.storm.daemon.supervisor with parameters of type IStormClusterState
  Modifier and Type
  Method
  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
  Modifier
  Constructor
  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
  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
  Modifier
  Constructor
  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, Credentials initialCredentials)`

- ## Uses of IStormClusterState in org.apache.storm.executor

  Fields in org.apache.storm.executor declared as IStormClusterState
  Modifier and Type
  Field
  Description
  `protected final IStormClusterState`
  Executor.`stormClusterState`
  Methods in org.apache.storm.executor that return IStormClusterState
  Modifier and Type
  Method
  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
  Modifier
  Constructor
  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
  Modifier
  Constructor
  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)`
  Creates a `LeaderListenerCallback`.

- ## Uses of IStormClusterState in org.apache.storm.security.auth.workertoken

  Constructors in org.apache.storm.security.auth.workertoken with parameters of type IStormClusterState
  Modifier
  Constructor
  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
  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
  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, Object submitLock)`
  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, Object submitLock)`
  Constructors in org.apache.storm.zookeeper with parameters of type IStormClusterState
  Modifier
  Constructor
  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, Object submitLock)`