diff options
author | Ulas Kozat <ulas.kozat@gmail.com> | 2016-05-15 21:31:15 -0700 |
---|---|---|
committer | Ulas Kozat <ulas.kozat@gmail.com> | 2016-05-15 21:43:21 -0700 |
commit | 7893dd02c15f2a727eb50887c9ddb829fc71f556 (patch) | |
tree | 54efcdadfda729ec4301537d264f6ea4298716e9 /lib/dominoRPC/ttypes.py | |
parent | 06f85217ae3d5c9b429bad94827caed0641cd120 (diff) |
Simple mapper/scheduler/partitioner functions implemented
Change-Id: I553b196943022451d8dc4984fe37b2b228c8f4cf
Signed-off-by: Ulas C. Kozat <ulas.kozat@huawei.com>
Diffstat (limited to 'lib/dominoRPC/ttypes.py')
-rw-r--r-- | lib/dominoRPC/ttypes.py | 1435 |
1 files changed, 1435 insertions, 0 deletions
diff --git a/lib/dominoRPC/ttypes.py b/lib/dominoRPC/ttypes.py new file mode 100644 index 0000000..8a80d5f --- /dev/null +++ b/lib/dominoRPC/ttypes.py @@ -0,0 +1,1435 @@ +# +# Autogenerated by Thrift Compiler (0.9.3) +# +# 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 thrift.transport import TTransport +from thrift.protocol import TBinaryProtocol, TProtocol +try: + from thrift.protocol import fastbinary +except: + fastbinary = None + + + +class HeartBeatMessage: + """ + Domino sends periodic heartbeats from + Domino Clients and Domino Server echos + + Attributes: + - messageType + - domino_udid + - seq_no + """ + + thrift_spec = ( + None, # 0 + (1, TType.BYTE, 'messageType', None, 1, ), # 1 + (2, TType.I64, 'domino_udid', None, None, ), # 2 + (3, TType.I64, 'seq_no', None, None, ), # 3 + ) + + def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None,): + if messageType is self.thrift_spec[1][4]: + messageType = 1 + self.messageType = messageType + self.domino_udid = domino_udid + self.seq_no = seq_no + + 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.BYTE: + self.messageType = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.I64: + self.domino_udid = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I64: + self.seq_no = iprot.readI64() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('HeartBeatMessage') + if self.messageType is not None: + oprot.writeFieldBegin('messageType', TType.BYTE, 1) + oprot.writeByte(self.messageType) + oprot.writeFieldEnd() + if self.domino_udid is not None: + oprot.writeFieldBegin('domino_udid', TType.I64, 2) + oprot.writeI64(self.domino_udid) + oprot.writeFieldEnd() + if self.seq_no is not None: + oprot.writeFieldBegin('seq_no', TType.I64, 3) + oprot.writeI64(self.seq_no) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.messageType) + value = (value * 31) ^ hash(self.domino_udid) + value = (value * 31) ^ hash(self.seq_no) + return value + + 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 RegisterMessage: + """ + Domino Clients must first register with + Domino Server. Clients can ask for a specific + Unique Domino ID (UDID) + + Attributes: + - messageType + - domino_udid_desired + - seq_no + - ipaddr + - tcpport + - supported_templates + """ + + thrift_spec = ( + None, # 0 + (1, TType.BYTE, 'messageType', None, 2, ), # 1 + (2, TType.I64, 'domino_udid_desired', None, None, ), # 2 + (3, TType.I64, 'seq_no', None, None, ), # 3 + (4, TType.STRING, 'ipaddr', None, None, ), # 4 + (5, TType.I16, 'tcpport', None, None, ), # 5 + (6, TType.LIST, 'supported_templates', (TType.STRING,None), None, ), # 6 + ) + + def __init__(self, messageType=thrift_spec[1][4], domino_udid_desired=None, seq_no=None, ipaddr=None, tcpport=None, supported_templates=None,): + if messageType is self.thrift_spec[1][4]: + messageType = 2 + self.messageType = messageType + self.domino_udid_desired = domino_udid_desired + self.seq_no = seq_no + self.ipaddr = ipaddr + self.tcpport = tcpport + self.supported_templates = supported_templates + + 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.BYTE: + self.messageType = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.I64: + self.domino_udid_desired = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I64: + self.seq_no = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.ipaddr = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.I16: + self.tcpport = iprot.readI16() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.LIST: + self.supported_templates = [] + (_etype3, _size0) = iprot.readListBegin() + for _i4 in xrange(_size0): + _elem5 = iprot.readString() + self.supported_templates.append(_elem5) + iprot.readListEnd() + 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('RegisterMessage') + if self.messageType is not None: + oprot.writeFieldBegin('messageType', TType.BYTE, 1) + oprot.writeByte(self.messageType) + oprot.writeFieldEnd() + if self.domino_udid_desired is not None: + oprot.writeFieldBegin('domino_udid_desired', TType.I64, 2) + oprot.writeI64(self.domino_udid_desired) + oprot.writeFieldEnd() + if self.seq_no is not None: + oprot.writeFieldBegin('seq_no', TType.I64, 3) + oprot.writeI64(self.seq_no) + oprot.writeFieldEnd() + if self.ipaddr is not None: + oprot.writeFieldBegin('ipaddr', TType.STRING, 4) + oprot.writeString(self.ipaddr) + oprot.writeFieldEnd() + if self.tcpport is not None: + oprot.writeFieldBegin('tcpport', TType.I16, 5) + oprot.writeI16(self.tcpport) + oprot.writeFieldEnd() + if self.supported_templates is not None: + oprot.writeFieldBegin('supported_templates', TType.LIST, 6) + oprot.writeListBegin(TType.STRING, len(self.supported_templates)) + for iter6 in self.supported_templates: + oprot.writeString(iter6) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.messageType) + value = (value * 31) ^ hash(self.domino_udid_desired) + value = (value * 31) ^ hash(self.seq_no) + value = (value * 31) ^ hash(self.ipaddr) + value = (value * 31) ^ hash(self.tcpport) + value = (value * 31) ^ hash(self.supported_templates) + return value + + 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 RegisterResponseMessage: + """ + Attributes: + - messageType + - domino_udid + - domino_udid_assigned + - seq_no + - responseCode + - comments + """ + + thrift_spec = ( + None, # 0 + (1, TType.BYTE, 'messageType', None, 3, ), # 1 + (2, TType.I64, 'domino_udid', None, None, ), # 2 + (3, TType.I64, 'domino_udid_assigned', None, None, ), # 3 + (4, TType.I64, 'seq_no', None, None, ), # 4 + (5, TType.BYTE, 'responseCode', None, None, ), # 5 + (6, TType.LIST, 'comments', (TType.STRING,None), None, ), # 6 + ) + + def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, domino_udid_assigned=None, seq_no=None, responseCode=None, comments=None,): + if messageType is self.thrift_spec[1][4]: + messageType = 3 + self.messageType = messageType + self.domino_udid = domino_udid + self.domino_udid_assigned = domino_udid_assigned + self.seq_no = seq_no + self.responseCode = responseCode + self.comments = comments + + 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.BYTE: + self.messageType = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.I64: + self.domino_udid = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I64: + self.domino_udid_assigned = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.I64: + self.seq_no = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.BYTE: + self.responseCode = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.LIST: + self.comments = [] + (_etype10, _size7) = iprot.readListBegin() + for _i11 in xrange(_size7): + _elem12 = iprot.readString() + self.comments.append(_elem12) + iprot.readListEnd() + 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('RegisterResponseMessage') + if self.messageType is not None: + oprot.writeFieldBegin('messageType', TType.BYTE, 1) + oprot.writeByte(self.messageType) + oprot.writeFieldEnd() + if self.domino_udid is not None: + oprot.writeFieldBegin('domino_udid', TType.I64, 2) + oprot.writeI64(self.domino_udid) + oprot.writeFieldEnd() + if self.domino_udid_assigned is not None: + oprot.writeFieldBegin('domino_udid_assigned', TType.I64, 3) + oprot.writeI64(self.domino_udid_assigned) + oprot.writeFieldEnd() + if self.seq_no is not None: + oprot.writeFieldBegin('seq_no', TType.I64, 4) + oprot.writeI64(self.seq_no) + oprot.writeFieldEnd() + if self.responseCode is not None: + oprot.writeFieldBegin('responseCode', TType.BYTE, 5) + oprot.writeByte(self.responseCode) + oprot.writeFieldEnd() + if self.comments is not None: + oprot.writeFieldBegin('comments', TType.LIST, 6) + oprot.writeListBegin(TType.STRING, len(self.comments)) + for iter13 in self.comments: + oprot.writeString(iter13) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.messageType) + value = (value * 31) ^ hash(self.domino_udid) + value = (value * 31) ^ hash(self.domino_udid_assigned) + value = (value * 31) ^ hash(self.seq_no) + value = (value * 31) ^ hash(self.responseCode) + value = (value * 31) ^ hash(self.comments) + return value + + 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 SubscribeMessage: + """ + Attributes: + - messageType + - domino_udid + - seq_no + - template_op + - supported_template_types + - label_op + - labels + """ + + thrift_spec = ( + None, # 0 + (1, TType.BYTE, 'messageType', None, 4, ), # 1 + (2, TType.I64, 'domino_udid', None, None, ), # 2 + (3, TType.I64, 'seq_no', None, None, ), # 3 + (4, TType.BYTE, 'template_op', None, None, ), # 4 + (5, TType.LIST, 'supported_template_types', (TType.STRING,None), None, ), # 5 + (6, TType.BYTE, 'label_op', None, None, ), # 6 + (7, TType.LIST, 'labels', (TType.STRING,None), None, ), # 7 + ) + + def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, template_op=None, supported_template_types=None, label_op=None, labels=None,): + if messageType is self.thrift_spec[1][4]: + messageType = 4 + self.messageType = messageType + self.domino_udid = domino_udid + self.seq_no = seq_no + self.template_op = template_op + self.supported_template_types = supported_template_types + self.label_op = label_op + self.labels = labels + + 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.BYTE: + self.messageType = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.I64: + self.domino_udid = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I64: + self.seq_no = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.BYTE: + self.template_op = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.supported_template_types = [] + (_etype17, _size14) = iprot.readListBegin() + for _i18 in xrange(_size14): + _elem19 = iprot.readString() + self.supported_template_types.append(_elem19) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 6: + if ftype == TType.BYTE: + self.label_op = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 7: + if ftype == TType.LIST: + self.labels = [] + (_etype23, _size20) = iprot.readListBegin() + for _i24 in xrange(_size20): + _elem25 = iprot.readString() + self.labels.append(_elem25) + iprot.readListEnd() + 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('SubscribeMessage') + if self.messageType is not None: + oprot.writeFieldBegin('messageType', TType.BYTE, 1) + oprot.writeByte(self.messageType) + oprot.writeFieldEnd() + if self.domino_udid is not None: + oprot.writeFieldBegin('domino_udid', TType.I64, 2) + oprot.writeI64(self.domino_udid) + oprot.writeFieldEnd() + if self.seq_no is not None: + oprot.writeFieldBegin('seq_no', TType.I64, 3) + oprot.writeI64(self.seq_no) + oprot.writeFieldEnd() + if self.template_op is not None: + oprot.writeFieldBegin('template_op', TType.BYTE, 4) + oprot.writeByte(self.template_op) + oprot.writeFieldEnd() + if self.supported_template_types is not None: + oprot.writeFieldBegin('supported_template_types', TType.LIST, 5) + oprot.writeListBegin(TType.STRING, len(self.supported_template_types)) + for iter26 in self.supported_template_types: + oprot.writeString(iter26) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.label_op is not None: + oprot.writeFieldBegin('label_op', TType.BYTE, 6) + oprot.writeByte(self.label_op) + oprot.writeFieldEnd() + if self.labels is not None: + oprot.writeFieldBegin('labels', TType.LIST, 7) + oprot.writeListBegin(TType.STRING, len(self.labels)) + for iter27 in self.labels: + oprot.writeString(iter27) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.messageType) + value = (value * 31) ^ hash(self.domino_udid) + value = (value * 31) ^ hash(self.seq_no) + value = (value * 31) ^ hash(self.template_op) + value = (value * 31) ^ hash(self.supported_template_types) + value = (value * 31) ^ hash(self.label_op) + value = (value * 31) ^ hash(self.labels) + return value + + 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 SubscribeResponseMessage: + """ + Attributes: + - messageType + - domino_udid + - seq_no + - responseCode + - comments + """ + + thrift_spec = ( + None, # 0 + (1, TType.BYTE, 'messageType', None, 5, ), # 1 + (2, TType.I64, 'domino_udid', None, None, ), # 2 + (3, TType.I64, 'seq_no', None, None, ), # 3 + (4, TType.BYTE, 'responseCode', None, None, ), # 4 + (5, TType.LIST, 'comments', (TType.STRING,None), None, ), # 5 + ) + + def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, responseCode=None, comments=None,): + if messageType is self.thrift_spec[1][4]: + messageType = 5 + self.messageType = messageType + self.domino_udid = domino_udid + self.seq_no = seq_no + self.responseCode = responseCode + self.comments = comments + + 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.BYTE: + self.messageType = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.I64: + self.domino_udid = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I64: + self.seq_no = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.BYTE: + self.responseCode = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.comments = [] + (_etype31, _size28) = iprot.readListBegin() + for _i32 in xrange(_size28): + _elem33 = iprot.readString() + self.comments.append(_elem33) + iprot.readListEnd() + 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('SubscribeResponseMessage') + if self.messageType is not None: + oprot.writeFieldBegin('messageType', TType.BYTE, 1) + oprot.writeByte(self.messageType) + oprot.writeFieldEnd() + if self.domino_udid is not None: + oprot.writeFieldBegin('domino_udid', TType.I64, 2) + oprot.writeI64(self.domino_udid) + oprot.writeFieldEnd() + if self.seq_no is not None: + oprot.writeFieldBegin('seq_no', TType.I64, 3) + oprot.writeI64(self.seq_no) + oprot.writeFieldEnd() + if self.responseCode is not None: + oprot.writeFieldBegin('responseCode', TType.BYTE, 4) + oprot.writeByte(self.responseCode) + oprot.writeFieldEnd() + if self.comments is not None: + oprot.writeFieldBegin('comments', TType.LIST, 5) + oprot.writeListBegin(TType.STRING, len(self.comments)) + for iter34 in self.comments: + oprot.writeString(iter34) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.messageType) + value = (value * 31) ^ hash(self.domino_udid) + value = (value * 31) ^ hash(self.seq_no) + value = (value * 31) ^ hash(self.responseCode) + value = (value * 31) ^ hash(self.comments) + return value + + 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 PublishMessage: + """ + Attributes: + - messageType + - domino_udid + - seq_no + - template_type + - template + """ + + thrift_spec = ( + None, # 0 + (1, TType.BYTE, 'messageType', None, 6, ), # 1 + (2, TType.I64, 'domino_udid', None, None, ), # 2 + (3, TType.I64, 'seq_no', None, None, ), # 3 + (4, TType.STRING, 'template_type', None, None, ), # 4 + (5, TType.LIST, 'template', (TType.STRING,None), None, ), # 5 + ) + + def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, template_type=None, template=None,): + if messageType is self.thrift_spec[1][4]: + messageType = 6 + self.messageType = messageType + self.domino_udid = domino_udid + self.seq_no = seq_no + self.template_type = template_type + self.template = template + + 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.BYTE: + self.messageType = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.I64: + self.domino_udid = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I64: + self.seq_no = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.template_type = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.template = [] + (_etype38, _size35) = iprot.readListBegin() + for _i39 in xrange(_size35): + _elem40 = iprot.readString() + self.template.append(_elem40) + iprot.readListEnd() + 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('PublishMessage') + if self.messageType is not None: + oprot.writeFieldBegin('messageType', TType.BYTE, 1) + oprot.writeByte(self.messageType) + oprot.writeFieldEnd() + if self.domino_udid is not None: + oprot.writeFieldBegin('domino_udid', TType.I64, 2) + oprot.writeI64(self.domino_udid) + oprot.writeFieldEnd() + if self.seq_no is not None: + oprot.writeFieldBegin('seq_no', TType.I64, 3) + oprot.writeI64(self.seq_no) + oprot.writeFieldEnd() + if self.template_type is not None: + oprot.writeFieldBegin('template_type', TType.STRING, 4) + oprot.writeString(self.template_type) + oprot.writeFieldEnd() + if self.template is not None: + oprot.writeFieldBegin('template', TType.LIST, 5) + oprot.writeListBegin(TType.STRING, len(self.template)) + for iter41 in self.template: + oprot.writeString(iter41) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.messageType) + value = (value * 31) ^ hash(self.domino_udid) + value = (value * 31) ^ hash(self.seq_no) + value = (value * 31) ^ hash(self.template_type) + value = (value * 31) ^ hash(self.template) + return value + + 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 PublishResponseMessage: + """ + Attributes: + - messageType + - domino_udid + - seq_no + - responseCode + - comments + """ + + thrift_spec = ( + None, # 0 + (1, TType.BYTE, 'messageType', None, 7, ), # 1 + (2, TType.I64, 'domino_udid', None, None, ), # 2 + (3, TType.I64, 'seq_no', None, None, ), # 3 + (4, TType.BYTE, 'responseCode', None, None, ), # 4 + (5, TType.LIST, 'comments', (TType.STRING,None), None, ), # 5 + ) + + def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, responseCode=None, comments=None,): + if messageType is self.thrift_spec[1][4]: + messageType = 7 + self.messageType = messageType + self.domino_udid = domino_udid + self.seq_no = seq_no + self.responseCode = responseCode + self.comments = comments + + 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.BYTE: + self.messageType = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.I64: + self.domino_udid = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I64: + self.seq_no = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.BYTE: + self.responseCode = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.comments = [] + (_etype45, _size42) = iprot.readListBegin() + for _i46 in xrange(_size42): + _elem47 = iprot.readString() + self.comments.append(_elem47) + iprot.readListEnd() + 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('PublishResponseMessage') + if self.messageType is not None: + oprot.writeFieldBegin('messageType', TType.BYTE, 1) + oprot.writeByte(self.messageType) + oprot.writeFieldEnd() + if self.domino_udid is not None: + oprot.writeFieldBegin('domino_udid', TType.I64, 2) + oprot.writeI64(self.domino_udid) + oprot.writeFieldEnd() + if self.seq_no is not None: + oprot.writeFieldBegin('seq_no', TType.I64, 3) + oprot.writeI64(self.seq_no) + oprot.writeFieldEnd() + if self.responseCode is not None: + oprot.writeFieldBegin('responseCode', TType.BYTE, 4) + oprot.writeByte(self.responseCode) + oprot.writeFieldEnd() + if self.comments is not None: + oprot.writeFieldBegin('comments', TType.LIST, 5) + oprot.writeListBegin(TType.STRING, len(self.comments)) + for iter48 in self.comments: + oprot.writeString(iter48) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.messageType) + value = (value * 31) ^ hash(self.domino_udid) + value = (value * 31) ^ hash(self.seq_no) + value = (value * 31) ^ hash(self.responseCode) + value = (value * 31) ^ hash(self.comments) + return value + + 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 PushMessage: + """ + Attributes: + - messageType + - domino_udid + - seq_no + - template_type + - template + """ + + thrift_spec = ( + None, # 0 + (1, TType.BYTE, 'messageType', None, 8, ), # 1 + (2, TType.I64, 'domino_udid', None, None, ), # 2 + (3, TType.I64, 'seq_no', None, None, ), # 3 + (4, TType.STRING, 'template_type', None, None, ), # 4 + (5, TType.LIST, 'template', (TType.STRING,None), None, ), # 5 + ) + + def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, template_type=None, template=None,): + if messageType is self.thrift_spec[1][4]: + messageType = 8 + self.messageType = messageType + self.domino_udid = domino_udid + self.seq_no = seq_no + self.template_type = template_type + self.template = template + + 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.BYTE: + self.messageType = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.I64: + self.domino_udid = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I64: + self.seq_no = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRING: + self.template_type = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.template = [] + (_etype52, _size49) = iprot.readListBegin() + for _i53 in xrange(_size49): + _elem54 = iprot.readString() + self.template.append(_elem54) + iprot.readListEnd() + 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('PushMessage') + if self.messageType is not None: + oprot.writeFieldBegin('messageType', TType.BYTE, 1) + oprot.writeByte(self.messageType) + oprot.writeFieldEnd() + if self.domino_udid is not None: + oprot.writeFieldBegin('domino_udid', TType.I64, 2) + oprot.writeI64(self.domino_udid) + oprot.writeFieldEnd() + if self.seq_no is not None: + oprot.writeFieldBegin('seq_no', TType.I64, 3) + oprot.writeI64(self.seq_no) + oprot.writeFieldEnd() + if self.template_type is not None: + oprot.writeFieldBegin('template_type', TType.STRING, 4) + oprot.writeString(self.template_type) + oprot.writeFieldEnd() + if self.template is not None: + oprot.writeFieldBegin('template', TType.LIST, 5) + oprot.writeListBegin(TType.STRING, len(self.template)) + for iter55 in self.template: + oprot.writeString(iter55) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.messageType) + value = (value * 31) ^ hash(self.domino_udid) + value = (value * 31) ^ hash(self.seq_no) + value = (value * 31) ^ hash(self.template_type) + value = (value * 31) ^ hash(self.template) + return value + + 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 PushResponseMessage: + """ + Attributes: + - messageType + - domino_udid + - seq_no + - responseCode + - comments + """ + + thrift_spec = ( + None, # 0 + (1, TType.BYTE, 'messageType', None, 9, ), # 1 + (2, TType.I64, 'domino_udid', None, None, ), # 2 + (3, TType.I64, 'seq_no', None, None, ), # 3 + (4, TType.BYTE, 'responseCode', None, None, ), # 4 + (5, TType.LIST, 'comments', (TType.STRING,None), None, ), # 5 + ) + + def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, responseCode=None, comments=None,): + if messageType is self.thrift_spec[1][4]: + messageType = 9 + self.messageType = messageType + self.domino_udid = domino_udid + self.seq_no = seq_no + self.responseCode = responseCode + self.comments = comments + + 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.BYTE: + self.messageType = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.I64: + self.domino_udid = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I64: + self.seq_no = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.BYTE: + self.responseCode = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.comments = [] + (_etype59, _size56) = iprot.readListBegin() + for _i60 in xrange(_size56): + _elem61 = iprot.readString() + self.comments.append(_elem61) + iprot.readListEnd() + 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('PushResponseMessage') + if self.messageType is not None: + oprot.writeFieldBegin('messageType', TType.BYTE, 1) + oprot.writeByte(self.messageType) + oprot.writeFieldEnd() + if self.domino_udid is not None: + oprot.writeFieldBegin('domino_udid', TType.I64, 2) + oprot.writeI64(self.domino_udid) + oprot.writeFieldEnd() + if self.seq_no is not None: + oprot.writeFieldBegin('seq_no', TType.I64, 3) + oprot.writeI64(self.seq_no) + oprot.writeFieldEnd() + if self.responseCode is not None: + oprot.writeFieldBegin('responseCode', TType.BYTE, 4) + oprot.writeByte(self.responseCode) + oprot.writeFieldEnd() + if self.comments is not None: + oprot.writeFieldBegin('comments', TType.LIST, 5) + oprot.writeListBegin(TType.STRING, len(self.comments)) + for iter62 in self.comments: + oprot.writeString(iter62) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.messageType) + value = (value * 31) ^ hash(self.domino_udid) + value = (value * 31) ^ hash(self.seq_no) + value = (value * 31) ^ hash(self.responseCode) + value = (value * 31) ^ hash(self.comments) + return value + + 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 QueryMessage: + """ + Attributes: + - messageType + - domino_udid + - seq_no + - queryString + """ + + thrift_spec = ( + None, # 0 + (1, TType.BYTE, 'messageType', None, 10, ), # 1 + (2, TType.I64, 'domino_udid', None, None, ), # 2 + (3, TType.I64, 'seq_no', None, None, ), # 3 + (4, TType.LIST, 'queryString', (TType.STRING,None), None, ), # 4 + ) + + def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, queryString=None,): + if messageType is self.thrift_spec[1][4]: + messageType = 10 + self.messageType = messageType + self.domino_udid = domino_udid + self.seq_no = seq_no + self.queryString = queryString + + 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.BYTE: + self.messageType = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.I64: + self.domino_udid = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I64: + self.seq_no = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.LIST: + self.queryString = [] + (_etype66, _size63) = iprot.readListBegin() + for _i67 in xrange(_size63): + _elem68 = iprot.readString() + self.queryString.append(_elem68) + iprot.readListEnd() + 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('QueryMessage') + if self.messageType is not None: + oprot.writeFieldBegin('messageType', TType.BYTE, 1) + oprot.writeByte(self.messageType) + oprot.writeFieldEnd() + if self.domino_udid is not None: + oprot.writeFieldBegin('domino_udid', TType.I64, 2) + oprot.writeI64(self.domino_udid) + oprot.writeFieldEnd() + if self.seq_no is not None: + oprot.writeFieldBegin('seq_no', TType.I64, 3) + oprot.writeI64(self.seq_no) + oprot.writeFieldEnd() + if self.queryString is not None: + oprot.writeFieldBegin('queryString', TType.LIST, 4) + oprot.writeListBegin(TType.STRING, len(self.queryString)) + for iter69 in self.queryString: + oprot.writeString(iter69) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.messageType) + value = (value * 31) ^ hash(self.domino_udid) + value = (value * 31) ^ hash(self.seq_no) + value = (value * 31) ^ hash(self.queryString) + return value + + 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 QueryResponseMessage: + """ + Attributes: + - messageType + - domino_udid + - seq_no + - responseCode + - queryResponse + """ + + thrift_spec = ( + None, # 0 + (1, TType.BYTE, 'messageType', None, 11, ), # 1 + (2, TType.I64, 'domino_udid', None, None, ), # 2 + (3, TType.I64, 'seq_no', None, None, ), # 3 + (4, TType.BYTE, 'responseCode', None, None, ), # 4 + (5, TType.LIST, 'queryResponse', (TType.STRING,None), None, ), # 5 + ) + + def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, responseCode=None, queryResponse=None,): + if messageType is self.thrift_spec[1][4]: + messageType = 11 + self.messageType = messageType + self.domino_udid = domino_udid + self.seq_no = seq_no + self.responseCode = responseCode + self.queryResponse = queryResponse + + 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.BYTE: + self.messageType = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.I64: + self.domino_udid = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.I64: + self.seq_no = iprot.readI64() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.BYTE: + self.responseCode = iprot.readByte() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.queryResponse = [] + (_etype73, _size70) = iprot.readListBegin() + for _i74 in xrange(_size70): + _elem75 = iprot.readString() + self.queryResponse.append(_elem75) + iprot.readListEnd() + 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('QueryResponseMessage') + if self.messageType is not None: + oprot.writeFieldBegin('messageType', TType.BYTE, 1) + oprot.writeByte(self.messageType) + oprot.writeFieldEnd() + if self.domino_udid is not None: + oprot.writeFieldBegin('domino_udid', TType.I64, 2) + oprot.writeI64(self.domino_udid) + oprot.writeFieldEnd() + if self.seq_no is not None: + oprot.writeFieldBegin('seq_no', TType.I64, 3) + oprot.writeI64(self.seq_no) + oprot.writeFieldEnd() + if self.responseCode is not None: + oprot.writeFieldBegin('responseCode', TType.BYTE, 4) + oprot.writeByte(self.responseCode) + oprot.writeFieldEnd() + if self.queryResponse is not None: + oprot.writeFieldBegin('queryResponse', TType.LIST, 5) + oprot.writeListBegin(TType.STRING, len(self.queryResponse)) + for iter76 in self.queryResponse: + oprot.writeString(iter76) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.messageType) + value = (value * 31) ^ hash(self.domino_udid) + value = (value * 31) ^ hash(self.seq_no) + value = (value * 31) ^ hash(self.responseCode) + value = (value * 31) ^ hash(self.queryResponse) + return value + + 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) |