You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2018/05/23 20:03:34 UTC
[04/43] storm git commit: STORM-3061: thrift 0.11
http://git-wip-us.apache.org/repos/asf/storm/blob/1fd1e17f/storm-client/src/py/storm/Nimbus-remote
----------------------------------------------------------------------
diff --git a/storm-client/src/py/storm/Nimbus-remote b/storm-client/src/py/storm/Nimbus-remote
index 603b628..280c42b 100644
--- a/storm-client/src/py/storm/Nimbus-remote
+++ b/storm-client/src/py/storm/Nimbus-remote
@@ -18,7 +18,7 @@
#!/usr/bin/env python
#
-# Autogenerated by Thrift Compiler (0.9.3)
+# Autogenerated by Thrift Compiler (0.11.0)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
@@ -27,429 +27,452 @@
import sys
import pprint
-from urlparse import urlparse
-from thrift.transport import TTransport
-from thrift.transport import TSocket
-from thrift.transport import TSSLSocket
-from thrift.transport import THttpClient
-from thrift.protocol import TBinaryProtocol
+if sys.version_info[0] > 2:
+ from urllib.parse import urlparse
+else:
+ from urlparse import urlparse
+from thrift.transport import TTransport, TSocket, TSSLSocket, THttpClient
+from thrift.protocol.TBinaryProtocol import TBinaryProtocol
from storm import Nimbus
from storm.ttypes import *
if len(sys.argv) <= 1 or sys.argv[1] == '--help':
- print('')
- print('Usage: ' + sys.argv[0] + ' [-h host[:port]] [-u url] [-f[ramed]] [-s[sl]] function [arg1 [arg2...]]')
- print('')
- print('Functions:')
- print(' void submitTopology(string name, string uploadedJarLocation, string jsonConf, StormTopology topology)')
- print(' void submitTopologyWithOpts(string name, string uploadedJarLocation, string jsonConf, StormTopology topology, SubmitOptions options)')
- print(' void killTopology(string name)')
- print(' void killTopologyWithOpts(string name, KillOptions options)')
- print(' void activate(string name)')
- print(' void deactivate(string name)')
- print(' void rebalance(string name, RebalanceOptions options)')
- print(' void setLogConfig(string name, LogConfig config)')
- print(' LogConfig getLogConfig(string name)')
- print(' void debug(string name, string component, bool enable, double samplingPercentage)')
- print(' void setWorkerProfiler(string id, ProfileRequest profileRequest)')
- print(' getComponentPendingProfileActions(string id, string component_id, ProfileAction action)')
- print(' void uploadNewCredentials(string name, Credentials creds)')
- print(' string beginCreateBlob(string key, SettableBlobMeta meta)')
- print(' string beginUpdateBlob(string key)')
- print(' void uploadBlobChunk(string session, string chunk)')
- print(' void finishBlobUpload(string session)')
- print(' void cancelBlobUpload(string session)')
- print(' ReadableBlobMeta getBlobMeta(string key)')
- print(' void setBlobMeta(string key, SettableBlobMeta meta)')
- print(' BeginDownloadResult beginBlobDownload(string key)')
- print(' string downloadBlobChunk(string session)')
- print(' void deleteBlob(string key)')
- print(' ListBlobsResult listBlobs(string session)')
- print(' i32 getBlobReplication(string key)')
- print(' i32 updateBlobReplication(string key, i32 replication)')
- print(' void createStateInZookeeper(string key)')
- print(' string beginFileUpload()')
- print(' void uploadChunk(string location, string chunk)')
- print(' void finishFileUpload(string location)')
- print(' string beginFileDownload(string file)')
- print(' string downloadChunk(string id)')
- print(' string getNimbusConf()')
- print(' ClusterSummary getClusterInfo()')
- print(' NimbusSummary getLeader()')
- print(' bool isTopologyNameAllowed(string name)')
- print(' TopologyInfo getTopologyInfo(string id)')
- print(' TopologyInfo getTopologyInfoWithOpts(string id, GetInfoOptions options)')
- print(' TopologyPageInfo getTopologyPageInfo(string id, string window, bool is_include_sys)')
- print(' SupervisorPageInfo getSupervisorPageInfo(string id, string host, bool is_include_sys)')
- print(' ComponentPageInfo getComponentPageInfo(string topology_id, string component_id, string window, bool is_include_sys)')
- print(' string getTopologyConf(string id)')
- print(' StormTopology getTopology(string id)')
- print(' StormTopology getUserTopology(string id)')
- print(' TopologyHistoryInfo getTopologyHistory(string user)')
- print(' getOwnerResourceSummaries(string owner)')
- print(' SupervisorAssignments getSupervisorAssignments(string node)')
- print(' void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats)')
- print(' void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat)')
- print(' void processWorkerMetrics(WorkerMetrics metrics)')
- print('')
- sys.exit(0)
-
-pp = pprint.PrettyPrinter(indent = 2)
+ print('')
+ print('Usage: ' + sys.argv[0] + ' [-h host[:port]] [-u url] [-f[ramed]] [-s[sl]] [-novalidate] [-ca_certs certs] [-keyfile keyfile] [-certfile certfile] function [arg1 [arg2...]]')
+ print('')
+ print('Functions:')
+ print(' void submitTopology(string name, string uploadedJarLocation, string jsonConf, StormTopology topology)')
+ print(' void submitTopologyWithOpts(string name, string uploadedJarLocation, string jsonConf, StormTopology topology, SubmitOptions options)')
+ print(' void killTopology(string name)')
+ print(' void killTopologyWithOpts(string name, KillOptions options)')
+ print(' void activate(string name)')
+ print(' void deactivate(string name)')
+ print(' void rebalance(string name, RebalanceOptions options)')
+ print(' void setLogConfig(string name, LogConfig config)')
+ print(' LogConfig getLogConfig(string name)')
+ print(' void debug(string name, string component, bool enable, double samplingPercentage)')
+ print(' void setWorkerProfiler(string id, ProfileRequest profileRequest)')
+ print(' getComponentPendingProfileActions(string id, string component_id, ProfileAction action)')
+ print(' void uploadNewCredentials(string name, Credentials creds)')
+ print(' string beginCreateBlob(string key, SettableBlobMeta meta)')
+ print(' string beginUpdateBlob(string key)')
+ print(' void uploadBlobChunk(string session, string chunk)')
+ print(' void finishBlobUpload(string session)')
+ print(' void cancelBlobUpload(string session)')
+ print(' ReadableBlobMeta getBlobMeta(string key)')
+ print(' void setBlobMeta(string key, SettableBlobMeta meta)')
+ print(' BeginDownloadResult beginBlobDownload(string key)')
+ print(' string downloadBlobChunk(string session)')
+ print(' void deleteBlob(string key)')
+ print(' ListBlobsResult listBlobs(string session)')
+ print(' i32 getBlobReplication(string key)')
+ print(' i32 updateBlobReplication(string key, i32 replication)')
+ print(' void createStateInZookeeper(string key)')
+ print(' string beginFileUpload()')
+ print(' void uploadChunk(string location, string chunk)')
+ print(' void finishFileUpload(string location)')
+ print(' string beginFileDownload(string file)')
+ print(' string downloadChunk(string id)')
+ print(' string getNimbusConf()')
+ print(' ClusterSummary getClusterInfo()')
+ print(' NimbusSummary getLeader()')
+ print(' bool isTopologyNameAllowed(string name)')
+ print(' TopologyInfo getTopologyInfo(string id)')
+ print(' TopologyInfo getTopologyInfoWithOpts(string id, GetInfoOptions options)')
+ print(' TopologyPageInfo getTopologyPageInfo(string id, string window, bool is_include_sys)')
+ print(' SupervisorPageInfo getSupervisorPageInfo(string id, string host, bool is_include_sys)')
+ print(' ComponentPageInfo getComponentPageInfo(string topology_id, string component_id, string window, bool is_include_sys)')
+ print(' string getTopologyConf(string id)')
+ print(' StormTopology getTopology(string id)')
+ print(' StormTopology getUserTopology(string id)')
+ print(' TopologyHistoryInfo getTopologyHistory(string user)')
+ print(' getOwnerResourceSummaries(string owner)')
+ print(' SupervisorAssignments getSupervisorAssignments(string node)')
+ print(' void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats)')
+ print(' void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat)')
+ print(' void processWorkerMetrics(WorkerMetrics metrics)')
+ print('')
+ sys.exit(0)
+
+pp = pprint.PrettyPrinter(indent=2)
host = 'localhost'
port = 9090
uri = ''
framed = False
ssl = False
+validate = True
+ca_certs = None
+keyfile = None
+certfile = None
http = False
argi = 1
if sys.argv[argi] == '-h':
- parts = sys.argv[argi+1].split(':')
- host = parts[0]
- if len(parts) > 1:
- port = int(parts[1])
- argi += 2
+ parts = sys.argv[argi + 1].split(':')
+ host = parts[0]
+ if len(parts) > 1:
+ port = int(parts[1])
+ argi += 2
if sys.argv[argi] == '-u':
- url = urlparse(sys.argv[argi+1])
- parts = url[1].split(':')
- host = parts[0]
- if len(parts) > 1:
- port = int(parts[1])
- else:
- port = 80
- uri = url[2]
- if url[4]:
- uri += '?%s' % url[4]
- http = True
- argi += 2
+ url = urlparse(sys.argv[argi + 1])
+ parts = url[1].split(':')
+ host = parts[0]
+ if len(parts) > 1:
+ port = int(parts[1])
+ else:
+ port = 80
+ uri = url[2]
+ if url[4]:
+ uri += '?%s' % url[4]
+ http = True
+ argi += 2
if sys.argv[argi] == '-f' or sys.argv[argi] == '-framed':
- framed = True
- argi += 1
+ framed = True
+ argi += 1
if sys.argv[argi] == '-s' or sys.argv[argi] == '-ssl':
- ssl = True
- argi += 1
+ ssl = True
+ argi += 1
+
+if sys.argv[argi] == '-novalidate':
+ validate = False
+ argi += 1
+
+if sys.argv[argi] == '-ca_certs':
+ ca_certs = sys.argv[argi+1]
+ argi += 2
+
+if sys.argv[argi] == '-keyfile':
+ keyfile = sys.argv[argi+1]
+ argi += 2
+
+if sys.argv[argi] == '-certfile':
+ certfile = sys.argv[argi+1]
+ argi += 2
cmd = sys.argv[argi]
-args = sys.argv[argi+1:]
+args = sys.argv[argi + 1:]
if http:
- transport = THttpClient.THttpClient(host, port, uri)
+ transport = THttpClient.THttpClient(host, port, uri)
else:
- socket = TSSLSocket.TSSLSocket(host, port, validate=False) if ssl else TSocket.TSocket(host, port)
- if framed:
- transport = TTransport.TFramedTransport(socket)
- else:
- transport = TTransport.TBufferedTransport(socket)
-protocol = TBinaryProtocol.TBinaryProtocol(transport)
+ if ssl:
+ socket = TSSLSocket.TSSLSocket(host, port, validate=validate, ca_certs=ca_certs, keyfile=keyfile, certfile=certfile)
+ else:
+ socket = TSocket.TSocket(host, port)
+ if framed:
+ transport = TTransport.TFramedTransport(socket)
+ else:
+ transport = TTransport.TBufferedTransport(socket)
+protocol = TBinaryProtocol(transport)
client = Nimbus.Client(protocol)
transport.open()
if cmd == 'submitTopology':
- if len(args) != 4:
- print('submitTopology requires 4 args')
- sys.exit(1)
- pp.pprint(client.submitTopology(args[0],args[1],args[2],eval(args[3]),))
+ if len(args) != 4:
+ print('submitTopology requires 4 args')
+ sys.exit(1)
+ pp.pprint(client.submitTopology(args[0], args[1], args[2], eval(args[3]),))
elif cmd == 'submitTopologyWithOpts':
- if len(args) != 5:
- print('submitTopologyWithOpts requires 5 args')
- sys.exit(1)
- pp.pprint(client.submitTopologyWithOpts(args[0],args[1],args[2],eval(args[3]),eval(args[4]),))
+ if len(args) != 5:
+ print('submitTopologyWithOpts requires 5 args')
+ sys.exit(1)
+ pp.pprint(client.submitTopologyWithOpts(args[0], args[1], args[2], eval(args[3]), eval(args[4]),))
elif cmd == 'killTopology':
- if len(args) != 1:
- print('killTopology requires 1 args')
- sys.exit(1)
- pp.pprint(client.killTopology(args[0],))
+ if len(args) != 1:
+ print('killTopology requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.killTopology(args[0],))
elif cmd == 'killTopologyWithOpts':
- if len(args) != 2:
- print('killTopologyWithOpts requires 2 args')
- sys.exit(1)
- pp.pprint(client.killTopologyWithOpts(args[0],eval(args[1]),))
+ if len(args) != 2:
+ print('killTopologyWithOpts requires 2 args')
+ sys.exit(1)
+ pp.pprint(client.killTopologyWithOpts(args[0], eval(args[1]),))
elif cmd == 'activate':
- if len(args) != 1:
- print('activate requires 1 args')
- sys.exit(1)
- pp.pprint(client.activate(args[0],))
+ if len(args) != 1:
+ print('activate requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.activate(args[0],))
elif cmd == 'deactivate':
- if len(args) != 1:
- print('deactivate requires 1 args')
- sys.exit(1)
- pp.pprint(client.deactivate(args[0],))
+ if len(args) != 1:
+ print('deactivate requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.deactivate(args[0],))
elif cmd == 'rebalance':
- if len(args) != 2:
- print('rebalance requires 2 args')
- sys.exit(1)
- pp.pprint(client.rebalance(args[0],eval(args[1]),))
+ if len(args) != 2:
+ print('rebalance requires 2 args')
+ sys.exit(1)
+ pp.pprint(client.rebalance(args[0], eval(args[1]),))
elif cmd == 'setLogConfig':
- if len(args) != 2:
- print('setLogConfig requires 2 args')
- sys.exit(1)
- pp.pprint(client.setLogConfig(args[0],eval(args[1]),))
+ if len(args) != 2:
+ print('setLogConfig requires 2 args')
+ sys.exit(1)
+ pp.pprint(client.setLogConfig(args[0], eval(args[1]),))
elif cmd == 'getLogConfig':
- if len(args) != 1:
- print('getLogConfig requires 1 args')
- sys.exit(1)
- pp.pprint(client.getLogConfig(args[0],))
+ if len(args) != 1:
+ print('getLogConfig requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.getLogConfig(args[0],))
elif cmd == 'debug':
- if len(args) != 4:
- print('debug requires 4 args')
- sys.exit(1)
- pp.pprint(client.debug(args[0],args[1],eval(args[2]),eval(args[3]),))
+ if len(args) != 4:
+ print('debug requires 4 args')
+ sys.exit(1)
+ pp.pprint(client.debug(args[0], args[1], eval(args[2]), eval(args[3]),))
elif cmd == 'setWorkerProfiler':
- if len(args) != 2:
- print('setWorkerProfiler requires 2 args')
- sys.exit(1)
- pp.pprint(client.setWorkerProfiler(args[0],eval(args[1]),))
+ if len(args) != 2:
+ print('setWorkerProfiler requires 2 args')
+ sys.exit(1)
+ pp.pprint(client.setWorkerProfiler(args[0], eval(args[1]),))
elif cmd == 'getComponentPendingProfileActions':
- if len(args) != 3:
- print('getComponentPendingProfileActions requires 3 args')
- sys.exit(1)
- pp.pprint(client.getComponentPendingProfileActions(args[0],args[1],eval(args[2]),))
+ if len(args) != 3:
+ print('getComponentPendingProfileActions requires 3 args')
+ sys.exit(1)
+ pp.pprint(client.getComponentPendingProfileActions(args[0], args[1], eval(args[2]),))
elif cmd == 'uploadNewCredentials':
- if len(args) != 2:
- print('uploadNewCredentials requires 2 args')
- sys.exit(1)
- pp.pprint(client.uploadNewCredentials(args[0],eval(args[1]),))
+ if len(args) != 2:
+ print('uploadNewCredentials requires 2 args')
+ sys.exit(1)
+ pp.pprint(client.uploadNewCredentials(args[0], eval(args[1]),))
elif cmd == 'beginCreateBlob':
- if len(args) != 2:
- print('beginCreateBlob requires 2 args')
- sys.exit(1)
- pp.pprint(client.beginCreateBlob(args[0],eval(args[1]),))
+ if len(args) != 2:
+ print('beginCreateBlob requires 2 args')
+ sys.exit(1)
+ pp.pprint(client.beginCreateBlob(args[0], eval(args[1]),))
elif cmd == 'beginUpdateBlob':
- if len(args) != 1:
- print('beginUpdateBlob requires 1 args')
- sys.exit(1)
- pp.pprint(client.beginUpdateBlob(args[0],))
+ if len(args) != 1:
+ print('beginUpdateBlob requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.beginUpdateBlob(args[0],))
elif cmd == 'uploadBlobChunk':
- if len(args) != 2:
- print('uploadBlobChunk requires 2 args')
- sys.exit(1)
- pp.pprint(client.uploadBlobChunk(args[0],args[1],))
+ if len(args) != 2:
+ print('uploadBlobChunk requires 2 args')
+ sys.exit(1)
+ pp.pprint(client.uploadBlobChunk(args[0], args[1],))
elif cmd == 'finishBlobUpload':
- if len(args) != 1:
- print('finishBlobUpload requires 1 args')
- sys.exit(1)
- pp.pprint(client.finishBlobUpload(args[0],))
+ if len(args) != 1:
+ print('finishBlobUpload requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.finishBlobUpload(args[0],))
elif cmd == 'cancelBlobUpload':
- if len(args) != 1:
- print('cancelBlobUpload requires 1 args')
- sys.exit(1)
- pp.pprint(client.cancelBlobUpload(args[0],))
+ if len(args) != 1:
+ print('cancelBlobUpload requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.cancelBlobUpload(args[0],))
elif cmd == 'getBlobMeta':
- if len(args) != 1:
- print('getBlobMeta requires 1 args')
- sys.exit(1)
- pp.pprint(client.getBlobMeta(args[0],))
+ if len(args) != 1:
+ print('getBlobMeta requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.getBlobMeta(args[0],))
elif cmd == 'setBlobMeta':
- if len(args) != 2:
- print('setBlobMeta requires 2 args')
- sys.exit(1)
- pp.pprint(client.setBlobMeta(args[0],eval(args[1]),))
+ if len(args) != 2:
+ print('setBlobMeta requires 2 args')
+ sys.exit(1)
+ pp.pprint(client.setBlobMeta(args[0], eval(args[1]),))
elif cmd == 'beginBlobDownload':
- if len(args) != 1:
- print('beginBlobDownload requires 1 args')
- sys.exit(1)
- pp.pprint(client.beginBlobDownload(args[0],))
+ if len(args) != 1:
+ print('beginBlobDownload requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.beginBlobDownload(args[0],))
elif cmd == 'downloadBlobChunk':
- if len(args) != 1:
- print('downloadBlobChunk requires 1 args')
- sys.exit(1)
- pp.pprint(client.downloadBlobChunk(args[0],))
+ if len(args) != 1:
+ print('downloadBlobChunk requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.downloadBlobChunk(args[0],))
elif cmd == 'deleteBlob':
- if len(args) != 1:
- print('deleteBlob requires 1 args')
- sys.exit(1)
- pp.pprint(client.deleteBlob(args[0],))
+ if len(args) != 1:
+ print('deleteBlob requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.deleteBlob(args[0],))
elif cmd == 'listBlobs':
- if len(args) != 1:
- print('listBlobs requires 1 args')
- sys.exit(1)
- pp.pprint(client.listBlobs(args[0],))
+ if len(args) != 1:
+ print('listBlobs requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.listBlobs(args[0],))
elif cmd == 'getBlobReplication':
- if len(args) != 1:
- print('getBlobReplication requires 1 args')
- sys.exit(1)
- pp.pprint(client.getBlobReplication(args[0],))
+ if len(args) != 1:
+ print('getBlobReplication requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.getBlobReplication(args[0],))
elif cmd == 'updateBlobReplication':
- if len(args) != 2:
- print('updateBlobReplication requires 2 args')
- sys.exit(1)
- pp.pprint(client.updateBlobReplication(args[0],eval(args[1]),))
+ if len(args) != 2:
+ print('updateBlobReplication requires 2 args')
+ sys.exit(1)
+ pp.pprint(client.updateBlobReplication(args[0], eval(args[1]),))
elif cmd == 'createStateInZookeeper':
- if len(args) != 1:
- print('createStateInZookeeper requires 1 args')
- sys.exit(1)
- pp.pprint(client.createStateInZookeeper(args[0],))
+ if len(args) != 1:
+ print('createStateInZookeeper requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.createStateInZookeeper(args[0],))
elif cmd == 'beginFileUpload':
- if len(args) != 0:
- print('beginFileUpload requires 0 args')
- sys.exit(1)
- pp.pprint(client.beginFileUpload())
+ if len(args) != 0:
+ print('beginFileUpload requires 0 args')
+ sys.exit(1)
+ pp.pprint(client.beginFileUpload())
elif cmd == 'uploadChunk':
- if len(args) != 2:
- print('uploadChunk requires 2 args')
- sys.exit(1)
- pp.pprint(client.uploadChunk(args[0],args[1],))
+ if len(args) != 2:
+ print('uploadChunk requires 2 args')
+ sys.exit(1)
+ pp.pprint(client.uploadChunk(args[0], args[1],))
elif cmd == 'finishFileUpload':
- if len(args) != 1:
- print('finishFileUpload requires 1 args')
- sys.exit(1)
- pp.pprint(client.finishFileUpload(args[0],))
+ if len(args) != 1:
+ print('finishFileUpload requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.finishFileUpload(args[0],))
elif cmd == 'beginFileDownload':
- if len(args) != 1:
- print('beginFileDownload requires 1 args')
- sys.exit(1)
- pp.pprint(client.beginFileDownload(args[0],))
+ if len(args) != 1:
+ print('beginFileDownload requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.beginFileDownload(args[0],))
elif cmd == 'downloadChunk':
- if len(args) != 1:
- print('downloadChunk requires 1 args')
- sys.exit(1)
- pp.pprint(client.downloadChunk(args[0],))
+ if len(args) != 1:
+ print('downloadChunk requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.downloadChunk(args[0],))
elif cmd == 'getNimbusConf':
- if len(args) != 0:
- print('getNimbusConf requires 0 args')
- sys.exit(1)
- pp.pprint(client.getNimbusConf())
+ if len(args) != 0:
+ print('getNimbusConf requires 0 args')
+ sys.exit(1)
+ pp.pprint(client.getNimbusConf())
elif cmd == 'getClusterInfo':
- if len(args) != 0:
- print('getClusterInfo requires 0 args')
- sys.exit(1)
- pp.pprint(client.getClusterInfo())
+ if len(args) != 0:
+ print('getClusterInfo requires 0 args')
+ sys.exit(1)
+ pp.pprint(client.getClusterInfo())
elif cmd == 'getLeader':
- if len(args) != 0:
- print('getLeader requires 0 args')
- sys.exit(1)
- pp.pprint(client.getLeader())
+ if len(args) != 0:
+ print('getLeader requires 0 args')
+ sys.exit(1)
+ pp.pprint(client.getLeader())
elif cmd == 'isTopologyNameAllowed':
- if len(args) != 1:
- print('isTopologyNameAllowed requires 1 args')
- sys.exit(1)
- pp.pprint(client.isTopologyNameAllowed(args[0],))
+ if len(args) != 1:
+ print('isTopologyNameAllowed requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.isTopologyNameAllowed(args[0],))
elif cmd == 'getTopologyInfo':
- if len(args) != 1:
- print('getTopologyInfo requires 1 args')
- sys.exit(1)
- pp.pprint(client.getTopologyInfo(args[0],))
+ if len(args) != 1:
+ print('getTopologyInfo requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.getTopologyInfo(args[0],))
elif cmd == 'getTopologyInfoWithOpts':
- if len(args) != 2:
- print('getTopologyInfoWithOpts requires 2 args')
- sys.exit(1)
- pp.pprint(client.getTopologyInfoWithOpts(args[0],eval(args[1]),))
+ if len(args) != 2:
+ print('getTopologyInfoWithOpts requires 2 args')
+ sys.exit(1)
+ pp.pprint(client.getTopologyInfoWithOpts(args[0], eval(args[1]),))
elif cmd == 'getTopologyPageInfo':
- if len(args) != 3:
- print('getTopologyPageInfo requires 3 args')
- sys.exit(1)
- pp.pprint(client.getTopologyPageInfo(args[0],args[1],eval(args[2]),))
+ if len(args) != 3:
+ print('getTopologyPageInfo requires 3 args')
+ sys.exit(1)
+ pp.pprint(client.getTopologyPageInfo(args[0], args[1], eval(args[2]),))
elif cmd == 'getSupervisorPageInfo':
- if len(args) != 3:
- print('getSupervisorPageInfo requires 3 args')
- sys.exit(1)
- pp.pprint(client.getSupervisorPageInfo(args[0],args[1],eval(args[2]),))
+ if len(args) != 3:
+ print('getSupervisorPageInfo requires 3 args')
+ sys.exit(1)
+ pp.pprint(client.getSupervisorPageInfo(args[0], args[1], eval(args[2]),))
elif cmd == 'getComponentPageInfo':
- if len(args) != 4:
- print('getComponentPageInfo requires 4 args')
- sys.exit(1)
- pp.pprint(client.getComponentPageInfo(args[0],args[1],args[2],eval(args[3]),))
+ if len(args) != 4:
+ print('getComponentPageInfo requires 4 args')
+ sys.exit(1)
+ pp.pprint(client.getComponentPageInfo(args[0], args[1], args[2], eval(args[3]),))
elif cmd == 'getTopologyConf':
- if len(args) != 1:
- print('getTopologyConf requires 1 args')
- sys.exit(1)
- pp.pprint(client.getTopologyConf(args[0],))
+ if len(args) != 1:
+ print('getTopologyConf requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.getTopologyConf(args[0],))
elif cmd == 'getTopology':
- if len(args) != 1:
- print('getTopology requires 1 args')
- sys.exit(1)
- pp.pprint(client.getTopology(args[0],))
+ if len(args) != 1:
+ print('getTopology requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.getTopology(args[0],))
elif cmd == 'getUserTopology':
- if len(args) != 1:
- print('getUserTopology requires 1 args')
- sys.exit(1)
- pp.pprint(client.getUserTopology(args[0],))
+ if len(args) != 1:
+ print('getUserTopology requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.getUserTopology(args[0],))
elif cmd == 'getTopologyHistory':
- if len(args) != 1:
- print('getTopologyHistory requires 1 args')
- sys.exit(1)
- pp.pprint(client.getTopologyHistory(args[0],))
+ if len(args) != 1:
+ print('getTopologyHistory requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.getTopologyHistory(args[0],))
elif cmd == 'getOwnerResourceSummaries':
- if len(args) != 1:
- print('getOwnerResourceSummaries requires 1 args')
- sys.exit(1)
- pp.pprint(client.getOwnerResourceSummaries(args[0],))
+ if len(args) != 1:
+ print('getOwnerResourceSummaries requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.getOwnerResourceSummaries(args[0],))
elif cmd == 'getSupervisorAssignments':
- if len(args) != 1:
- print('getSupervisorAssignments requires 1 args')
- sys.exit(1)
- pp.pprint(client.getSupervisorAssignments(args[0],))
+ if len(args) != 1:
+ print('getSupervisorAssignments requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.getSupervisorAssignments(args[0],))
elif cmd == 'sendSupervisorWorkerHeartbeats':
- if len(args) != 1:
- print('sendSupervisorWorkerHeartbeats requires 1 args')
- sys.exit(1)
- pp.pprint(client.sendSupervisorWorkerHeartbeats(eval(args[0]),))
+ if len(args) != 1:
+ print('sendSupervisorWorkerHeartbeats requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.sendSupervisorWorkerHeartbeats(eval(args[0]),))
elif cmd == 'sendSupervisorWorkerHeartbeat':
- if len(args) != 1:
- print('sendSupervisorWorkerHeartbeat requires 1 args')
- sys.exit(1)
- pp.pprint(client.sendSupervisorWorkerHeartbeat(eval(args[0]),))
+ if len(args) != 1:
+ print('sendSupervisorWorkerHeartbeat requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.sendSupervisorWorkerHeartbeat(eval(args[0]),))
elif cmd == 'processWorkerMetrics':
- if len(args) != 1:
- print('processWorkerMetrics requires 1 args')
- sys.exit(1)
- pp.pprint(client.processWorkerMetrics(eval(args[0]),))
+ if len(args) != 1:
+ print('processWorkerMetrics requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.processWorkerMetrics(eval(args[0]),))
else:
- print('Unrecognized method %s' % cmd)
- sys.exit(1)
+ print('Unrecognized method %s' % cmd)
+ sys.exit(1)
transport.close()