362 lines
10 KiB
Python
362 lines
10 KiB
Python
#
|
|
# Autogenerated by Thrift Compiler (0.8.0)
|
|
#
|
|
# 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
|
|
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):
|
|
def ping(self, ):
|
|
pass
|
|
|
|
def sayHello(self, msg):
|
|
"""
|
|
Parameters:
|
|
- msg
|
|
"""
|
|
pass
|
|
|
|
|
|
class Client(Iface):
|
|
def __init__(self, iprot, oprot=None):
|
|
self._iprot = self._oprot = iprot
|
|
if oprot is not None:
|
|
self._oprot = oprot
|
|
self._seqid = 0
|
|
|
|
def ping(self, ):
|
|
self.send_ping()
|
|
return self.recv_ping()
|
|
|
|
def send_ping(self, ):
|
|
self._oprot.writeMessageBegin('ping', TMessageType.CALL, self._seqid)
|
|
args = ping_args()
|
|
args.write(self._oprot)
|
|
self._oprot.writeMessageEnd()
|
|
self._oprot.trans.flush()
|
|
|
|
def recv_ping(self, ):
|
|
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
|
if mtype == TMessageType.EXCEPTION:
|
|
x = TApplicationException()
|
|
x.read(self._iprot)
|
|
self._iprot.readMessageEnd()
|
|
raise x
|
|
result = ping_result()
|
|
result.read(self._iprot)
|
|
self._iprot.readMessageEnd()
|
|
if result.success is not None:
|
|
return result.success
|
|
raise TApplicationException(TApplicationException.MISSING_RESULT, "ping failed: unknown result");
|
|
|
|
def sayHello(self, msg):
|
|
"""
|
|
Parameters:
|
|
- msg
|
|
"""
|
|
self.send_sayHello(msg)
|
|
return self.recv_sayHello()
|
|
|
|
def send_sayHello(self, msg):
|
|
self._oprot.writeMessageBegin('sayHello', TMessageType.CALL, self._seqid)
|
|
args = sayHello_args()
|
|
args.msg = msg
|
|
args.write(self._oprot)
|
|
self._oprot.writeMessageEnd()
|
|
self._oprot.trans.flush()
|
|
|
|
def recv_sayHello(self, ):
|
|
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
|
|
if mtype == TMessageType.EXCEPTION:
|
|
x = TApplicationException()
|
|
x.read(self._iprot)
|
|
self._iprot.readMessageEnd()
|
|
raise x
|
|
result = sayHello_result()
|
|
result.read(self._iprot)
|
|
self._iprot.readMessageEnd()
|
|
if result.success is not None:
|
|
return result.success
|
|
raise TApplicationException(TApplicationException.MISSING_RESULT, "sayHello failed: unknown result");
|
|
|
|
|
|
class Processor(Iface, TProcessor):
|
|
def __init__(self, handler):
|
|
self._handler = handler
|
|
self._processMap = {}
|
|
self._processMap["ping"] = Processor.process_ping
|
|
self._processMap["sayHello"] = Processor.process_sayHello
|
|
|
|
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_ping(self, seqid, iprot, oprot):
|
|
args = ping_args()
|
|
args.read(iprot)
|
|
iprot.readMessageEnd()
|
|
result = ping_result()
|
|
result.success = self._handler.ping()
|
|
oprot.writeMessageBegin("ping", TMessageType.REPLY, seqid)
|
|
result.write(oprot)
|
|
oprot.writeMessageEnd()
|
|
oprot.trans.flush()
|
|
|
|
def process_sayHello(self, seqid, iprot, oprot):
|
|
args = sayHello_args()
|
|
args.read(iprot)
|
|
iprot.readMessageEnd()
|
|
result = sayHello_result()
|
|
result.success = self._handler.sayHello(args.msg)
|
|
oprot.writeMessageBegin("sayHello", TMessageType.REPLY, seqid)
|
|
result.write(oprot)
|
|
oprot.writeMessageEnd()
|
|
oprot.trans.flush()
|
|
|
|
|
|
# HELPER FUNCTIONS AND STRUCTURES
|
|
|
|
class ping_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('ping_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 ping_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('ping_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 sayHello_args(object):
|
|
"""
|
|
Attributes:
|
|
- msg
|
|
"""
|
|
|
|
thrift_spec = (
|
|
None, # 0
|
|
(1, TType.STRUCT, 'msg', (Message, Message.thrift_spec), None, ), # 1
|
|
)
|
|
|
|
def __init__(self, msg=None,):
|
|
self.msg = msg
|
|
|
|
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.STRUCT:
|
|
self.msg = Message()
|
|
self.msg.read(iprot)
|
|
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('sayHello_args')
|
|
if self.msg is not None:
|
|
oprot.writeFieldBegin('msg', TType.STRUCT, 1)
|
|
self.msg.write(oprot)
|
|
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 sayHello_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('sayHello_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)
|