org.apache.storm.cluster

Interface IStormClusterState

All Known Implementing Classes:

StormClusterStateImpl

public interface IStormClusterState

Method Summary

Modifier and Type	Method and Description
void	activateStorm(String stormId, StormBase stormBase, Map<String,Object> topoConf)
List<String>	activeKeys()
List<String>	activeStorms()
void	addNimbusHost(String nimbusId, NimbusSummary nimbusSummary)
Assignment	assignmentInfo(String stormId, Runnable callback)
VersionedData<Assignment>	assignmentInfoWithVersion(String stormId, Runnable callback)
List<String>	assignments(Runnable callback)
Integer	assignmentVersion(String stormId, Runnable callback)
List<String>	backpressureTopologies()
List<String>	blobstore(Runnable callback)
List<String>	blobstoreInfo(String blobKey)
Credentials	credentials(String stormId, Runnable callback)
void	deleteTopologyProfileRequests(String stormId, ProfileRequest profileRequest)
void	disconnect()
List<ErrorInfo>	errors(String stormId, String componentId)
List<String>	errorTopologies()
Map<ExecutorInfo,ExecutorBeat>	executorBeats(String stormId, Map<List<Long>,NodeInfo> executorNodePort)
List<ProfileRequest>	getTopologyProfileRequests(String stormId)
ClusterWorkerHeartbeat	getWorkerHeartbeat(String stormId, String node, Long port)
List<ProfileRequest>	getWorkerProfileRequests(String stormId, NodeInfo nodeInfo)
List<String>	heartbeatStorms()
ErrorInfo	lastError(String stormId, String componentId)
List	nimbuses()
void	removeBackpressure(String stormId)
void	removeBlobstoreKey(String blobKey)
void	removeKeyVersion(String blobKey)
void	removeStorm(String stormId)
void	removeStormBase(String stormId)
void	removeWorkerBackpressure(String stormId, String node, Long port)
void	removeWorkerHeartbeat(String stormId, String node, Long port)
void	reportError(String stormId, String componentId, String node, Long port, Throwable error)
void	setAssignment(String stormId, Assignment info, Map<String,Object> topoConf)
void	setCredentials(String stormId, Credentials creds, Map topoConf)
void	setTopologyLogConfig(String stormId, LogConfig logConfig, Map<String,Object> topoConf)
void	setupBackpressure(String stormId, Map<String,Object> topoConf)
void	setupBlobstore(String key, NimbusInfo nimbusInfo, Integer versionInfo)
void	setupErrors(String stormId, Map<String,Object> topoConf)
void	setupHeatbeats(String stormId, Map<String,Object> topoConf)
void	setWorkerProfileRequest(String stormId, ProfileRequest profileRequest)
StormBase	stormBase(String stormId, Runnable callback)
void	supervisorHeartbeat(String supervisorId, SupervisorInfo info)
SupervisorInfo	supervisorInfo(String supervisorId)
List<String>	supervisors(Runnable callback)
void	teardownHeartbeats(String stormId)
void	teardownTopologyErrors(String stormId)
boolean	topologyBackpressure(String stormId, Runnable callback)
LogConfig	topologyLogConfig(String stormId, Runnable cb)
void	updateStorm(String stormId, StormBase newElems)
void	workerBackpressure(String stormId, String node, Long port, boolean on)
void	workerHeartbeat(String stormId, String node, Long port, ClusterWorkerHeartbeat info)

Method Detail

assignments

List<String> assignments(Runnable callback)

assignmentInfo

Assignment assignmentInfo(String stormId,
                          Runnable callback)

assignmentInfoWithVersion

VersionedData<Assignment> assignmentInfoWithVersion(String stormId,
                                                    Runnable callback)

assignmentVersion

Integer assignmentVersion(String stormId,
                          Runnable callback)
                   throws Exception

Throws:

Exception

blobstoreInfo

List<String> blobstoreInfo(String blobKey)

nimbuses

List nimbuses()

addNimbusHost

void addNimbusHost(String nimbusId,
                   NimbusSummary nimbusSummary)

activeStorms

List<String> activeStorms()

stormBase

StormBase stormBase(String stormId,
                    Runnable callback)

getWorkerHeartbeat

ClusterWorkerHeartbeat getWorkerHeartbeat(String stormId,
                                          String node,
                                          Long port)

getWorkerProfileRequests

List<ProfileRequest> getWorkerProfileRequests(String stormId,
                                              NodeInfo nodeInfo)

getTopologyProfileRequests

List<ProfileRequest> getTopologyProfileRequests(String stormId)

setWorkerProfileRequest

void setWorkerProfileRequest(String stormId,
                             ProfileRequest profileRequest)

deleteTopologyProfileRequests

void deleteTopologyProfileRequests(String stormId,
                                   ProfileRequest profileRequest)

executorBeats

Map<ExecutorInfo,ExecutorBeat> executorBeats(String stormId,
                                             Map<List<Long>,NodeInfo> executorNodePort)

supervisors

List<String> supervisors(Runnable callback)

supervisorInfo

SupervisorInfo supervisorInfo(String supervisorId)

setupHeatbeats

void setupHeatbeats(String stormId,
                    Map<String,Object> topoConf)

teardownHeartbeats

void teardownHeartbeats(String stormId)

teardownTopologyErrors

void teardownTopologyErrors(String stormId)

heartbeatStorms

List<String> heartbeatStorms()

errorTopologies

List<String> errorTopologies()

backpressureTopologies

List<String> backpressureTopologies()

setTopologyLogConfig

void setTopologyLogConfig(String stormId,
                          LogConfig logConfig,
                          Map<String,Object> topoConf)

topologyLogConfig

LogConfig topologyLogConfig(String stormId,
                            Runnable cb)

workerHeartbeat

void workerHeartbeat(String stormId,
                     String node,
                     Long port,
                     ClusterWorkerHeartbeat info)

removeWorkerHeartbeat

void removeWorkerHeartbeat(String stormId,
                           String node,
                           Long port)

supervisorHeartbeat

void supervisorHeartbeat(String supervisorId,
                         SupervisorInfo info)

workerBackpressure

void workerBackpressure(String stormId,
                        String node,
                        Long port,
                        boolean on)

topologyBackpressure

boolean topologyBackpressure(String stormId,
                             Runnable callback)

setupBackpressure

void setupBackpressure(String stormId,
                       Map<String,Object> topoConf)

removeBackpressure

void removeBackpressure(String stormId)

removeWorkerBackpressure

void removeWorkerBackpressure(String stormId,
                              String node,
                              Long port)

activateStorm

void activateStorm(String stormId,
                   StormBase stormBase,
                   Map<String,Object> topoConf)

updateStorm

void updateStorm(String stormId,
                 StormBase newElems)

removeStormBase

void removeStormBase(String stormId)

setAssignment

void setAssignment(String stormId,
                   Assignment info,
                   Map<String,Object> topoConf)

setupBlobstore

void setupBlobstore(String key,
                    NimbusInfo nimbusInfo,
                    Integer versionInfo)

activeKeys

List<String> activeKeys()

blobstore

List<String> blobstore(Runnable callback)

removeStorm

void removeStorm(String stormId)

removeBlobstoreKey

void removeBlobstoreKey(String blobKey)

removeKeyVersion

void removeKeyVersion(String blobKey)

reportError

void reportError(String stormId,
                 String componentId,
                 String node,
                 Long port,
                 Throwable error)

setupErrors

void setupErrors(String stormId,
                 Map<String,Object> topoConf)

errors

List<ErrorInfo> errors(String stormId,
                       String componentId)

lastError

ErrorInfo lastError(String stormId,
                    String componentId)

setCredentials

void setCredentials(String stormId,
                    Credentials creds,
                    Map topoConf)

credentials

Credentials credentials(String stormId,
                        Runnable callback)

disconnect

void disconnect()