|
|
@@ -1,1930 +0,0 @@
|
|
|
-#
|
|
|
-# Autogenerated by Thrift Compiler (0.9.1)
|
|
|
-#
|
|
|
-# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
|
|
|
-#
|
|
|
-# options string: py:new_style
|
|
|
-#
|
|
|
-
|
|
|
-from thrift.Thrift import TType, TMessageType, TException, TApplicationException
|
|
|
-from ttypes import *
|
|
|
-from thrift.Thrift import TProcessor
|
|
|
-from thrift.transport import TTransport
|
|
|
-from thrift.protocol import TBinaryProtocol, TProtocol
|
|
|
-try:
|
|
|
- from thrift.protocol import fastbinary
|
|
|
-except:
|
|
|
- fastbinary = None
|
|
|
-
|
|
|
-
|
|
|
-class Iface(object):
|
|
|
- """
|
|
|
- Standard base service
|
|
|
- """
|
|
|
- def getName(self):
|
|
|
- """
|
|
|
- Returns a descriptive name of the service
|
|
|
- """
|
|
|
- pass
|
|
|
-
|
|
|
- def getVersion(self):
|
|
|
- """
|
|
|
- Returns the version of the service
|
|
|
- """
|
|
|
- pass
|
|
|
-
|
|
|
- def getStatus(self):
|
|
|
- """
|
|
|
- Gets the status of this service
|
|
|
- """
|
|
|
- pass
|
|
|
-
|
|
|
- def getStatusDetails(self):
|
|
|
- """
|
|
|
- User friendly description of status, such as why the service is in
|
|
|
- the dead or warning state, or what is being started or stopped.
|
|
|
- """
|
|
|
- pass
|
|
|
-
|
|
|
- def getCounters(self):
|
|
|
- """
|
|
|
- Gets the counters for this service
|
|
|
- """
|
|
|
- pass
|
|
|
-
|
|
|
- def getCounter(self, key):
|
|
|
- """
|
|
|
- Gets the value of a single counter
|
|
|
-
|
|
|
- Parameters:
|
|
|
- - key
|
|
|
- """
|
|
|
- pass
|
|
|
-
|
|
|
- def setOption(self, key, value):
|
|
|
- """
|
|
|
- Sets an option
|
|
|
-
|
|
|
- Parameters:
|
|
|
- - key
|
|
|
- - value
|
|
|
- """
|
|
|
- pass
|
|
|
-
|
|
|
- def getOption(self, key):
|
|
|
- """
|
|
|
- Gets an option
|
|
|
-
|
|
|
- Parameters:
|
|
|
- - key
|
|
|
- """
|
|
|
- pass
|
|
|
-
|
|
|
- def getOptions(self):
|
|
|
- """
|
|
|
- Gets all options
|
|
|
- """
|
|
|
- pass
|
|
|
-
|
|
|
- def getCpuProfile(self, profileDurationInSec):
|
|
|
- """
|
|
|
- Returns a CPU profile over the given time interval (client and server
|
|
|
- must agree on the profile format).
|
|
|
-
|
|
|
- Parameters:
|
|
|
- - profileDurationInSec
|
|
|
- """
|
|
|
- pass
|
|
|
-
|
|
|
- def aliveSince(self):
|
|
|
- """
|
|
|
- Returns the unix time that the server has been running since
|
|
|
- """
|
|
|
- pass
|
|
|
-
|
|
|
- def reinitialize(self):
|
|
|
- """
|
|
|
- Tell the server to reload its configuration, reopen log files, etc
|
|
|
- """
|
|
|
- pass
|
|
|
-
|
|
|
- def shutdown(self):
|
|
|
- """
|
|
|
- Suggest a shutdown to the server
|
|
|
- """
|
|
|
- pass
|
|
|
-
|
|
|
-
|
|
|
-class Client(Iface):
|
|
|
- """
|
|
|
- Standard base service
|
|
|
- """
|
|
|
- def __init__(self, iprot, oprot=None):
|
|
|
- self._iprot = self._oprot = iprot
|
|
|
- if oprot is not None:
|
|
|
- self._oprot = oprot
|
|
|
- self._seqid = 0
|
|
|
-
|
|
|
- def getName(self):
|
|
|
- """
|
|
|
- Returns a descriptive name of the service
|
|
|
- """
|
|
|
- self.send_getName()
|
|
|
- return self.recv_getName()
|
|
|
-
|
|
|
- def send_getName(self):
|
|
|
- self._oprot.writeMessageBegin('getName', TMessageType.CALL, self._seqid)
|
|
|
- args = getName_args()
|
|
|
- args.write(self._oprot)
|
|
|
- self._oprot.writeMessageEnd()
|
|
|
- self._oprot.trans.flush()
|
|
|
-
|
|
|
- def recv_getName(self):
|
|
|
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
|
|
- if mtype == TMessageType.EXCEPTION:
|
|
|
- x = TApplicationException()
|
|
|
- x.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- raise x
|
|
|
- result = getName_result()
|
|
|
- result.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- if result.success is not None:
|
|
|
- return result.success
|
|
|
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getName failed: unknown result");
|
|
|
-
|
|
|
- def getVersion(self):
|
|
|
- """
|
|
|
- Returns the version of the service
|
|
|
- """
|
|
|
- self.send_getVersion()
|
|
|
- return self.recv_getVersion()
|
|
|
-
|
|
|
- def send_getVersion(self):
|
|
|
- self._oprot.writeMessageBegin('getVersion', TMessageType.CALL, self._seqid)
|
|
|
- args = getVersion_args()
|
|
|
- args.write(self._oprot)
|
|
|
- self._oprot.writeMessageEnd()
|
|
|
- self._oprot.trans.flush()
|
|
|
-
|
|
|
- def recv_getVersion(self):
|
|
|
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
|
|
- if mtype == TMessageType.EXCEPTION:
|
|
|
- x = TApplicationException()
|
|
|
- x.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- raise x
|
|
|
- result = getVersion_result()
|
|
|
- result.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- if result.success is not None:
|
|
|
- return result.success
|
|
|
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getVersion failed: unknown result");
|
|
|
-
|
|
|
- def getStatus(self):
|
|
|
- """
|
|
|
- Gets the status of this service
|
|
|
- """
|
|
|
- self.send_getStatus()
|
|
|
- return self.recv_getStatus()
|
|
|
-
|
|
|
- def send_getStatus(self):
|
|
|
- self._oprot.writeMessageBegin('getStatus', TMessageType.CALL, self._seqid)
|
|
|
- args = getStatus_args()
|
|
|
- args.write(self._oprot)
|
|
|
- self._oprot.writeMessageEnd()
|
|
|
- self._oprot.trans.flush()
|
|
|
-
|
|
|
- def recv_getStatus(self):
|
|
|
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
|
|
- if mtype == TMessageType.EXCEPTION:
|
|
|
- x = TApplicationException()
|
|
|
- x.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- raise x
|
|
|
- result = getStatus_result()
|
|
|
- result.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- if result.success is not None:
|
|
|
- return result.success
|
|
|
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getStatus failed: unknown result");
|
|
|
-
|
|
|
- def getStatusDetails(self):
|
|
|
- """
|
|
|
- User friendly description of status, such as why the service is in
|
|
|
- the dead or warning state, or what is being started or stopped.
|
|
|
- """
|
|
|
- self.send_getStatusDetails()
|
|
|
- return self.recv_getStatusDetails()
|
|
|
-
|
|
|
- def send_getStatusDetails(self):
|
|
|
- self._oprot.writeMessageBegin('getStatusDetails', TMessageType.CALL, self._seqid)
|
|
|
- args = getStatusDetails_args()
|
|
|
- args.write(self._oprot)
|
|
|
- self._oprot.writeMessageEnd()
|
|
|
- self._oprot.trans.flush()
|
|
|
-
|
|
|
- def recv_getStatusDetails(self):
|
|
|
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
|
|
- if mtype == TMessageType.EXCEPTION:
|
|
|
- x = TApplicationException()
|
|
|
- x.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- raise x
|
|
|
- result = getStatusDetails_result()
|
|
|
- result.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- if result.success is not None:
|
|
|
- return result.success
|
|
|
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getStatusDetails failed: unknown result");
|
|
|
-
|
|
|
- def getCounters(self):
|
|
|
- """
|
|
|
- Gets the counters for this service
|
|
|
- """
|
|
|
- self.send_getCounters()
|
|
|
- return self.recv_getCounters()
|
|
|
-
|
|
|
- def send_getCounters(self):
|
|
|
- self._oprot.writeMessageBegin('getCounters', TMessageType.CALL, self._seqid)
|
|
|
- args = getCounters_args()
|
|
|
- args.write(self._oprot)
|
|
|
- self._oprot.writeMessageEnd()
|
|
|
- self._oprot.trans.flush()
|
|
|
-
|
|
|
- def recv_getCounters(self):
|
|
|
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
|
|
- if mtype == TMessageType.EXCEPTION:
|
|
|
- x = TApplicationException()
|
|
|
- x.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- raise x
|
|
|
- result = getCounters_result()
|
|
|
- result.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- if result.success is not None:
|
|
|
- return result.success
|
|
|
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getCounters failed: unknown result");
|
|
|
-
|
|
|
- def getCounter(self, key):
|
|
|
- """
|
|
|
- Gets the value of a single counter
|
|
|
-
|
|
|
- Parameters:
|
|
|
- - key
|
|
|
- """
|
|
|
- self.send_getCounter(key)
|
|
|
- return self.recv_getCounter()
|
|
|
-
|
|
|
- def send_getCounter(self, key):
|
|
|
- self._oprot.writeMessageBegin('getCounter', TMessageType.CALL, self._seqid)
|
|
|
- args = getCounter_args()
|
|
|
- args.key = key
|
|
|
- args.write(self._oprot)
|
|
|
- self._oprot.writeMessageEnd()
|
|
|
- self._oprot.trans.flush()
|
|
|
-
|
|
|
- def recv_getCounter(self):
|
|
|
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
|
|
- if mtype == TMessageType.EXCEPTION:
|
|
|
- x = TApplicationException()
|
|
|
- x.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- raise x
|
|
|
- result = getCounter_result()
|
|
|
- result.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- if result.success is not None:
|
|
|
- return result.success
|
|
|
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getCounter failed: unknown result");
|
|
|
-
|
|
|
- def setOption(self, key, value):
|
|
|
- """
|
|
|
- Sets an option
|
|
|
-
|
|
|
- Parameters:
|
|
|
- - key
|
|
|
- - value
|
|
|
- """
|
|
|
- self.send_setOption(key, value)
|
|
|
- self.recv_setOption()
|
|
|
-
|
|
|
- def send_setOption(self, key, value):
|
|
|
- self._oprot.writeMessageBegin('setOption', TMessageType.CALL, self._seqid)
|
|
|
- args = setOption_args()
|
|
|
- args.key = key
|
|
|
- args.value = value
|
|
|
- args.write(self._oprot)
|
|
|
- self._oprot.writeMessageEnd()
|
|
|
- self._oprot.trans.flush()
|
|
|
-
|
|
|
- def recv_setOption(self):
|
|
|
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
|
|
- if mtype == TMessageType.EXCEPTION:
|
|
|
- x = TApplicationException()
|
|
|
- x.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- raise x
|
|
|
- result = setOption_result()
|
|
|
- result.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- return
|
|
|
-
|
|
|
- def getOption(self, key):
|
|
|
- """
|
|
|
- Gets an option
|
|
|
-
|
|
|
- Parameters:
|
|
|
- - key
|
|
|
- """
|
|
|
- self.send_getOption(key)
|
|
|
- return self.recv_getOption()
|
|
|
-
|
|
|
- def send_getOption(self, key):
|
|
|
- self._oprot.writeMessageBegin('getOption', TMessageType.CALL, self._seqid)
|
|
|
- args = getOption_args()
|
|
|
- args.key = key
|
|
|
- args.write(self._oprot)
|
|
|
- self._oprot.writeMessageEnd()
|
|
|
- self._oprot.trans.flush()
|
|
|
-
|
|
|
- def recv_getOption(self):
|
|
|
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
|
|
- if mtype == TMessageType.EXCEPTION:
|
|
|
- x = TApplicationException()
|
|
|
- x.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- raise x
|
|
|
- result = getOption_result()
|
|
|
- result.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- if result.success is not None:
|
|
|
- return result.success
|
|
|
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getOption failed: unknown result");
|
|
|
-
|
|
|
- def getOptions(self):
|
|
|
- """
|
|
|
- Gets all options
|
|
|
- """
|
|
|
- self.send_getOptions()
|
|
|
- return self.recv_getOptions()
|
|
|
-
|
|
|
- def send_getOptions(self):
|
|
|
- self._oprot.writeMessageBegin('getOptions', TMessageType.CALL, self._seqid)
|
|
|
- args = getOptions_args()
|
|
|
- args.write(self._oprot)
|
|
|
- self._oprot.writeMessageEnd()
|
|
|
- self._oprot.trans.flush()
|
|
|
-
|
|
|
- def recv_getOptions(self):
|
|
|
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
|
|
- if mtype == TMessageType.EXCEPTION:
|
|
|
- x = TApplicationException()
|
|
|
- x.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- raise x
|
|
|
- result = getOptions_result()
|
|
|
- result.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- if result.success is not None:
|
|
|
- return result.success
|
|
|
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getOptions failed: unknown result");
|
|
|
-
|
|
|
- def getCpuProfile(self, profileDurationInSec):
|
|
|
- """
|
|
|
- Returns a CPU profile over the given time interval (client and server
|
|
|
- must agree on the profile format).
|
|
|
-
|
|
|
- Parameters:
|
|
|
- - profileDurationInSec
|
|
|
- """
|
|
|
- self.send_getCpuProfile(profileDurationInSec)
|
|
|
- return self.recv_getCpuProfile()
|
|
|
-
|
|
|
- def send_getCpuProfile(self, profileDurationInSec):
|
|
|
- self._oprot.writeMessageBegin('getCpuProfile', TMessageType.CALL, self._seqid)
|
|
|
- args = getCpuProfile_args()
|
|
|
- args.profileDurationInSec = profileDurationInSec
|
|
|
- args.write(self._oprot)
|
|
|
- self._oprot.writeMessageEnd()
|
|
|
- self._oprot.trans.flush()
|
|
|
-
|
|
|
- def recv_getCpuProfile(self):
|
|
|
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
|
|
- if mtype == TMessageType.EXCEPTION:
|
|
|
- x = TApplicationException()
|
|
|
- x.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- raise x
|
|
|
- result = getCpuProfile_result()
|
|
|
- result.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- if result.success is not None:
|
|
|
- return result.success
|
|
|
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getCpuProfile failed: unknown result");
|
|
|
-
|
|
|
- def aliveSince(self):
|
|
|
- """
|
|
|
- Returns the unix time that the server has been running since
|
|
|
- """
|
|
|
- self.send_aliveSince()
|
|
|
- return self.recv_aliveSince()
|
|
|
-
|
|
|
- def send_aliveSince(self):
|
|
|
- self._oprot.writeMessageBegin('aliveSince', TMessageType.CALL, self._seqid)
|
|
|
- args = aliveSince_args()
|
|
|
- args.write(self._oprot)
|
|
|
- self._oprot.writeMessageEnd()
|
|
|
- self._oprot.trans.flush()
|
|
|
-
|
|
|
- def recv_aliveSince(self):
|
|
|
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
|
|
- if mtype == TMessageType.EXCEPTION:
|
|
|
- x = TApplicationException()
|
|
|
- x.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- raise x
|
|
|
- result = aliveSince_result()
|
|
|
- result.read(self._iprot)
|
|
|
- self._iprot.readMessageEnd()
|
|
|
- if result.success is not None:
|
|
|
- return result.success
|
|
|
- raise TApplicationException(TApplicationException.MISSING_RESULT, "aliveSince failed: unknown result");
|
|
|
-
|
|
|
- def reinitialize(self):
|
|
|
- """
|
|
|
- Tell the server to reload its configuration, reopen log files, etc
|
|
|
- """
|
|
|
- self.send_reinitialize()
|
|
|
-
|
|
|
- def send_reinitialize(self):
|
|
|
- self._oprot.writeMessageBegin('reinitialize', TMessageType.CALL, self._seqid)
|
|
|
- args = reinitialize_args()
|
|
|
- args.write(self._oprot)
|
|
|
- self._oprot.writeMessageEnd()
|
|
|
- self._oprot.trans.flush()
|
|
|
- def shutdown(self):
|
|
|
- """
|
|
|
- Suggest a shutdown to the server
|
|
|
- """
|
|
|
- self.send_shutdown()
|
|
|
-
|
|
|
- def send_shutdown(self):
|
|
|
- self._oprot.writeMessageBegin('shutdown', TMessageType.CALL, self._seqid)
|
|
|
- args = shutdown_args()
|
|
|
- args.write(self._oprot)
|
|
|
- self._oprot.writeMessageEnd()
|
|
|
- self._oprot.trans.flush()
|
|
|
-
|
|
|
-class Processor(Iface, TProcessor):
|
|
|
- def __init__(self, handler):
|
|
|
- self._handler = handler
|
|
|
- self._processMap = {}
|
|
|
- self._processMap["getName"] = Processor.process_getName
|
|
|
- self._processMap["getVersion"] = Processor.process_getVersion
|
|
|
- self._processMap["getStatus"] = Processor.process_getStatus
|
|
|
- self._processMap["getStatusDetails"] = Processor.process_getStatusDetails
|
|
|
- self._processMap["getCounters"] = Processor.process_getCounters
|
|
|
- self._processMap["getCounter"] = Processor.process_getCounter
|
|
|
- self._processMap["setOption"] = Processor.process_setOption
|
|
|
- self._processMap["getOption"] = Processor.process_getOption
|
|
|
- self._processMap["getOptions"] = Processor.process_getOptions
|
|
|
- self._processMap["getCpuProfile"] = Processor.process_getCpuProfile
|
|
|
- self._processMap["aliveSince"] = Processor.process_aliveSince
|
|
|
- self._processMap["reinitialize"] = Processor.process_reinitialize
|
|
|
- self._processMap["shutdown"] = Processor.process_shutdown
|
|
|
-
|
|
|
- def process(self, iprot, oprot):
|
|
|
- (name, type, seqid) = iprot.readMessageBegin()
|
|
|
- if name not in self._processMap:
|
|
|
- iprot.skip(TType.STRUCT)
|
|
|
- iprot.readMessageEnd()
|
|
|
- x = TApplicationException(TApplicationException.UNKNOWN_METHOD, 'Unknown function %s' % (name))
|
|
|
- oprot.writeMessageBegin(name, TMessageType.EXCEPTION, seqid)
|
|
|
- x.write(oprot)
|
|
|
- oprot.writeMessageEnd()
|
|
|
- oprot.trans.flush()
|
|
|
- return
|
|
|
- else:
|
|
|
- self._processMap[name](self, seqid, iprot, oprot)
|
|
|
- return True
|
|
|
-
|
|
|
- def process_getName(self, seqid, iprot, oprot):
|
|
|
- args = getName_args()
|
|
|
- args.read(iprot)
|
|
|
- iprot.readMessageEnd()
|
|
|
- result = getName_result()
|
|
|
- result.success = self._handler.getName()
|
|
|
- oprot.writeMessageBegin("getName", TMessageType.REPLY, seqid)
|
|
|
- result.write(oprot)
|
|
|
- oprot.writeMessageEnd()
|
|
|
- oprot.trans.flush()
|
|
|
-
|
|
|
- def process_getVersion(self, seqid, iprot, oprot):
|
|
|
- args = getVersion_args()
|
|
|
- args.read(iprot)
|
|
|
- iprot.readMessageEnd()
|
|
|
- result = getVersion_result()
|
|
|
- result.success = self._handler.getVersion()
|
|
|
- oprot.writeMessageBegin("getVersion", TMessageType.REPLY, seqid)
|
|
|
- result.write(oprot)
|
|
|
- oprot.writeMessageEnd()
|
|
|
- oprot.trans.flush()
|
|
|
-
|
|
|
- def process_getStatus(self, seqid, iprot, oprot):
|
|
|
- args = getStatus_args()
|
|
|
- args.read(iprot)
|
|
|
- iprot.readMessageEnd()
|
|
|
- result = getStatus_result()
|
|
|
- result.success = self._handler.getStatus()
|
|
|
- oprot.writeMessageBegin("getStatus", TMessageType.REPLY, seqid)
|
|
|
- result.write(oprot)
|
|
|
- oprot.writeMessageEnd()
|
|
|
- oprot.trans.flush()
|
|
|
-
|
|
|
- def process_getStatusDetails(self, seqid, iprot, oprot):
|
|
|
- args = getStatusDetails_args()
|
|
|
- args.read(iprot)
|
|
|
- iprot.readMessageEnd()
|
|
|
- result = getStatusDetails_result()
|
|
|
- result.success = self._handler.getStatusDetails()
|
|
|
- oprot.writeMessageBegin("getStatusDetails", TMessageType.REPLY, seqid)
|
|
|
- result.write(oprot)
|
|
|
- oprot.writeMessageEnd()
|
|
|
- oprot.trans.flush()
|
|
|
-
|
|
|
- def process_getCounters(self, seqid, iprot, oprot):
|
|
|
- args = getCounters_args()
|
|
|
- args.read(iprot)
|
|
|
- iprot.readMessageEnd()
|
|
|
- result = getCounters_result()
|
|
|
- result.success = self._handler.getCounters()
|
|
|
- oprot.writeMessageBegin("getCounters", TMessageType.REPLY, seqid)
|
|
|
- result.write(oprot)
|
|
|
- oprot.writeMessageEnd()
|
|
|
- oprot.trans.flush()
|
|
|
-
|
|
|
- def process_getCounter(self, seqid, iprot, oprot):
|
|
|
- args = getCounter_args()
|
|
|
- args.read(iprot)
|
|
|
- iprot.readMessageEnd()
|
|
|
- result = getCounter_result()
|
|
|
- result.success = self._handler.getCounter(args.key)
|
|
|
- oprot.writeMessageBegin("getCounter", TMessageType.REPLY, seqid)
|
|
|
- result.write(oprot)
|
|
|
- oprot.writeMessageEnd()
|
|
|
- oprot.trans.flush()
|
|
|
-
|
|
|
- def process_setOption(self, seqid, iprot, oprot):
|
|
|
- args = setOption_args()
|
|
|
- args.read(iprot)
|
|
|
- iprot.readMessageEnd()
|
|
|
- result = setOption_result()
|
|
|
- self._handler.setOption(args.key, args.value)
|
|
|
- oprot.writeMessageBegin("setOption", TMessageType.REPLY, seqid)
|
|
|
- result.write(oprot)
|
|
|
- oprot.writeMessageEnd()
|
|
|
- oprot.trans.flush()
|
|
|
-
|
|
|
- def process_getOption(self, seqid, iprot, oprot):
|
|
|
- args = getOption_args()
|
|
|
- args.read(iprot)
|
|
|
- iprot.readMessageEnd()
|
|
|
- result = getOption_result()
|
|
|
- result.success = self._handler.getOption(args.key)
|
|
|
- oprot.writeMessageBegin("getOption", TMessageType.REPLY, seqid)
|
|
|
- result.write(oprot)
|
|
|
- oprot.writeMessageEnd()
|
|
|
- oprot.trans.flush()
|
|
|
-
|
|
|
- def process_getOptions(self, seqid, iprot, oprot):
|
|
|
- args = getOptions_args()
|
|
|
- args.read(iprot)
|
|
|
- iprot.readMessageEnd()
|
|
|
- result = getOptions_result()
|
|
|
- result.success = self._handler.getOptions()
|
|
|
- oprot.writeMessageBegin("getOptions", TMessageType.REPLY, seqid)
|
|
|
- result.write(oprot)
|
|
|
- oprot.writeMessageEnd()
|
|
|
- oprot.trans.flush()
|
|
|
-
|
|
|
- def process_getCpuProfile(self, seqid, iprot, oprot):
|
|
|
- args = getCpuProfile_args()
|
|
|
- args.read(iprot)
|
|
|
- iprot.readMessageEnd()
|
|
|
- result = getCpuProfile_result()
|
|
|
- result.success = self._handler.getCpuProfile(args.profileDurationInSec)
|
|
|
- oprot.writeMessageBegin("getCpuProfile", TMessageType.REPLY, seqid)
|
|
|
- result.write(oprot)
|
|
|
- oprot.writeMessageEnd()
|
|
|
- oprot.trans.flush()
|
|
|
-
|
|
|
- def process_aliveSince(self, seqid, iprot, oprot):
|
|
|
- args = aliveSince_args()
|
|
|
- args.read(iprot)
|
|
|
- iprot.readMessageEnd()
|
|
|
- result = aliveSince_result()
|
|
|
- result.success = self._handler.aliveSince()
|
|
|
- oprot.writeMessageBegin("aliveSince", TMessageType.REPLY, seqid)
|
|
|
- result.write(oprot)
|
|
|
- oprot.writeMessageEnd()
|
|
|
- oprot.trans.flush()
|
|
|
-
|
|
|
- def process_reinitialize(self, seqid, iprot, oprot):
|
|
|
- args = reinitialize_args()
|
|
|
- args.read(iprot)
|
|
|
- iprot.readMessageEnd()
|
|
|
- self._handler.reinitialize()
|
|
|
- return
|
|
|
-
|
|
|
- def process_shutdown(self, seqid, iprot, oprot):
|
|
|
- args = shutdown_args()
|
|
|
- args.read(iprot)
|
|
|
- iprot.readMessageEnd()
|
|
|
- self._handler.shutdown()
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
-# HELPER FUNCTIONS AND STRUCTURES
|
|
|
-
|
|
|
-class getName_args(object):
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- )
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getName_args')
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getName_result(object):
|
|
|
- """
|
|
|
- Attributes:
|
|
|
- - success
|
|
|
- """
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- (0, TType.STRING, 'success', None, None, ), # 0
|
|
|
- )
|
|
|
-
|
|
|
- def __init__(self, success=None,):
|
|
|
- self.success = success
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- if fid == 0:
|
|
|
- if ftype == TType.STRING:
|
|
|
- self.success = iprot.readString();
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getName_result')
|
|
|
- if self.success is not None:
|
|
|
- oprot.writeFieldBegin('success', TType.STRING, 0)
|
|
|
- oprot.writeString(self.success)
|
|
|
- oprot.writeFieldEnd()
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getVersion_args(object):
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- )
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getVersion_args')
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getVersion_result(object):
|
|
|
- """
|
|
|
- Attributes:
|
|
|
- - success
|
|
|
- """
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- (0, TType.STRING, 'success', None, None, ), # 0
|
|
|
- )
|
|
|
-
|
|
|
- def __init__(self, success=None,):
|
|
|
- self.success = success
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- if fid == 0:
|
|
|
- if ftype == TType.STRING:
|
|
|
- self.success = iprot.readString();
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getVersion_result')
|
|
|
- if self.success is not None:
|
|
|
- oprot.writeFieldBegin('success', TType.STRING, 0)
|
|
|
- oprot.writeString(self.success)
|
|
|
- oprot.writeFieldEnd()
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getStatus_args(object):
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- )
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getStatus_args')
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getStatus_result(object):
|
|
|
- """
|
|
|
- Attributes:
|
|
|
- - success
|
|
|
- """
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- (0, TType.I32, 'success', None, None, ), # 0
|
|
|
- )
|
|
|
-
|
|
|
- def __init__(self, success=None,):
|
|
|
- self.success = success
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- if fid == 0:
|
|
|
- if ftype == TType.I32:
|
|
|
- self.success = iprot.readI32();
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getStatus_result')
|
|
|
- if self.success is not None:
|
|
|
- oprot.writeFieldBegin('success', TType.I32, 0)
|
|
|
- oprot.writeI32(self.success)
|
|
|
- oprot.writeFieldEnd()
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getStatusDetails_args(object):
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- )
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getStatusDetails_args')
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getStatusDetails_result(object):
|
|
|
- """
|
|
|
- Attributes:
|
|
|
- - success
|
|
|
- """
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- (0, TType.STRING, 'success', None, None, ), # 0
|
|
|
- )
|
|
|
-
|
|
|
- def __init__(self, success=None,):
|
|
|
- self.success = success
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- if fid == 0:
|
|
|
- if ftype == TType.STRING:
|
|
|
- self.success = iprot.readString();
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getStatusDetails_result')
|
|
|
- if self.success is not None:
|
|
|
- oprot.writeFieldBegin('success', TType.STRING, 0)
|
|
|
- oprot.writeString(self.success)
|
|
|
- oprot.writeFieldEnd()
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getCounters_args(object):
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- )
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getCounters_args')
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getCounters_result(object):
|
|
|
- """
|
|
|
- Attributes:
|
|
|
- - success
|
|
|
- """
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- (0, TType.MAP, 'success', (TType.STRING,None,TType.I64,None), None, ), # 0
|
|
|
- )
|
|
|
-
|
|
|
- def __init__(self, success=None,):
|
|
|
- self.success = success
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- if fid == 0:
|
|
|
- if ftype == TType.MAP:
|
|
|
- self.success = {}
|
|
|
- (_ktype1, _vtype2, _size0 ) = iprot.readMapBegin()
|
|
|
- for _i4 in xrange(_size0):
|
|
|
- _key5 = iprot.readString();
|
|
|
- _val6 = iprot.readI64();
|
|
|
- self.success[_key5] = _val6
|
|
|
- iprot.readMapEnd()
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getCounters_result')
|
|
|
- if self.success is not None:
|
|
|
- oprot.writeFieldBegin('success', TType.MAP, 0)
|
|
|
- oprot.writeMapBegin(TType.STRING, TType.I64, len(self.success))
|
|
|
- for kiter7,viter8 in self.success.items():
|
|
|
- oprot.writeString(kiter7)
|
|
|
- oprot.writeI64(viter8)
|
|
|
- oprot.writeMapEnd()
|
|
|
- oprot.writeFieldEnd()
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getCounter_args(object):
|
|
|
- """
|
|
|
- Attributes:
|
|
|
- - key
|
|
|
- """
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- None, # 0
|
|
|
- (1, TType.STRING, 'key', None, None, ), # 1
|
|
|
- )
|
|
|
-
|
|
|
- def __init__(self, key=None,):
|
|
|
- self.key = key
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- if fid == 1:
|
|
|
- if ftype == TType.STRING:
|
|
|
- self.key = iprot.readString();
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getCounter_args')
|
|
|
- if self.key is not None:
|
|
|
- oprot.writeFieldBegin('key', TType.STRING, 1)
|
|
|
- oprot.writeString(self.key)
|
|
|
- oprot.writeFieldEnd()
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getCounter_result(object):
|
|
|
- """
|
|
|
- Attributes:
|
|
|
- - success
|
|
|
- """
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- (0, TType.I64, 'success', None, None, ), # 0
|
|
|
- )
|
|
|
-
|
|
|
- def __init__(self, success=None,):
|
|
|
- self.success = success
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- if fid == 0:
|
|
|
- if ftype == TType.I64:
|
|
|
- self.success = iprot.readI64();
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getCounter_result')
|
|
|
- if self.success is not None:
|
|
|
- oprot.writeFieldBegin('success', TType.I64, 0)
|
|
|
- oprot.writeI64(self.success)
|
|
|
- oprot.writeFieldEnd()
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class setOption_args(object):
|
|
|
- """
|
|
|
- Attributes:
|
|
|
- - key
|
|
|
- - value
|
|
|
- """
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- None, # 0
|
|
|
- (1, TType.STRING, 'key', None, None, ), # 1
|
|
|
- (2, TType.STRING, 'value', None, None, ), # 2
|
|
|
- )
|
|
|
-
|
|
|
- def __init__(self, key=None, value=None,):
|
|
|
- self.key = key
|
|
|
- self.value = value
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- if fid == 1:
|
|
|
- if ftype == TType.STRING:
|
|
|
- self.key = iprot.readString();
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- elif fid == 2:
|
|
|
- if ftype == TType.STRING:
|
|
|
- self.value = iprot.readString();
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('setOption_args')
|
|
|
- if self.key is not None:
|
|
|
- oprot.writeFieldBegin('key', TType.STRING, 1)
|
|
|
- oprot.writeString(self.key)
|
|
|
- oprot.writeFieldEnd()
|
|
|
- if self.value is not None:
|
|
|
- oprot.writeFieldBegin('value', TType.STRING, 2)
|
|
|
- oprot.writeString(self.value)
|
|
|
- oprot.writeFieldEnd()
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class setOption_result(object):
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- )
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('setOption_result')
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getOption_args(object):
|
|
|
- """
|
|
|
- Attributes:
|
|
|
- - key
|
|
|
- """
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- None, # 0
|
|
|
- (1, TType.STRING, 'key', None, None, ), # 1
|
|
|
- )
|
|
|
-
|
|
|
- def __init__(self, key=None,):
|
|
|
- self.key = key
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- if fid == 1:
|
|
|
- if ftype == TType.STRING:
|
|
|
- self.key = iprot.readString();
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getOption_args')
|
|
|
- if self.key is not None:
|
|
|
- oprot.writeFieldBegin('key', TType.STRING, 1)
|
|
|
- oprot.writeString(self.key)
|
|
|
- oprot.writeFieldEnd()
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getOption_result(object):
|
|
|
- """
|
|
|
- Attributes:
|
|
|
- - success
|
|
|
- """
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- (0, TType.STRING, 'success', None, None, ), # 0
|
|
|
- )
|
|
|
-
|
|
|
- def __init__(self, success=None,):
|
|
|
- self.success = success
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- if fid == 0:
|
|
|
- if ftype == TType.STRING:
|
|
|
- self.success = iprot.readString();
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getOption_result')
|
|
|
- if self.success is not None:
|
|
|
- oprot.writeFieldBegin('success', TType.STRING, 0)
|
|
|
- oprot.writeString(self.success)
|
|
|
- oprot.writeFieldEnd()
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getOptions_args(object):
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- )
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getOptions_args')
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getOptions_result(object):
|
|
|
- """
|
|
|
- Attributes:
|
|
|
- - success
|
|
|
- """
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- (0, TType.MAP, 'success', (TType.STRING,None,TType.STRING,None), None, ), # 0
|
|
|
- )
|
|
|
-
|
|
|
- def __init__(self, success=None,):
|
|
|
- self.success = success
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- if fid == 0:
|
|
|
- if ftype == TType.MAP:
|
|
|
- self.success = {}
|
|
|
- (_ktype10, _vtype11, _size9 ) = iprot.readMapBegin()
|
|
|
- for _i13 in xrange(_size9):
|
|
|
- _key14 = iprot.readString();
|
|
|
- _val15 = iprot.readString();
|
|
|
- self.success[_key14] = _val15
|
|
|
- iprot.readMapEnd()
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getOptions_result')
|
|
|
- if self.success is not None:
|
|
|
- oprot.writeFieldBegin('success', TType.MAP, 0)
|
|
|
- oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success))
|
|
|
- for kiter16,viter17 in self.success.items():
|
|
|
- oprot.writeString(kiter16)
|
|
|
- oprot.writeString(viter17)
|
|
|
- oprot.writeMapEnd()
|
|
|
- oprot.writeFieldEnd()
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getCpuProfile_args(object):
|
|
|
- """
|
|
|
- Attributes:
|
|
|
- - profileDurationInSec
|
|
|
- """
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- None, # 0
|
|
|
- (1, TType.I32, 'profileDurationInSec', None, None, ), # 1
|
|
|
- )
|
|
|
-
|
|
|
- def __init__(self, profileDurationInSec=None,):
|
|
|
- self.profileDurationInSec = profileDurationInSec
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- if fid == 1:
|
|
|
- if ftype == TType.I32:
|
|
|
- self.profileDurationInSec = iprot.readI32();
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getCpuProfile_args')
|
|
|
- if self.profileDurationInSec is not None:
|
|
|
- oprot.writeFieldBegin('profileDurationInSec', TType.I32, 1)
|
|
|
- oprot.writeI32(self.profileDurationInSec)
|
|
|
- oprot.writeFieldEnd()
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class getCpuProfile_result(object):
|
|
|
- """
|
|
|
- Attributes:
|
|
|
- - success
|
|
|
- """
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- (0, TType.STRING, 'success', None, None, ), # 0
|
|
|
- )
|
|
|
-
|
|
|
- def __init__(self, success=None,):
|
|
|
- self.success = success
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- if fid == 0:
|
|
|
- if ftype == TType.STRING:
|
|
|
- self.success = iprot.readString();
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('getCpuProfile_result')
|
|
|
- if self.success is not None:
|
|
|
- oprot.writeFieldBegin('success', TType.STRING, 0)
|
|
|
- oprot.writeString(self.success)
|
|
|
- oprot.writeFieldEnd()
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class aliveSince_args(object):
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- )
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('aliveSince_args')
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class aliveSince_result(object):
|
|
|
- """
|
|
|
- Attributes:
|
|
|
- - success
|
|
|
- """
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- (0, TType.I64, 'success', None, None, ), # 0
|
|
|
- )
|
|
|
-
|
|
|
- def __init__(self, success=None,):
|
|
|
- self.success = success
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- if fid == 0:
|
|
|
- if ftype == TType.I64:
|
|
|
- self.success = iprot.readI64();
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('aliveSince_result')
|
|
|
- if self.success is not None:
|
|
|
- oprot.writeFieldBegin('success', TType.I64, 0)
|
|
|
- oprot.writeI64(self.success)
|
|
|
- oprot.writeFieldEnd()
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class reinitialize_args(object):
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- )
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('reinitialize_args')
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|
|
|
-
|
|
|
-class shutdown_args(object):
|
|
|
-
|
|
|
- thrift_spec = (
|
|
|
- )
|
|
|
-
|
|
|
- def read(self, iprot):
|
|
|
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
|
|
|
- return
|
|
|
- iprot.readStructBegin()
|
|
|
- while True:
|
|
|
- (fname, ftype, fid) = iprot.readFieldBegin()
|
|
|
- if ftype == TType.STOP:
|
|
|
- break
|
|
|
- else:
|
|
|
- iprot.skip(ftype)
|
|
|
- iprot.readFieldEnd()
|
|
|
- iprot.readStructEnd()
|
|
|
-
|
|
|
- def write(self, oprot):
|
|
|
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
|
|
|
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
|
|
|
- return
|
|
|
- oprot.writeStructBegin('shutdown_args')
|
|
|
- oprot.writeFieldStop()
|
|
|
- oprot.writeStructEnd()
|
|
|
-
|
|
|
- def validate(self):
|
|
|
- return
|
|
|
-
|
|
|
-
|
|
|
- def __repr__(self):
|
|
|
- L = ['%s=%r' % (key, value)
|
|
|
- for key, value in self.__dict__.iteritems()]
|
|
|
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
|
|
|
-
|
|
|
- def __eq__(self, other):
|
|
|
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
|
|
|
-
|
|
|
- def __ne__(self, other):
|
|
|
- return not (self == other)
|