org.apache.storm.generated

Interface Nimbus.AsyncIface

All Known Implementing Classes:

Nimbus.AsyncClient

Enclosing class:

Nimbus

public static interface Nimbus.AsyncIface

Method Summary

Modifier and Type	Method and Description
void	activate(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	beginBlobDownload(String key, org.apache.storm.thrift.async.AsyncMethodCallback<BeginDownloadResult> resultHandler)
void	beginCreateBlob(String key, SettableBlobMeta meta, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
void	beginFileUpload(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
void	beginUpdateBlob(String key, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
void	cancelBlobUpload(String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	createStateInZookeeper(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	deactivate(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	debug(String name, String component, boolean enable, double samplingPercentage, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	deleteBlob(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	downloadBlobChunk(String session, org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler)
void	downloadChunk(String id, org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler)
void	finishBlobUpload(String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	finishFileUpload(String location, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	getBlobMeta(String key, org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler)
void	getBlobReplication(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler)
void	getClusterInfo(org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler)
void	getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler)
void	getComponentPendingProfileActions(String id, String component_id, ProfileAction action, org.apache.storm.thrift.async.AsyncMethodCallback<List<ProfileRequest>> resultHandler)
void	getLeader(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler)
void	getLogConfig(String name, org.apache.storm.thrift.async.AsyncMethodCallback<LogConfig> resultHandler)
void	getNimbusConf(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
void	getOwnerResourceSummaries(String owner, org.apache.storm.thrift.async.AsyncMethodCallback<List<OwnerResourceSummary>> resultHandler)
void	getSupervisorAssignments(String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler)
void	getSupervisorPageInfo(String id, String host, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> resultHandler)
void	getTopology(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler)
void	getTopologyConf(String id, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
void	getTopologyHistory(String user, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler)
void	getTopologyInfo(String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler)
void	getTopologyInfoWithOpts(String id, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler)
void	getTopologyPageInfo(String id, String window, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler)
void	getUserTopology(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler)
void	isRemoteBlobExists(String blobKey, org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler)
void	isTopologyNameAllowed(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler)
void	killTopology(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	killTopologyWithOpts(String name, KillOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	listBlobs(String session, org.apache.storm.thrift.async.AsyncMethodCallback<ListBlobsResult> resultHandler)
void	processWorkerMetrics(WorkerMetrics metrics, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	rebalance(String name, RebalanceOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	setBlobMeta(String key, SettableBlobMeta meta, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	setLogConfig(String name, LogConfig config, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	setWorkerProfiler(String id, ProfileRequest profileRequest, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	updateBlobReplication(String key, int replication, org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler)
void	uploadBlobChunk(String session, ByteBuffer chunk, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	uploadChunk(String location, ByteBuffer chunk, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	uploadNewCredentials(String name, Credentials creds, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)

Method Detail

submitTopology

void submitTopology(String name,
                    String uploadedJarLocation,
                    String jsonConf,
                    StormTopology topology,
                    org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
             throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

submitTopologyWithOpts

void submitTopologyWithOpts(String name,
                            String uploadedJarLocation,
                            String jsonConf,
                            StormTopology topology,
                            SubmitOptions options,
                            org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                     throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

killTopology

void killTopology(String name,
                  org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
           throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

killTopologyWithOpts

void killTopologyWithOpts(String name,
                          KillOptions options,
                          org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                   throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

activate

void activate(String name,
              org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
       throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

deactivate

void deactivate(String name,
                org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
         throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

rebalance

void rebalance(String name,
               RebalanceOptions options,
               org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
        throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

setLogConfig

void setLogConfig(String name,
                  LogConfig config,
                  org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
           throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getLogConfig

void getLogConfig(String name,
                  org.apache.storm.thrift.async.AsyncMethodCallback<LogConfig> resultHandler)
           throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

debug

void debug(String name,
           String component,
           boolean enable,
           double samplingPercentage,
           org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
    throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

setWorkerProfiler

void setWorkerProfiler(String id,
                       ProfileRequest profileRequest,
                       org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getComponentPendingProfileActions

void getComponentPendingProfileActions(String id,
                                       String component_id,
                                       ProfileAction action,
                                       org.apache.storm.thrift.async.AsyncMethodCallback<List<ProfileRequest>> resultHandler)
                                throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

uploadNewCredentials

void uploadNewCredentials(String name,
                          Credentials creds,
                          org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                   throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

beginCreateBlob

void beginCreateBlob(String key,
                     SettableBlobMeta meta,
                     org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
              throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

beginUpdateBlob

void beginUpdateBlob(String key,
                     org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
              throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

uploadBlobChunk

void uploadBlobChunk(String session,
                     ByteBuffer chunk,
                     org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
              throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

finishBlobUpload

void finishBlobUpload(String session,
                      org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
               throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

cancelBlobUpload

void cancelBlobUpload(String session,
                      org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
               throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getBlobMeta

void getBlobMeta(String key,
                 org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler)
          throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

setBlobMeta

void setBlobMeta(String key,
                 SettableBlobMeta meta,
                 org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
          throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

beginBlobDownload

void beginBlobDownload(String key,
                       org.apache.storm.thrift.async.AsyncMethodCallback<BeginDownloadResult> resultHandler)
                throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

downloadBlobChunk

void downloadBlobChunk(String session,
                       org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler)
                throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

deleteBlob

void deleteBlob(String key,
                org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
         throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

listBlobs

void listBlobs(String session,
               org.apache.storm.thrift.async.AsyncMethodCallback<ListBlobsResult> resultHandler)
        throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getBlobReplication

void getBlobReplication(String key,
                        org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler)
                 throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

updateBlobReplication

void updateBlobReplication(String key,
                           int replication,
                           org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler)
                    throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

createStateInZookeeper

void createStateInZookeeper(String key,
                            org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                     throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

beginFileUpload

void beginFileUpload(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
              throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

uploadChunk

void uploadChunk(String location,
                 ByteBuffer chunk,
                 org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
          throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

finishFileUpload

void finishFileUpload(String location,
                      org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
               throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

downloadChunk

void downloadChunk(String id,
                   org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler)
            throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getNimbusConf

void getNimbusConf(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
            throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getClusterInfo

void getClusterInfo(org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler)
             throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getLeader

void getLeader(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler)
        throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

isTopologyNameAllowed

void isTopologyNameAllowed(String name,
                           org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler)
                    throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getTopologyInfo

void getTopologyInfo(String id,
                     org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler)
              throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getTopologyInfoWithOpts

void getTopologyInfoWithOpts(String id,
                             GetInfoOptions options,
                             org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler)
                      throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getTopologyPageInfo

void getTopologyPageInfo(String id,
                         String window,
                         boolean is_include_sys,
                         org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler)
                  throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getSupervisorPageInfo

void getSupervisorPageInfo(String id,
                           String host,
                           boolean is_include_sys,
                           org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> resultHandler)
                    throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getComponentPageInfo

void getComponentPageInfo(String topology_id,
                          String component_id,
                          String window,
                          boolean is_include_sys,
                          org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler)
                   throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getTopologyConf

void getTopologyConf(String id,
                     org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler)
              throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getTopology

void getTopology(String id,
                 org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler)
          throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getUserTopology

void getUserTopology(String id,
                     org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler)
              throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getTopologyHistory

void getTopologyHistory(String user,
                        org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler)
                 throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getOwnerResourceSummaries

void getOwnerResourceSummaries(String owner,
                               org.apache.storm.thrift.async.AsyncMethodCallback<List<OwnerResourceSummary>> resultHandler)
                        throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getSupervisorAssignments

void getSupervisorAssignments(String node,
                              org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler)
                       throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

sendSupervisorWorkerHeartbeats

void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats,
                                    org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                             throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

sendSupervisorWorkerHeartbeat

void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat,
                                   org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                            throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

processWorkerMetrics

void processWorkerMetrics(WorkerMetrics metrics,
                          org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                   throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

isRemoteBlobExists

void isRemoteBlobExists(String blobKey,
                        org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler)
                 throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException