# Licensed to the Apache Software Foundation (ASF) under one # or more contributor license agreements. See the NOTICE file # distributed with this work for additional information # regarding copyright ownership. The ASF licenses this file # to you under the Apache License, Version 2.0 (the # "License"); you may not use this file except in compliance # with the License. You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, # software distributed under the License is distributed on an # "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY # KIND, either express or implied. See the License for the # specific language governing permissions and limitations # under the License. # # Autogenerated by Thrift Compiler (0.16.0) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # # options string: py # import logging import sys from thrift.Thrift import ( TApplicationException, TMessageType, TProcessor, TType, ) from thrift.transport import TTransport from thrift.TRecursive import fix_spec from .ttypes import * all_structs = [] class Iface: """ 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): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(iprot) iprot.readMessageEnd() raise x result = getName_result() result.read(iprot) 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): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(iprot) iprot.readMessageEnd() raise x result = getVersion_result() result.read(iprot) 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): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(iprot) iprot.readMessageEnd() raise x result = getStatus_result() result.read(iprot) 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): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(iprot) iprot.readMessageEnd() raise x result = getStatusDetails_result() result.read(iprot) 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): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(iprot) iprot.readMessageEnd() raise x result = getCounters_result() result.read(iprot) 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): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(iprot) iprot.readMessageEnd() raise x result = getCounter_result() result.read(iprot) 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): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(iprot) iprot.readMessageEnd() raise x result = setOption_result() result.read(iprot) 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): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(iprot) iprot.readMessageEnd() raise x result = getOption_result() result.read(iprot) 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): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(iprot) iprot.readMessageEnd() raise x result = getOptions_result() result.read(iprot) 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): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(iprot) iprot.readMessageEnd() raise x result = getCpuProfile_result() result.read(iprot) 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): iprot = self._iprot (fname, mtype, rseqid) = iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(iprot) iprot.readMessageEnd() raise x result = aliveSince_result() result.read(iprot) 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.ONEWAY, 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.ONEWAY, 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 self._on_message_begin = None def on_message_begin(self, func): self._on_message_begin = func def process(self, iprot, oprot): (name, type, seqid) = iprot.readMessageBegin() if self._on_message_begin: self._on_message_begin(name, type, seqid) 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() try: result.success = self._handler.getName() msg_type = TMessageType.REPLY except TTransport.TTransportException: raise except TApplicationException as ex: logging.exception("TApplication exception in handler") msg_type = TMessageType.EXCEPTION result = ex except Exception: logging.exception("Unexpected exception in handler") msg_type = TMessageType.EXCEPTION result = TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error") oprot.writeMessageBegin("getName", msg_type, 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() try: result.success = self._handler.getVersion() msg_type = TMessageType.REPLY except TTransport.TTransportException: raise except TApplicationException as ex: logging.exception("TApplication exception in handler") msg_type = TMessageType.EXCEPTION result = ex except Exception: logging.exception("Unexpected exception in handler") msg_type = TMessageType.EXCEPTION result = TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error") oprot.writeMessageBegin("getVersion", msg_type, 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() try: result.success = self._handler.getStatus() msg_type = TMessageType.REPLY except TTransport.TTransportException: raise except TApplicationException as ex: logging.exception("TApplication exception in handler") msg_type = TMessageType.EXCEPTION result = ex except Exception: logging.exception("Unexpected exception in handler") msg_type = TMessageType.EXCEPTION result = TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error") oprot.writeMessageBegin("getStatus", msg_type, 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() try: result.success = self._handler.getStatusDetails() msg_type = TMessageType.REPLY except TTransport.TTransportException: raise except TApplicationException as ex: logging.exception("TApplication exception in handler") msg_type = TMessageType.EXCEPTION result = ex except Exception: logging.exception("Unexpected exception in handler") msg_type = TMessageType.EXCEPTION result = TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error") oprot.writeMessageBegin("getStatusDetails", msg_type, 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() try: result.success = self._handler.getCounters() msg_type = TMessageType.REPLY except TTransport.TTransportException: raise except TApplicationException as ex: logging.exception("TApplication exception in handler") msg_type = TMessageType.EXCEPTION result = ex except Exception: logging.exception("Unexpected exception in handler") msg_type = TMessageType.EXCEPTION result = TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error") oprot.writeMessageBegin("getCounters", msg_type, 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() try: result.success = self._handler.getCounter(args.key) msg_type = TMessageType.REPLY except TTransport.TTransportException: raise except TApplicationException as ex: logging.exception("TApplication exception in handler") msg_type = TMessageType.EXCEPTION result = ex except Exception: logging.exception("Unexpected exception in handler") msg_type = TMessageType.EXCEPTION result = TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error") oprot.writeMessageBegin("getCounter", msg_type, 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() try: self._handler.setOption(args.key, args.value) msg_type = TMessageType.REPLY except TTransport.TTransportException: raise except TApplicationException as ex: logging.exception("TApplication exception in handler") msg_type = TMessageType.EXCEPTION result = ex except Exception: logging.exception("Unexpected exception in handler") msg_type = TMessageType.EXCEPTION result = TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error") oprot.writeMessageBegin("setOption", msg_type, 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() try: result.success = self._handler.getOption(args.key) msg_type = TMessageType.REPLY except TTransport.TTransportException: raise except TApplicationException as ex: logging.exception("TApplication exception in handler") msg_type = TMessageType.EXCEPTION result = ex except Exception: logging.exception("Unexpected exception in handler") msg_type = TMessageType.EXCEPTION result = TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error") oprot.writeMessageBegin("getOption", msg_type, 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() try: result.success = self._handler.getOptions() msg_type = TMessageType.REPLY except TTransport.TTransportException: raise except TApplicationException as ex: logging.exception("TApplication exception in handler") msg_type = TMessageType.EXCEPTION result = ex except Exception: logging.exception("Unexpected exception in handler") msg_type = TMessageType.EXCEPTION result = TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error") oprot.writeMessageBegin("getOptions", msg_type, 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() try: result.success = self._handler.getCpuProfile(args.profileDurationInSec) msg_type = TMessageType.REPLY except TTransport.TTransportException: raise except TApplicationException as ex: logging.exception("TApplication exception in handler") msg_type = TMessageType.EXCEPTION result = ex except Exception: logging.exception("Unexpected exception in handler") msg_type = TMessageType.EXCEPTION result = TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error") oprot.writeMessageBegin("getCpuProfile", msg_type, 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() try: result.success = self._handler.aliveSince() msg_type = TMessageType.REPLY except TTransport.TTransportException: raise except TApplicationException as ex: logging.exception("TApplication exception in handler") msg_type = TMessageType.EXCEPTION result = ex except Exception: logging.exception("Unexpected exception in handler") msg_type = TMessageType.EXCEPTION result = TApplicationException(TApplicationException.INTERNAL_ERROR, "Internal error") oprot.writeMessageBegin("aliveSince", msg_type, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() def process_reinitialize(self, seqid, iprot, oprot): args = reinitialize_args() args.read(iprot) iprot.readMessageEnd() try: self._handler.reinitialize() except TTransport.TTransportException: raise except Exception: logging.exception("Exception in oneway handler") def process_shutdown(self, seqid, iprot, oprot): args = shutdown_args() args.read(iprot) iprot.readMessageEnd() try: self._handler.shutdown() except TTransport.TTransportException: raise except Exception: logging.exception("Exception in oneway handler") # HELPER FUNCTIONS AND STRUCTURES class getName_args: def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec])) return oprot.writeStructBegin("getName_args") oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getName_args) getName_args.thrift_spec = () class getName_result: """ Attributes: - success """ def __init__( self, success=None, ): self.success = success def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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().decode("utf-8", errors="replace") if sys.version_info[0] == 2 else iprot.readString() ) else: iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() iprot.readStructEnd() def write(self, oprot): if oprot._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(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.encode("utf-8") if sys.version_info[0] == 2 else self.success) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getName_result) getName_result.thrift_spec = ( ( 0, TType.STRING, "success", "UTF8", None, ), # 0 ) class getVersion_args: def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec])) return oprot.writeStructBegin("getVersion_args") oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getVersion_args) getVersion_args.thrift_spec = () class getVersion_result: """ Attributes: - success """ def __init__( self, success=None, ): self.success = success def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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().decode("utf-8", errors="replace") if sys.version_info[0] == 2 else iprot.readString() ) else: iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() iprot.readStructEnd() def write(self, oprot): if oprot._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(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.encode("utf-8") if sys.version_info[0] == 2 else self.success) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getVersion_result) getVersion_result.thrift_spec = ( ( 0, TType.STRING, "success", "UTF8", None, ), # 0 ) class getStatus_args: def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec])) return oprot.writeStructBegin("getStatus_args") oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getStatus_args) getStatus_args.thrift_spec = () class getStatus_result: """ Attributes: - success """ def __init__( self, success=None, ): self.success = success def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(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 = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getStatus_result) getStatus_result.thrift_spec = ( ( 0, TType.I32, "success", None, None, ), # 0 ) class getStatusDetails_args: def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec])) return oprot.writeStructBegin("getStatusDetails_args") oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getStatusDetails_args) getStatusDetails_args.thrift_spec = () class getStatusDetails_result: """ Attributes: - success """ def __init__( self, success=None, ): self.success = success def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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().decode("utf-8", errors="replace") if sys.version_info[0] == 2 else iprot.readString() ) else: iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() iprot.readStructEnd() def write(self, oprot): if oprot._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(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.encode("utf-8") if sys.version_info[0] == 2 else self.success) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getStatusDetails_result) getStatusDetails_result.thrift_spec = ( ( 0, TType.STRING, "success", "UTF8", None, ), # 0 ) class getCounters_args: def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec])) return oprot.writeStructBegin("getCounters_args") oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getCounters_args) getCounters_args.thrift_spec = () class getCounters_result: """ Attributes: - success """ def __init__( self, success=None, ): self.success = success def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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 range(_size0): _key5 = ( iprot.readString().decode("utf-8", errors="replace") if sys.version_info[0] == 2 else 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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(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.encode("utf-8") if sys.version_info[0] == 2 else kiter7) oprot.writeI64(viter8) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getCounters_result) getCounters_result.thrift_spec = ( ( 0, TType.MAP, "success", (TType.STRING, "UTF8", TType.I64, None, False), None, ), # 0 ) class getCounter_args: """ Attributes: - key """ def __init__( self, key=None, ): self.key = key def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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().decode("utf-8", errors="replace") if sys.version_info[0] == 2 else iprot.readString() ) else: iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() iprot.readStructEnd() def write(self, oprot): if oprot._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(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.encode("utf-8") if sys.version_info[0] == 2 else self.key) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getCounter_args) getCounter_args.thrift_spec = ( None, # 0 ( 1, TType.STRING, "key", "UTF8", None, ), # 1 ) class getCounter_result: """ Attributes: - success """ def __init__( self, success=None, ): self.success = success def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(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 = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getCounter_result) getCounter_result.thrift_spec = ( ( 0, TType.I64, "success", None, None, ), # 0 ) class setOption_args: """ Attributes: - key - value """ def __init__( self, key=None, value=None, ): self.key = key self.value = value def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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().decode("utf-8", errors="replace") if sys.version_info[0] == 2 else iprot.readString() ) else: iprot.skip(ftype) elif fid == 2: if ftype == TType.STRING: self.value = ( iprot.readString().decode("utf-8", errors="replace") if sys.version_info[0] == 2 else iprot.readString() ) else: iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() iprot.readStructEnd() def write(self, oprot): if oprot._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(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.encode("utf-8") if sys.version_info[0] == 2 else self.key) oprot.writeFieldEnd() if self.value is not None: oprot.writeFieldBegin("value", TType.STRING, 2) oprot.writeString(self.value.encode("utf-8") if sys.version_info[0] == 2 else self.value) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(setOption_args) setOption_args.thrift_spec = ( None, # 0 ( 1, TType.STRING, "key", "UTF8", None, ), # 1 ( 2, TType.STRING, "value", "UTF8", None, ), # 2 ) class setOption_result: def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec])) return oprot.writeStructBegin("setOption_result") oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(setOption_result) setOption_result.thrift_spec = () class getOption_args: """ Attributes: - key """ def __init__( self, key=None, ): self.key = key def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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().decode("utf-8", errors="replace") if sys.version_info[0] == 2 else iprot.readString() ) else: iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() iprot.readStructEnd() def write(self, oprot): if oprot._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(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.encode("utf-8") if sys.version_info[0] == 2 else self.key) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getOption_args) getOption_args.thrift_spec = ( None, # 0 ( 1, TType.STRING, "key", "UTF8", None, ), # 1 ) class getOption_result: """ Attributes: - success """ def __init__( self, success=None, ): self.success = success def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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().decode("utf-8", errors="replace") if sys.version_info[0] == 2 else iprot.readString() ) else: iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() iprot.readStructEnd() def write(self, oprot): if oprot._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(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.encode("utf-8") if sys.version_info[0] == 2 else self.success) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getOption_result) getOption_result.thrift_spec = ( ( 0, TType.STRING, "success", "UTF8", None, ), # 0 ) class getOptions_args: def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec])) return oprot.writeStructBegin("getOptions_args") oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getOptions_args) getOptions_args.thrift_spec = () class getOptions_result: """ Attributes: - success """ def __init__( self, success=None, ): self.success = success def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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 range(_size9): _key14 = ( iprot.readString().decode("utf-8", errors="replace") if sys.version_info[0] == 2 else iprot.readString() ) _val15 = ( iprot.readString().decode("utf-8", errors="replace") if sys.version_info[0] == 2 else 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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(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.encode("utf-8") if sys.version_info[0] == 2 else kiter16) oprot.writeString(viter17.encode("utf-8") if sys.version_info[0] == 2 else viter17) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getOptions_result) getOptions_result.thrift_spec = ( ( 0, TType.MAP, "success", (TType.STRING, "UTF8", TType.STRING, "UTF8", False), None, ), # 0 ) class getCpuProfile_args: """ Attributes: - profileDurationInSec """ def __init__( self, profileDurationInSec=None, ): self.profileDurationInSec = profileDurationInSec def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(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 = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getCpuProfile_args) getCpuProfile_args.thrift_spec = ( None, # 0 ( 1, TType.I32, "profileDurationInSec", None, None, ), # 1 ) class getCpuProfile_result: """ Attributes: - success """ def __init__( self, success=None, ): self.success = success def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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().decode("utf-8", errors="replace") if sys.version_info[0] == 2 else iprot.readString() ) else: iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() iprot.readStructEnd() def write(self, oprot): if oprot._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(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.encode("utf-8") if sys.version_info[0] == 2 else self.success) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(getCpuProfile_result) getCpuProfile_result.thrift_spec = ( ( 0, TType.STRING, "success", "UTF8", None, ), # 0 ) class aliveSince_args: def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec])) return oprot.writeStructBegin("aliveSince_args") oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(aliveSince_args) aliveSince_args.thrift_spec = () class aliveSince_result: """ Attributes: - success """ def __init__( self, success=None, ): self.success = success def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(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 = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(aliveSince_result) aliveSince_result.thrift_spec = ( ( 0, TType.I64, "success", None, None, ), # 0 ) class reinitialize_args: def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec])) return oprot.writeStructBegin("reinitialize_args") oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(reinitialize_args) reinitialize_args.thrift_spec = () class shutdown_args: def read(self, iprot): if ( iprot._fast_decode is not None and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None ): iprot._fast_decode(self, iprot, [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._fast_encode is not None and self.thrift_spec is not None: oprot.trans.write(oprot._fast_encode(self, [self.__class__, self.thrift_spec])) return oprot.writeStructBegin("shutdown_args") oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): return def __repr__(self): L = ["{}={!r}".format(key, value) for key, value in self.__dict__.items()] return "{}({})".format(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) all_structs.append(shutdown_args) shutdown_args.thrift_spec = () fix_spec(all_structs) del all_structs