Package org.apache.storm.generated
Interface Nimbus.AsyncIface
- All Known Implementing Classes:
- Nimbus.AsyncClient
- Enclosing class:
- Nimbus
public static interface Nimbus.AsyncIface
- 
Method SummaryModifier and TypeMethodDescriptionvoidvoidbeginBlobDownload(String key, org.apache.storm.thrift.async.AsyncMethodCallback<BeginDownloadResult> resultHandler) voidbeginCreateBlob(String key, SettableBlobMeta meta, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) voidbeginFileUpload(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) voidbeginUpdateBlob(String key, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) voidcancelBlobUpload(String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidcreateStateInZookeeper(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voiddeactivate(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voiddebug(String name, String component, boolean enable, double samplingPercentage, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voiddeleteBlob(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voiddownloadBlobChunk(String session, org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) voiddownloadChunk(String id, org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) voidfinishBlobUpload(String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidfinishFileUpload(String location, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidgetBlobMeta(String key, org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler) voidgetBlobReplication(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler) voidgetClusterInfo(org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler) voidgetComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler) voidgetComponentPendingProfileActions(String id, String component_id, ProfileAction action, org.apache.storm.thrift.async.AsyncMethodCallback<List<ProfileRequest>> resultHandler) voidgetLeader(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) voidgetLogConfig(String name, org.apache.storm.thrift.async.AsyncMethodCallback<LogConfig> resultHandler) voidgetNimbusConf(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) voidgetOwnerResourceSummaries(String owner, org.apache.storm.thrift.async.AsyncMethodCallback<List<OwnerResourceSummary>> resultHandler) voidgetSupervisorAssignments(String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) voidgetSupervisorPageInfo(String id, String host, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorPageInfo> resultHandler) voidgetTopology(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) voidgetTopologyConf(String id, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) voidgetTopologyHistory(String user, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler) voidgetTopologyInfo(String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) voidgetTopologyInfoByName(String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) voidgetTopologyInfoByNameWithOpts(String name, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) voidgetTopologyInfoWithOpts(String id, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) voidgetTopologyPageInfo(String id, String window, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler) voidgetTopologySummaries(org.apache.storm.thrift.async.AsyncMethodCallback<List<TopologySummary>> resultHandler) voidgetTopologySummary(String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) voidgetTopologySummaryByName(String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) voidgetUserTopology(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) voidisRemoteBlobExists(String blobKey, org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler) voidisTopologyNameAllowed(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler) voidkillTopology(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidkillTopologyWithOpts(String name, KillOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidlistBlobs(String session, org.apache.storm.thrift.async.AsyncMethodCallback<ListBlobsResult> resultHandler) voidprocessWorkerMetrics(WorkerMetrics metrics, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidrebalance(String name, RebalanceOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidsendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidsendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidsetBlobMeta(String key, SettableBlobMeta meta, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidsetLogConfig(String name, LogConfig config, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidsetWorkerProfiler(String id, ProfileRequest profileRequest, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidsubmitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidsubmitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidupdateBlobReplication(String key, int replication, org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler) voiduploadBlobChunk(String session, ByteBuffer chunk, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voiduploadChunk(String location, ByteBuffer chunk, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voiduploadNewCredentials(String name, Credentials creds, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) 
- 
Method Details- 
submitTopologyvoid 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
 
- 
submitTopologyWithOptsvoid 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
 
- 
killTopologyvoid killTopology(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
killTopologyWithOptsvoid 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
 
- 
activatevoid activate(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
deactivatevoid deactivate(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
rebalancevoid 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
 
- 
setLogConfigvoid 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
 
- 
getLogConfigvoid getLogConfig(String name, org.apache.storm.thrift.async.AsyncMethodCallback<LogConfig> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
debugvoid 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
 
- 
setWorkerProfilervoid 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
 
- 
getComponentPendingProfileActionsvoid 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
 
- 
uploadNewCredentialsvoid 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
 
- 
beginCreateBlobvoid 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
 
- 
beginUpdateBlobvoid beginUpdateBlob(String key, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
uploadBlobChunkvoid 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
 
- 
finishBlobUploadvoid finishBlobUpload(String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
cancelBlobUploadvoid cancelBlobUpload(String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getBlobMetavoid getBlobMeta(String key, org.apache.storm.thrift.async.AsyncMethodCallback<ReadableBlobMeta> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
setBlobMetavoid 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
 
- 
beginBlobDownloadvoid beginBlobDownload(String key, org.apache.storm.thrift.async.AsyncMethodCallback<BeginDownloadResult> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
downloadBlobChunkvoid downloadBlobChunk(String session, org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
deleteBlobvoid deleteBlob(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
listBlobsvoid listBlobs(String session, org.apache.storm.thrift.async.AsyncMethodCallback<ListBlobsResult> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getBlobReplicationvoid getBlobReplication(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Integer> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
updateBlobReplicationvoid 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
 
- 
createStateInZookeepervoid createStateInZookeeper(String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
beginFileUploadvoid beginFileUpload(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
uploadChunkvoid 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
 
- 
finishFileUploadvoid finishFileUpload(String location, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
downloadChunkvoid downloadChunk(String id, org.apache.storm.thrift.async.AsyncMethodCallback<ByteBuffer> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getNimbusConfvoid getNimbusConf(org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getClusterInfovoid getClusterInfo(org.apache.storm.thrift.async.AsyncMethodCallback<ClusterSummary> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologySummariesvoid getTopologySummaries(org.apache.storm.thrift.async.AsyncMethodCallback<List<TopologySummary>> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologySummaryByNamevoid getTopologySummaryByName(String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologySummaryvoid getTopologySummary(String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getLeadervoid getLeader(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
isTopologyNameAllowedvoid isTopologyNameAllowed(String name, org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologyInfoByNamevoid getTopologyInfoByName(String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologyInfovoid getTopologyInfo(String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologyInfoByNameWithOptsvoid getTopologyInfoByNameWithOpts(String name, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologyInfoWithOptsvoid 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
 
- 
getTopologyPageInfovoid 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
 
- 
getSupervisorPageInfovoid 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
 
- 
getComponentPageInfovoid 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
 
- 
getTopologyConfvoid getTopologyConf(String id, org.apache.storm.thrift.async.AsyncMethodCallback<String> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologyvoid getTopology(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getUserTopologyvoid getUserTopology(String id, org.apache.storm.thrift.async.AsyncMethodCallback<StormTopology> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getTopologyHistoryvoid getTopologyHistory(String user, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getOwnerResourceSummariesvoid getOwnerResourceSummaries(String owner, org.apache.storm.thrift.async.AsyncMethodCallback<List<OwnerResourceSummary>> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
getSupervisorAssignmentsvoid getSupervisorAssignments(String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
sendSupervisorWorkerHeartbeatsvoid sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
sendSupervisorWorkerHeartbeatvoid sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
processWorkerMetricsvoid processWorkerMetrics(WorkerMetrics metrics, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
isRemoteBlobExistsvoid isRemoteBlobExists(String blobKey, org.apache.storm.thrift.async.AsyncMethodCallback<Boolean> resultHandler) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
 
-