Interface Nimbus.AsyncIface

All Known Implementing Classes:
Nimbus.AsyncClient
Enclosing class:
Nimbus

public static interface Nimbus.AsyncIface
  • Method Details

    • 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
    • getTopologySummaries

      void getTopologySummaries(org.apache.storm.thrift.async.AsyncMethodCallback<List<TopologySummary>> resultHandler) throws org.apache.storm.thrift.TException
      Throws:
      org.apache.storm.thrift.TException
    • getTopologySummaryByName

      void getTopologySummaryByName(String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) throws org.apache.storm.thrift.TException
      Throws:
      org.apache.storm.thrift.TException
    • getTopologySummary

      void getTopologySummary(String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> 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
    • getTopologyInfoByName

      void getTopologyInfoByName(String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> 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
    • getTopologyInfoByNameWithOpts

      void 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
    • 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