http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/ThriftSecureEventTransmissionService.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/ThriftSecureEventTransmissionService.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/ThriftSecureEventTransmissionService.py new file mode 100644 index 0000000..b8c13c1 --- /dev/null +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/ThriftSecureEventTransmissionService.py @@ -0,0 +1,1495 @@ +# +# Autogenerated by Thrift Compiler (0.9.1) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py +# + +from ttypes import * +from ...thrift.Thrift import TProcessor +from ...thrift.transport import TTransport +from ..Exception import ttypes +from .. import Data + +try: + from ...thrift.protocol import fastbinary +except: + fastbinary = None + + +class Iface: + def connect(self, userName, password): + """ + Parameters: + - userName + - password + """ + pass + + def disconnect(self, sessionId): + """ + Parameters: + - sessionId + """ + pass + + def defineStream(self, sessionId, streamDefinition): + """ + Parameters: + - sessionId + - streamDefinition + """ + pass + + def findStreamId(self, sessionId, streamName, streamVersion): + """ + Parameters: + - sessionId + - streamName + - streamVersion + """ + pass + + def publish(self, eventBundle): + """ + Parameters: + - eventBundle + """ + pass + + def deleteStreamById(self, sessionId, streamId): + """ + Parameters: + - sessionId + - streamId + """ + pass + + def deleteStreamByNameVersion(self, sessionId, streamName, streamVersion): + """ + Parameters: + - sessionId + - streamName + - streamVersion + """ + 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 connect(self, userName, password): + """ + Parameters: + - userName + - password + """ + self.send_connect(userName, password) + return self.recv_connect() + + def send_connect(self, userName, password): + self._oprot.writeMessageBegin('connect', TMessageType.CALL, self._seqid) + args = connect_args() + args.userName = userName + args.password = password + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_connect(self): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = connect_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ae is not None: + raise result.ae + raise TApplicationException(TApplicationException.MISSING_RESULT, "connect failed: unknown result"); + + def disconnect(self, sessionId): + """ + Parameters: + - sessionId + """ + self.send_disconnect(sessionId) + self.recv_disconnect() + + def send_disconnect(self, sessionId): + self._oprot.writeMessageBegin('disconnect', TMessageType.CALL, self._seqid) + args = disconnect_args() + args.sessionId = sessionId + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_disconnect(self): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = disconnect_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + return + + def defineStream(self, sessionId, streamDefinition): + """ + Parameters: + - sessionId + - streamDefinition + """ + self.send_defineStream(sessionId, streamDefinition) + return self.recv_defineStream() + + def send_defineStream(self, sessionId, streamDefinition): + self._oprot.writeMessageBegin('defineStream', TMessageType.CALL, self._seqid) + args = defineStream_args() + args.sessionId = sessionId + args.streamDefinition = streamDefinition + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_defineStream(self): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = defineStream_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.ade is not None: + raise result.ade + if result.mtd is not None: + raise result.mtd + if result.tde is not None: + raise result.tde + if result.se is not None: + raise result.se + raise TApplicationException(TApplicationException.MISSING_RESULT, "defineStream failed: unknown result"); + + def findStreamId(self, sessionId, streamName, streamVersion): + """ + Parameters: + - sessionId + - streamName + - streamVersion + """ + self.send_findStreamId(sessionId, streamName, streamVersion) + return self.recv_findStreamId() + + def send_findStreamId(self, sessionId, streamName, streamVersion): + self._oprot.writeMessageBegin('findStreamId', TMessageType.CALL, self._seqid) + args = findStreamId_args() + args.sessionId = sessionId + args.streamName = streamName + args.streamVersion = streamVersion + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_findStreamId(self): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = findStreamId_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.tnde is not None: + raise result.tnde + if result.se is not None: + raise result.se + raise TApplicationException(TApplicationException.MISSING_RESULT, "findStreamId failed: unknown result"); + + def publish(self, eventBundle): + """ + Parameters: + - eventBundle + """ + self.send_publish(eventBundle) + self.recv_publish() + + def send_publish(self, eventBundle): + self._oprot.writeMessageBegin('publish', TMessageType.CALL, self._seqid) + args = publish_args() + args.eventBundle = eventBundle + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_publish(self): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = publish_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.ue is not None: + raise result.ue + if result.se is not None: + raise result.se + return + + def deleteStreamById(self, sessionId, streamId): + """ + Parameters: + - sessionId + - streamId + """ + self.send_deleteStreamById(sessionId, streamId) + return self.recv_deleteStreamById() + + def send_deleteStreamById(self, sessionId, streamId): + self._oprot.writeMessageBegin('deleteStreamById', TMessageType.CALL, self._seqid) + args = deleteStreamById_args() + args.sessionId = sessionId + args.streamId = streamId + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_deleteStreamById(self): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = deleteStreamById_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.se is not None: + raise result.se + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteStreamById failed: unknown result"); + + def deleteStreamByNameVersion(self, sessionId, streamName, streamVersion): + """ + Parameters: + - sessionId + - streamName + - streamVersion + """ + self.send_deleteStreamByNameVersion(sessionId, streamName, streamVersion) + return self.recv_deleteStreamByNameVersion() + + def send_deleteStreamByNameVersion(self, sessionId, streamName, streamVersion): + self._oprot.writeMessageBegin('deleteStreamByNameVersion', TMessageType.CALL, self._seqid) + args = deleteStreamByNameVersion_args() + args.sessionId = sessionId + args.streamName = streamName + args.streamVersion = streamVersion + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_deleteStreamByNameVersion(self): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = deleteStreamByNameVersion_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.se is not None: + raise result.se + raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteStreamByNameVersion failed: unknown result"); + + +class Processor(Iface, TProcessor): + def __init__(self, handler): + self._handler = handler + self._processMap = {} + self._processMap["connect"] = Processor.process_connect + self._processMap["disconnect"] = Processor.process_disconnect + self._processMap["defineStream"] = Processor.process_defineStream + self._processMap["findStreamId"] = Processor.process_findStreamId + self._processMap["publish"] = Processor.process_publish + self._processMap["deleteStreamById"] = Processor.process_deleteStreamById + self._processMap["deleteStreamByNameVersion"] = Processor.process_deleteStreamByNameVersion + + 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_connect(self, seqid, iprot, oprot): + args = connect_args() + args.read(iprot) + iprot.readMessageEnd() + result = connect_result() + try: + result.success = self._handler.connect(args.userName, args.password) + except ttypes.ThriftAuthenticationException, ae: + result.ae = ae + oprot.writeMessageBegin("connect", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_disconnect(self, seqid, iprot, oprot): + args = disconnect_args() + args.read(iprot) + iprot.readMessageEnd() + result = disconnect_result() + self._handler.disconnect(args.sessionId) + oprot.writeMessageBegin("disconnect", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_defineStream(self, seqid, iprot, oprot): + args = defineStream_args() + args.read(iprot) + iprot.readMessageEnd() + result = defineStream_result() + try: + result.success = self._handler.defineStream(args.sessionId, args.streamDefinition) + except ttypes.ThriftDifferentStreamDefinitionAlreadyDefinedException, ade: + result.ade = ade + except ttypes.ThriftMalformedStreamDefinitionException, mtd: + result.mtd = mtd + except ttypes.ThriftStreamDefinitionException, tde: + result.tde = tde + except ttypes.ThriftSessionExpiredException, se: + result.se = se + oprot.writeMessageBegin("defineStream", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_findStreamId(self, seqid, iprot, oprot): + args = findStreamId_args() + args.read(iprot) + iprot.readMessageEnd() + result = findStreamId_result() + try: + result.success = self._handler.findStreamId(args.sessionId, args.streamName, args.streamVersion) + except ttypes.ThriftNoStreamDefinitionExistException, tnde: + result.tnde = tnde + except ttypes.ThriftSessionExpiredException, se: + result.se = se + oprot.writeMessageBegin("findStreamId", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_publish(self, seqid, iprot, oprot): + args = publish_args() + args.read(iprot) + iprot.readMessageEnd() + result = publish_result() + try: + self._handler.publish(args.eventBundle) + except ttypes.ThriftUndefinedEventTypeException, ue: + result.ue = ue + except ttypes.ThriftSessionExpiredException, se: + result.se = se + oprot.writeMessageBegin("publish", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_deleteStreamById(self, seqid, iprot, oprot): + args = deleteStreamById_args() + args.read(iprot) + iprot.readMessageEnd() + result = deleteStreamById_result() + try: + result.success = self._handler.deleteStreamById(args.sessionId, args.streamId) + except ttypes.ThriftSessionExpiredException, se: + result.se = se + oprot.writeMessageBegin("deleteStreamById", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_deleteStreamByNameVersion(self, seqid, iprot, oprot): + args = deleteStreamByNameVersion_args() + args.read(iprot) + iprot.readMessageEnd() + result = deleteStreamByNameVersion_result() + try: + result.success = self._handler.deleteStreamByNameVersion(args.sessionId, args.streamName, args.streamVersion) + except ttypes.ThriftSessionExpiredException, se: + result.se = se + oprot.writeMessageBegin("deleteStreamByNameVersion", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + +# HELPER FUNCTIONS AND STRUCTURES + +class connect_args: + """ + Attributes: + - userName + - password + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'userName', None, None, ), # 1 + (2, TType.STRING, 'password', None, None, ), # 2 + ) + + def __init__(self, userName=None, password=None,): + self.userName = userName + self.password = password + + 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.userName = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.password = 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('connect_args') + if self.userName is not None: + oprot.writeFieldBegin('userName', TType.STRING, 1) + oprot.writeString(self.userName) + oprot.writeFieldEnd() + if self.password is not None: + oprot.writeFieldBegin('password', TType.STRING, 2) + oprot.writeString(self.password) + 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 connect_result: + """ + Attributes: + - success + - ae + """ + + thrift_spec = ( + (0, TType.STRING, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'ae', (ttypes.ThriftAuthenticationException, ttypes.ThriftAuthenticationException.thrift_spec), None, ), # 1 + ) + + def __init__(self, success=None, ae=None,): + self.success = success + self.ae = ae + + 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) + elif fid == 1: + if ftype == TType.STRUCT: + self.ae = ttypes.ThriftAuthenticationException() + self.ae.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('connect_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.STRING, 0) + oprot.writeString(self.success) + oprot.writeFieldEnd() + if self.ae is not None: + oprot.writeFieldBegin('ae', TType.STRUCT, 1) + self.ae.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 disconnect_args: + """ + Attributes: + - sessionId + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'sessionId', None, None, ), # 1 + ) + + def __init__(self, sessionId=None,): + self.sessionId = sessionId + + 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.sessionId = 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('disconnect_args') + if self.sessionId is not None: + oprot.writeFieldBegin('sessionId', TType.STRING, 1) + oprot.writeString(self.sessionId) + 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 disconnect_result: + + 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('disconnect_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 defineStream_args: + """ + Attributes: + - sessionId + - streamDefinition + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'sessionId', None, None, ), # 1 + (2, TType.STRING, 'streamDefinition', None, None, ), # 2 + ) + + def __init__(self, sessionId=None, streamDefinition=None,): + self.sessionId = sessionId + self.streamDefinition = streamDefinition + + 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.sessionId = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.streamDefinition = 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('defineStream_args') + if self.sessionId is not None: + oprot.writeFieldBegin('sessionId', TType.STRING, 1) + oprot.writeString(self.sessionId) + oprot.writeFieldEnd() + if self.streamDefinition is not None: + oprot.writeFieldBegin('streamDefinition', TType.STRING, 2) + oprot.writeString(self.streamDefinition) + 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 defineStream_result: + """ + Attributes: + - success + - ade + - mtd + - tde + - se + """ + + thrift_spec = ( + (0, TType.STRING, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'ade', (ttypes.ThriftDifferentStreamDefinitionAlreadyDefinedException, ttypes.ThriftDifferentStreamDefinitionAlreadyDefinedException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'mtd', (ttypes.ThriftMalformedStreamDefinitionException, ttypes.ThriftMalformedStreamDefinitionException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'tde', (ttypes.ThriftStreamDefinitionException, ttypes.ThriftStreamDefinitionException.thrift_spec), None, ), # 3 + (4, TType.STRUCT, 'se', (ttypes.ThriftSessionExpiredException, ttypes.ThriftSessionExpiredException.thrift_spec), None, ), # 4 + ) + + def __init__(self, success=None, ade=None, mtd=None, tde=None, se=None,): + self.success = success + self.ade = ade + self.mtd = mtd + self.tde = tde + self.se = se + + 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) + elif fid == 1: + if ftype == TType.STRUCT: + self.ade = ttypes.ThriftDifferentStreamDefinitionAlreadyDefinedException() + self.ade.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.mtd = ttypes.ThriftMalformedStreamDefinitionException() + self.mtd.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.tde = ttypes.ThriftStreamDefinitionException() + self.tde.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRUCT: + self.se = ttypes.ThriftSessionExpiredException() + self.se.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('defineStream_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.STRING, 0) + oprot.writeString(self.success) + oprot.writeFieldEnd() + if self.ade is not None: + oprot.writeFieldBegin('ade', TType.STRUCT, 1) + self.ade.write(oprot) + oprot.writeFieldEnd() + if self.mtd is not None: + oprot.writeFieldBegin('mtd', TType.STRUCT, 2) + self.mtd.write(oprot) + oprot.writeFieldEnd() + if self.tde is not None: + oprot.writeFieldBegin('tde', TType.STRUCT, 3) + self.tde.write(oprot) + oprot.writeFieldEnd() + if self.se is not None: + oprot.writeFieldBegin('se', TType.STRUCT, 4) + self.se.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 findStreamId_args: + """ + Attributes: + - sessionId + - streamName + - streamVersion + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'sessionId', None, None, ), # 1 + (2, TType.STRING, 'streamName', None, None, ), # 2 + (3, TType.STRING, 'streamVersion', None, None, ), # 3 + ) + + def __init__(self, sessionId=None, streamName=None, streamVersion=None,): + self.sessionId = sessionId + self.streamName = streamName + self.streamVersion = streamVersion + + 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.sessionId = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.streamName = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.streamVersion = 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('findStreamId_args') + if self.sessionId is not None: + oprot.writeFieldBegin('sessionId', TType.STRING, 1) + oprot.writeString(self.sessionId) + oprot.writeFieldEnd() + if self.streamName is not None: + oprot.writeFieldBegin('streamName', TType.STRING, 2) + oprot.writeString(self.streamName) + oprot.writeFieldEnd() + if self.streamVersion is not None: + oprot.writeFieldBegin('streamVersion', TType.STRING, 3) + oprot.writeString(self.streamVersion) + 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 findStreamId_result: + """ + Attributes: + - success + - tnde + - se + """ + + thrift_spec = ( + (0, TType.STRING, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'tnde', (ttypes.ThriftNoStreamDefinitionExistException, ttypes.ThriftNoStreamDefinitionExistException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'se', (ttypes.ThriftSessionExpiredException, ttypes.ThriftSessionExpiredException.thrift_spec), None, ), # 2 + ) + + def __init__(self, success=None, tnde=None, se=None,): + self.success = success + self.tnde = tnde + self.se = se + + 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) + elif fid == 1: + if ftype == TType.STRUCT: + self.tnde = ttypes.ThriftNoStreamDefinitionExistException() + self.tnde.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.se = ttypes.ThriftSessionExpiredException() + self.se.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('findStreamId_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.STRING, 0) + oprot.writeString(self.success) + oprot.writeFieldEnd() + if self.tnde is not None: + oprot.writeFieldBegin('tnde', TType.STRUCT, 1) + self.tnde.write(oprot) + oprot.writeFieldEnd() + if self.se is not None: + oprot.writeFieldBegin('se', TType.STRUCT, 2) + self.se.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 publish_args: + """ + Attributes: + - eventBundle + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'eventBundle', (Data.ttypes.ThriftEventBundle, Data.ttypes.ThriftEventBundle.thrift_spec), None, ), # 1 + ) + + def __init__(self, eventBundle=None,): + self.eventBundle = eventBundle + + 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.eventBundle = Data.ttypes.ThriftEventBundle() + self.eventBundle.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('publish_args') + if self.eventBundle is not None: + oprot.writeFieldBegin('eventBundle', TType.STRUCT, 1) + self.eventBundle.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 publish_result: + """ + Attributes: + - ue + - se + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'ue', (ttypes.ThriftUndefinedEventTypeException, ttypes.ThriftUndefinedEventTypeException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'se', (ttypes.ThriftSessionExpiredException, ttypes.ThriftSessionExpiredException.thrift_spec), None, ), # 2 + ) + + def __init__(self, ue=None, se=None,): + self.ue = ue + self.se = se + + 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.ue = ttypes.ThriftUndefinedEventTypeException() + self.ue.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.se = ttypes.ThriftSessionExpiredException() + self.se.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('publish_result') + if self.ue is not None: + oprot.writeFieldBegin('ue', TType.STRUCT, 1) + self.ue.write(oprot) + oprot.writeFieldEnd() + if self.se is not None: + oprot.writeFieldBegin('se', TType.STRUCT, 2) + self.se.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 deleteStreamById_args: + """ + Attributes: + - sessionId + - streamId + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'sessionId', None, None, ), # 1 + (2, TType.STRING, 'streamId', None, None, ), # 2 + ) + + def __init__(self, sessionId=None, streamId=None,): + self.sessionId = sessionId + self.streamId = streamId + + 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.sessionId = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.streamId = 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('deleteStreamById_args') + if self.sessionId is not None: + oprot.writeFieldBegin('sessionId', TType.STRING, 1) + oprot.writeString(self.sessionId) + oprot.writeFieldEnd() + if self.streamId is not None: + oprot.writeFieldBegin('streamId', TType.STRING, 2) + oprot.writeString(self.streamId) + 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 deleteStreamById_result: + """ + Attributes: + - success + - se + """ + + thrift_spec = ( + (0, TType.BOOL, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'se', (ttypes.ThriftSessionExpiredException, ttypes.ThriftSessionExpiredException.thrift_spec), None, ), # 1 + ) + + def __init__(self, success=None, se=None,): + self.success = success + self.se = se + + 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.BOOL: + self.success = iprot.readBool(); + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.se = ttypes.ThriftSessionExpiredException() + self.se.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('deleteStreamById_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.BOOL, 0) + oprot.writeBool(self.success) + oprot.writeFieldEnd() + if self.se is not None: + oprot.writeFieldBegin('se', TType.STRUCT, 1) + self.se.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 deleteStreamByNameVersion_args: + """ + Attributes: + - sessionId + - streamName + - streamVersion + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'sessionId', None, None, ), # 1 + (2, TType.STRING, 'streamName', None, None, ), # 2 + (3, TType.STRING, 'streamVersion', None, None, ), # 3 + ) + + def __init__(self, sessionId=None, streamName=None, streamVersion=None,): + self.sessionId = sessionId + self.streamName = streamName + self.streamVersion = streamVersion + + 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.sessionId = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.streamName = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRING: + self.streamVersion = 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('deleteStreamByNameVersion_args') + if self.sessionId is not None: + oprot.writeFieldBegin('sessionId', TType.STRING, 1) + oprot.writeString(self.sessionId) + oprot.writeFieldEnd() + if self.streamName is not None: + oprot.writeFieldBegin('streamName', TType.STRING, 2) + oprot.writeString(self.streamName) + oprot.writeFieldEnd() + if self.streamVersion is not None: + oprot.writeFieldBegin('streamVersion', TType.STRING, 3) + oprot.writeString(self.streamVersion) + 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 deleteStreamByNameVersion_result: + """ + Attributes: + - success + - se + """ + + thrift_spec = ( + (0, TType.BOOL, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'se', (ttypes.ThriftSessionExpiredException, ttypes.ThriftSessionExpiredException.thrift_spec), None, ), # 1 + ) + + def __init__(self, success=None, se=None,): + self.success = success + self.se = se + + 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.BOOL: + self.success = iprot.readBool(); + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.se = ttypes.ThriftSessionExpiredException() + self.se.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('deleteStreamByNameVersion_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.BOOL, 0) + oprot.writeBool(self.success) + oprot.writeFieldEnd() + if self.se is not None: + oprot.writeFieldBegin('se', TType.STRUCT, 1) + self.se.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)
http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/__init__.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/__init__.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/__init__.py new file mode 100644 index 0000000..c321ae1 --- /dev/null +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/__init__.py @@ -0,0 +1 @@ +__all__ = ['ttypes', 'constants', 'ThriftSecureEventTransmissionService'] http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/constants.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/constants.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/constants.py new file mode 100644 index 0000000..36943ba --- /dev/null +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/constants.py @@ -0,0 +1,8 @@ +# +# Autogenerated by Thrift Compiler (0.9.1) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py +# + http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/ttypes.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/ttypes.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/ttypes.py new file mode 100644 index 0000000..37ac241 --- /dev/null +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/ThriftSecureEventTransmissionService/ttypes.py @@ -0,0 +1,21 @@ +# +# Autogenerated by Thrift Compiler (0.9.1) +# +# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING +# +# options string: py +# + +from ...thrift.Thrift import TType, TMessageType, TException, TApplicationException +from ..Data import ttypes +from ..Exception import ttypes + + +from ...thrift.transport import TTransport +from ...thrift.protocol import TBinaryProtocol, TProtocol +try: + from thrift.protocol import fastbinary +except: + fastbinary = None + + http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/__init__.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/__init__.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/gen/__init__.py new file mode 100644 index 0000000..e69de29 http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/publisher.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/publisher.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/publisher.py index fa0a636..7c09d40 100644 --- a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/publisher.py +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/publisher.py @@ -1,10 +1,10 @@ import time import sys -sys.path.append("databridge/thrift/gen-py") +sys.path.append("gen") -from ThriftSecureEventTransmissionService import ThriftSecureEventTransmissionService -from ThriftSecureEventTransmissionService.ttypes import * +from gen.ThriftSecureEventTransmissionService import ThriftSecureEventTransmissionService +from gen.ThriftSecureEventTransmissionService.ttypes import * from thrift.transport import TSSLSocket from thrift.transport import TTransport http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/TTornado.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/TTornado.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/TTornado.py index af309c3..8d9f5ed 100644 --- a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/TTornado.py +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/TTornado.py @@ -22,8 +22,8 @@ import logging import socket import struct -from thrift.transport import TTransport -from thrift.transport.TTransport import TTransportException +from .transport import TTransport +from .transport.TTransport import TTransportException from tornado import gen from tornado import iostream http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/protocol/TBase.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/protocol/TBase.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/protocol/TBase.py index 6cbd5f3..61b469b 100644 --- a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/protocol/TBase.py +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/protocol/TBase.py @@ -17,12 +17,12 @@ # under the License. # -from thrift.Thrift import * -from thrift.protocol import TBinaryProtocol -from thrift.transport import TTransport +from ..Thrift import * +import TBinaryProtocol +from ..transport import TTransport try: - from thrift.protocol import fastbinary + import fastbinary except: fastbinary = None http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/protocol/TProtocol.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/protocol/TProtocol.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/protocol/TProtocol.py index dc2b095..0154641 100644 --- a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/protocol/TProtocol.py +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/protocol/TProtocol.py @@ -17,7 +17,7 @@ # under the License. # -from thrift.Thrift import * +from ..Thrift import * class TProtocolException(TException): http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/THttpServer.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/THttpServer.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/THttpServer.py index be54bab..6ee18dd 100644 --- a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/THttpServer.py +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/THttpServer.py @@ -19,8 +19,8 @@ import BaseHTTPServer -from thrift.server import TServer -from thrift.transport import TTransport +from ..server import TServer +from ..transport import TTransport class ResponseException(Exception): http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TNonblockingServer.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TNonblockingServer.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TNonblockingServer.py index fa478d0..aa27991 100644 --- a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TNonblockingServer.py +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TNonblockingServer.py @@ -31,8 +31,8 @@ import select import struct import logging -from thrift.transport import TTransport -from thrift.protocol.TBinaryProtocol import TBinaryProtocolFactory +from ..transport import TTransport +from ..protocol.TBinaryProtocol import TBinaryProtocolFactory __all__ = ['TNonblockingServer'] http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TProcessPoolServer.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TProcessPoolServer.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TProcessPoolServer.py index 2cd2189..74e142c 100644 --- a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TProcessPoolServer.py +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TProcessPoolServer.py @@ -22,7 +22,7 @@ import logging from multiprocessing import Process, Value, Condition from TServer import TServer -from thrift.transport.TTransport import TTransportException +from ..transport.TTransport import TTransportException class TProcessPoolServer(TServer): http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TServer.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TServer.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TServer.py index 2f24842..3e44107 100644 --- a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TServer.py +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/server/TServer.py @@ -24,9 +24,9 @@ import sys import threading import traceback -from thrift.Thrift import TProcessor -from thrift.protocol import TBinaryProtocol -from thrift.transport import TTransport +from ..Thrift import TProcessor +from ..protocol import TBinaryProtocol +from ..transport import TTransport class TServer: http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TSSLSocket.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TSSLSocket.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TSSLSocket.py index 81e0984..df35be4 100644 --- a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TSSLSocket.py +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TSSLSocket.py @@ -21,8 +21,8 @@ import os import socket import ssl -from thrift.transport import TSocket -from thrift.transport.TTransport import TTransportException +import TSocket +from TTransport import TTransportException class TSSLSocket(TSocket.TSocket): http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TTransport.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TTransport.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TTransport.py index 4481371..ed023d5 100644 --- a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TTransport.py +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TTransport.py @@ -19,7 +19,7 @@ from cStringIO import StringIO from struct import pack, unpack -from thrift.Thrift import TException +from ..Thrift import TException class TTransportException(TException): http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TTwisted.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TTwisted.py b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TTwisted.py index 3ce3eb2..6cdb172 100644 --- a/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TTwisted.py +++ b/tools/python-cartridge-agent/cartridge-agent/modules/databridge/thrift/thrift/transport/TTwisted.py @@ -27,7 +27,7 @@ from twisted.protocols import basic from twisted.python import log from twisted.web import server, resource, http -from thrift.transport import TTransport +import TTransport class TMessageSenderTransport(TTransport.TTransportBase): http://git-wip-us.apache.org/repos/asf/stratos/blob/105a09e9/tools/python-cartridge-agent/cartridge-agent/modules/util/extensionutils.py ---------------------------------------------------------------------- diff --git a/tools/python-cartridge-agent/cartridge-agent/modules/util/extensionutils.py b/tools/python-cartridge-agent/cartridge-agent/modules/util/extensionutils.py index 487def4..013713b 100644 --- a/tools/python-cartridge-agent/cartridge-agent/modules/util/extensionutils.py +++ b/tools/python-cartridge-agent/cartridge-agent/modules/util/extensionutils.py @@ -472,5 +472,4 @@ def execute_command(command, env_params=None): return output, errors -from .. config import cartridgeagentconfiguration from .. topology.topologycontext import * \ No newline at end of file
