2 # Autogenerated by Thrift Compiler (0.9.3)
4 # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
9 from thrift.Thrift import TType, TMessageType, TException, TApplicationException
11 from thrift.transport import TTransport
12 from thrift.protocol import TBinaryProtocol, TProtocol
14 from thrift.protocol import fastbinary
20 class HeartBeatMessage:
22 Domino sends periodic heartbeats from
23 Domino Clients and Domino Server echos
33 (1, TType.BYTE, 'messageType', None, 1, ), # 1
34 (2, TType.STRING, 'domino_udid', None, None, ), # 2
35 (3, TType.I64, 'seq_no', None, None, ), # 3
38 def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None,):
39 if messageType is self.thrift_spec[1][4]:
41 self.messageType = messageType
42 self.domino_udid = domino_udid
45 def read(self, iprot):
46 if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
47 fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
49 iprot.readStructBegin()
51 (fname, ftype, fid) = iprot.readFieldBegin()
52 if ftype == TType.STOP:
55 if ftype == TType.BYTE:
56 self.messageType = iprot.readByte()
60 if ftype == TType.STRING:
61 self.domino_udid = iprot.readString()
65 if ftype == TType.I64:
66 self.seq_no = iprot.readI64()
74 def write(self, oprot):
75 if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
76 oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
78 oprot.writeStructBegin('HeartBeatMessage')
79 if self.messageType is not None:
80 oprot.writeFieldBegin('messageType', TType.BYTE, 1)
81 oprot.writeByte(self.messageType)
83 if self.domino_udid is not None:
84 oprot.writeFieldBegin('domino_udid', TType.STRING, 2)
85 oprot.writeString(self.domino_udid)
87 if self.seq_no is not None:
88 oprot.writeFieldBegin('seq_no', TType.I64, 3)
89 oprot.writeI64(self.seq_no)
91 oprot.writeFieldStop()
92 oprot.writeStructEnd()
100 value = (value * 31) ^ hash(self.messageType)
101 value = (value * 31) ^ hash(self.domino_udid)
102 value = (value * 31) ^ hash(self.seq_no)
106 L = ['%s=%r' % (key, value)
107 for key, value in self.__dict__.iteritems()]
108 return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
110 def __eq__(self, other):
111 return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
113 def __ne__(self, other):
114 return not (self == other)
116 class RegisterMessage:
118 Domino Clients must first register with
119 Domino Server. Clients can ask for a specific
120 Unique Domino ID (UDID)
124 - domino_udid_desired
128 - supported_templates
133 (1, TType.BYTE, 'messageType', None, 2, ), # 1
134 (2, TType.STRING, 'domino_udid_desired', None, None, ), # 2
135 (3, TType.I64, 'seq_no', None, None, ), # 3
136 (4, TType.STRING, 'ipaddr', None, None, ), # 4
137 (5, TType.I16, 'tcpport', None, None, ), # 5
138 (6, TType.LIST, 'supported_templates', (TType.STRING,None), None, ), # 6
141 def __init__(self, messageType=thrift_spec[1][4], domino_udid_desired=None, seq_no=None, ipaddr=None, tcpport=None, supported_templates=None,):
142 if messageType is self.thrift_spec[1][4]:
144 self.messageType = messageType
145 self.domino_udid_desired = domino_udid_desired
148 self.tcpport = tcpport
149 self.supported_templates = supported_templates
151 def read(self, iprot):
152 if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
153 fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
155 iprot.readStructBegin()
157 (fname, ftype, fid) = iprot.readFieldBegin()
158 if ftype == TType.STOP:
161 if ftype == TType.BYTE:
162 self.messageType = iprot.readByte()
166 if ftype == TType.STRING:
167 self.domino_udid_desired = iprot.readString()
171 if ftype == TType.I64:
172 self.seq_no = iprot.readI64()
176 if ftype == TType.STRING:
177 self.ipaddr = iprot.readString()
181 if ftype == TType.I16:
182 self.tcpport = iprot.readI16()
186 if ftype == TType.LIST:
187 self.supported_templates = []
188 (_etype3, _size0) = iprot.readListBegin()
189 for _i4 in xrange(_size0):
190 _elem5 = iprot.readString()
191 self.supported_templates.append(_elem5)
198 iprot.readStructEnd()
200 def write(self, oprot):
201 if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
202 oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
204 oprot.writeStructBegin('RegisterMessage')
205 if self.messageType is not None:
206 oprot.writeFieldBegin('messageType', TType.BYTE, 1)
207 oprot.writeByte(self.messageType)
208 oprot.writeFieldEnd()
209 if self.domino_udid_desired is not None:
210 oprot.writeFieldBegin('domino_udid_desired', TType.STRING, 2)
211 oprot.writeString(self.domino_udid_desired)
212 oprot.writeFieldEnd()
213 if self.seq_no is not None:
214 oprot.writeFieldBegin('seq_no', TType.I64, 3)
215 oprot.writeI64(self.seq_no)
216 oprot.writeFieldEnd()
217 if self.ipaddr is not None:
218 oprot.writeFieldBegin('ipaddr', TType.STRING, 4)
219 oprot.writeString(self.ipaddr)
220 oprot.writeFieldEnd()
221 if self.tcpport is not None:
222 oprot.writeFieldBegin('tcpport', TType.I16, 5)
223 oprot.writeI16(self.tcpport)
224 oprot.writeFieldEnd()
225 if self.supported_templates is not None:
226 oprot.writeFieldBegin('supported_templates', TType.LIST, 6)
227 oprot.writeListBegin(TType.STRING, len(self.supported_templates))
228 for iter6 in self.supported_templates:
229 oprot.writeString(iter6)
231 oprot.writeFieldEnd()
232 oprot.writeFieldStop()
233 oprot.writeStructEnd()
241 value = (value * 31) ^ hash(self.messageType)
242 value = (value * 31) ^ hash(self.domino_udid_desired)
243 value = (value * 31) ^ hash(self.seq_no)
244 value = (value * 31) ^ hash(self.ipaddr)
245 value = (value * 31) ^ hash(self.tcpport)
246 value = (value * 31) ^ hash(self.supported_templates)
250 L = ['%s=%r' % (key, value)
251 for key, value in self.__dict__.iteritems()]
252 return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
254 def __eq__(self, other):
255 return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
257 def __ne__(self, other):
258 return not (self == other)
260 class RegisterResponseMessage:
265 - domino_udid_assigned
273 (1, TType.BYTE, 'messageType', None, 3, ), # 1
274 (2, TType.STRING, 'domino_udid', None, None, ), # 2
275 (3, TType.STRING, 'domino_udid_assigned', None, None, ), # 3
276 (4, TType.I64, 'seq_no', None, None, ), # 4
277 (5, TType.BYTE, 'responseCode', None, None, ), # 5
278 (6, TType.LIST, 'comments', (TType.STRING,None), None, ), # 6
281 def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, domino_udid_assigned=None, seq_no=None, responseCode=None, comments=None,):
282 if messageType is self.thrift_spec[1][4]:
284 self.messageType = messageType
285 self.domino_udid = domino_udid
286 self.domino_udid_assigned = domino_udid_assigned
288 self.responseCode = responseCode
289 self.comments = comments
291 def read(self, iprot):
292 if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
293 fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
295 iprot.readStructBegin()
297 (fname, ftype, fid) = iprot.readFieldBegin()
298 if ftype == TType.STOP:
301 if ftype == TType.BYTE:
302 self.messageType = iprot.readByte()
306 if ftype == TType.STRING:
307 self.domino_udid = iprot.readString()
311 if ftype == TType.STRING:
312 self.domino_udid_assigned = iprot.readString()
316 if ftype == TType.I64:
317 self.seq_no = iprot.readI64()
321 if ftype == TType.BYTE:
322 self.responseCode = iprot.readByte()
326 if ftype == TType.LIST:
328 (_etype10, _size7) = iprot.readListBegin()
329 for _i11 in xrange(_size7):
330 _elem12 = iprot.readString()
331 self.comments.append(_elem12)
338 iprot.readStructEnd()
340 def write(self, oprot):
341 if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
342 oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
344 oprot.writeStructBegin('RegisterResponseMessage')
345 if self.messageType is not None:
346 oprot.writeFieldBegin('messageType', TType.BYTE, 1)
347 oprot.writeByte(self.messageType)
348 oprot.writeFieldEnd()
349 if self.domino_udid is not None:
350 oprot.writeFieldBegin('domino_udid', TType.STRING, 2)
351 oprot.writeString(self.domino_udid)
352 oprot.writeFieldEnd()
353 if self.domino_udid_assigned is not None:
354 oprot.writeFieldBegin('domino_udid_assigned', TType.STRING, 3)
355 oprot.writeString(self.domino_udid_assigned)
356 oprot.writeFieldEnd()
357 if self.seq_no is not None:
358 oprot.writeFieldBegin('seq_no', TType.I64, 4)
359 oprot.writeI64(self.seq_no)
360 oprot.writeFieldEnd()
361 if self.responseCode is not None:
362 oprot.writeFieldBegin('responseCode', TType.BYTE, 5)
363 oprot.writeByte(self.responseCode)
364 oprot.writeFieldEnd()
365 if self.comments is not None:
366 oprot.writeFieldBegin('comments', TType.LIST, 6)
367 oprot.writeListBegin(TType.STRING, len(self.comments))
368 for iter13 in self.comments:
369 oprot.writeString(iter13)
371 oprot.writeFieldEnd()
372 oprot.writeFieldStop()
373 oprot.writeStructEnd()
381 value = (value * 31) ^ hash(self.messageType)
382 value = (value * 31) ^ hash(self.domino_udid)
383 value = (value * 31) ^ hash(self.domino_udid_assigned)
384 value = (value * 31) ^ hash(self.seq_no)
385 value = (value * 31) ^ hash(self.responseCode)
386 value = (value * 31) ^ hash(self.comments)
390 L = ['%s=%r' % (key, value)
391 for key, value in self.__dict__.iteritems()]
392 return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
394 def __eq__(self, other):
395 return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
397 def __ne__(self, other):
398 return not (self == other)
400 class SubscribeMessage:
407 - supported_template_types
414 (1, TType.BYTE, 'messageType', None, 4, ), # 1
415 (2, TType.STRING, 'domino_udid', None, None, ), # 2
416 (3, TType.I64, 'seq_no', None, None, ), # 3
417 (4, TType.BYTE, 'template_op', None, None, ), # 4
418 (5, TType.LIST, 'supported_template_types', (TType.STRING,None), None, ), # 5
419 (6, TType.BYTE, 'label_op', None, None, ), # 6
420 (7, TType.LIST, 'labels', (TType.STRING,None), None, ), # 7
423 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,):
424 if messageType is self.thrift_spec[1][4]:
426 self.messageType = messageType
427 self.domino_udid = domino_udid
429 self.template_op = template_op
430 self.supported_template_types = supported_template_types
431 self.label_op = label_op
434 def read(self, iprot):
435 if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
436 fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
438 iprot.readStructBegin()
440 (fname, ftype, fid) = iprot.readFieldBegin()
441 if ftype == TType.STOP:
444 if ftype == TType.BYTE:
445 self.messageType = iprot.readByte()
449 if ftype == TType.STRING:
450 self.domino_udid = iprot.readString()
454 if ftype == TType.I64:
455 self.seq_no = iprot.readI64()
459 if ftype == TType.BYTE:
460 self.template_op = iprot.readByte()
464 if ftype == TType.LIST:
465 self.supported_template_types = []
466 (_etype17, _size14) = iprot.readListBegin()
467 for _i18 in xrange(_size14):
468 _elem19 = iprot.readString()
469 self.supported_template_types.append(_elem19)
474 if ftype == TType.BYTE:
475 self.label_op = iprot.readByte()
479 if ftype == TType.LIST:
481 (_etype23, _size20) = iprot.readListBegin()
482 for _i24 in xrange(_size20):
483 _elem25 = iprot.readString()
484 self.labels.append(_elem25)
491 iprot.readStructEnd()
493 def write(self, oprot):
494 if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
495 oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
497 oprot.writeStructBegin('SubscribeMessage')
498 if self.messageType is not None:
499 oprot.writeFieldBegin('messageType', TType.BYTE, 1)
500 oprot.writeByte(self.messageType)
501 oprot.writeFieldEnd()
502 if self.domino_udid is not None:
503 oprot.writeFieldBegin('domino_udid', TType.STRING, 2)
504 oprot.writeString(self.domino_udid)
505 oprot.writeFieldEnd()
506 if self.seq_no is not None:
507 oprot.writeFieldBegin('seq_no', TType.I64, 3)
508 oprot.writeI64(self.seq_no)
509 oprot.writeFieldEnd()
510 if self.template_op is not None:
511 oprot.writeFieldBegin('template_op', TType.BYTE, 4)
512 oprot.writeByte(self.template_op)
513 oprot.writeFieldEnd()
514 if self.supported_template_types is not None:
515 oprot.writeFieldBegin('supported_template_types', TType.LIST, 5)
516 oprot.writeListBegin(TType.STRING, len(self.supported_template_types))
517 for iter26 in self.supported_template_types:
518 oprot.writeString(iter26)
520 oprot.writeFieldEnd()
521 if self.label_op is not None:
522 oprot.writeFieldBegin('label_op', TType.BYTE, 6)
523 oprot.writeByte(self.label_op)
524 oprot.writeFieldEnd()
525 if self.labels is not None:
526 oprot.writeFieldBegin('labels', TType.LIST, 7)
527 oprot.writeListBegin(TType.STRING, len(self.labels))
528 for iter27 in self.labels:
529 oprot.writeString(iter27)
531 oprot.writeFieldEnd()
532 oprot.writeFieldStop()
533 oprot.writeStructEnd()
541 value = (value * 31) ^ hash(self.messageType)
542 value = (value * 31) ^ hash(self.domino_udid)
543 value = (value * 31) ^ hash(self.seq_no)
544 value = (value * 31) ^ hash(self.template_op)
545 value = (value * 31) ^ hash(self.supported_template_types)
546 value = (value * 31) ^ hash(self.label_op)
547 value = (value * 31) ^ hash(self.labels)
551 L = ['%s=%r' % (key, value)
552 for key, value in self.__dict__.iteritems()]
553 return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
555 def __eq__(self, other):
556 return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
558 def __ne__(self, other):
559 return not (self == other)
561 class SubscribeResponseMessage:
573 (1, TType.BYTE, 'messageType', None, 5, ), # 1
574 (2, TType.STRING, 'domino_udid', None, None, ), # 2
575 (3, TType.I64, 'seq_no', None, None, ), # 3
576 (4, TType.BYTE, 'responseCode', None, None, ), # 4
577 (5, TType.LIST, 'comments', (TType.STRING,None), None, ), # 5
580 def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, responseCode=None, comments=None,):
581 if messageType is self.thrift_spec[1][4]:
583 self.messageType = messageType
584 self.domino_udid = domino_udid
586 self.responseCode = responseCode
587 self.comments = comments
589 def read(self, iprot):
590 if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
591 fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
593 iprot.readStructBegin()
595 (fname, ftype, fid) = iprot.readFieldBegin()
596 if ftype == TType.STOP:
599 if ftype == TType.BYTE:
600 self.messageType = iprot.readByte()
604 if ftype == TType.STRING:
605 self.domino_udid = iprot.readString()
609 if ftype == TType.I64:
610 self.seq_no = iprot.readI64()
614 if ftype == TType.BYTE:
615 self.responseCode = iprot.readByte()
619 if ftype == TType.LIST:
621 (_etype31, _size28) = iprot.readListBegin()
622 for _i32 in xrange(_size28):
623 _elem33 = iprot.readString()
624 self.comments.append(_elem33)
631 iprot.readStructEnd()
633 def write(self, oprot):
634 if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
635 oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
637 oprot.writeStructBegin('SubscribeResponseMessage')
638 if self.messageType is not None:
639 oprot.writeFieldBegin('messageType', TType.BYTE, 1)
640 oprot.writeByte(self.messageType)
641 oprot.writeFieldEnd()
642 if self.domino_udid is not None:
643 oprot.writeFieldBegin('domino_udid', TType.STRING, 2)
644 oprot.writeString(self.domino_udid)
645 oprot.writeFieldEnd()
646 if self.seq_no is not None:
647 oprot.writeFieldBegin('seq_no', TType.I64, 3)
648 oprot.writeI64(self.seq_no)
649 oprot.writeFieldEnd()
650 if self.responseCode is not None:
651 oprot.writeFieldBegin('responseCode', TType.BYTE, 4)
652 oprot.writeByte(self.responseCode)
653 oprot.writeFieldEnd()
654 if self.comments is not None:
655 oprot.writeFieldBegin('comments', TType.LIST, 5)
656 oprot.writeListBegin(TType.STRING, len(self.comments))
657 for iter34 in self.comments:
658 oprot.writeString(iter34)
660 oprot.writeFieldEnd()
661 oprot.writeFieldStop()
662 oprot.writeStructEnd()
670 value = (value * 31) ^ hash(self.messageType)
671 value = (value * 31) ^ hash(self.domino_udid)
672 value = (value * 31) ^ hash(self.seq_no)
673 value = (value * 31) ^ hash(self.responseCode)
674 value = (value * 31) ^ hash(self.comments)
678 L = ['%s=%r' % (key, value)
679 for key, value in self.__dict__.iteritems()]
680 return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
682 def __eq__(self, other):
683 return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
685 def __ne__(self, other):
686 return not (self == other)
688 class PublishMessage:
701 (1, TType.BYTE, 'messageType', None, 6, ), # 1
702 (2, TType.STRING, 'domino_udid', None, None, ), # 2
703 (3, TType.I64, 'seq_no', None, None, ), # 3
704 (4, TType.STRING, 'template_type', None, None, ), # 4
705 (5, TType.LIST, 'template', (TType.STRING,None), None, ), # 5
706 (6, TType.STRING, 'template_UUID', None, None, ), # 6
709 def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, template_type=None, template=None, template_UUID=None,):
710 if messageType is self.thrift_spec[1][4]:
712 self.messageType = messageType
713 self.domino_udid = domino_udid
715 self.template_type = template_type
716 self.template = template
717 self.template_UUID = template_UUID
719 def read(self, iprot):
720 if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
721 fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
723 iprot.readStructBegin()
725 (fname, ftype, fid) = iprot.readFieldBegin()
726 if ftype == TType.STOP:
729 if ftype == TType.BYTE:
730 self.messageType = iprot.readByte()
734 if ftype == TType.STRING:
735 self.domino_udid = iprot.readString()
739 if ftype == TType.I64:
740 self.seq_no = iprot.readI64()
744 if ftype == TType.STRING:
745 self.template_type = iprot.readString()
749 if ftype == TType.LIST:
751 (_etype38, _size35) = iprot.readListBegin()
752 for _i39 in xrange(_size35):
753 _elem40 = iprot.readString()
754 self.template.append(_elem40)
759 if ftype == TType.STRING:
760 self.template_UUID = iprot.readString()
766 iprot.readStructEnd()
768 def write(self, oprot):
769 if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
770 oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
772 oprot.writeStructBegin('PublishMessage')
773 if self.messageType is not None:
774 oprot.writeFieldBegin('messageType', TType.BYTE, 1)
775 oprot.writeByte(self.messageType)
776 oprot.writeFieldEnd()
777 if self.domino_udid is not None:
778 oprot.writeFieldBegin('domino_udid', TType.STRING, 2)
779 oprot.writeString(self.domino_udid)
780 oprot.writeFieldEnd()
781 if self.seq_no is not None:
782 oprot.writeFieldBegin('seq_no', TType.I64, 3)
783 oprot.writeI64(self.seq_no)
784 oprot.writeFieldEnd()
785 if self.template_type is not None:
786 oprot.writeFieldBegin('template_type', TType.STRING, 4)
787 oprot.writeString(self.template_type)
788 oprot.writeFieldEnd()
789 if self.template is not None:
790 oprot.writeFieldBegin('template', TType.LIST, 5)
791 oprot.writeListBegin(TType.STRING, len(self.template))
792 for iter41 in self.template:
793 oprot.writeString(iter41)
795 oprot.writeFieldEnd()
796 if self.template_UUID is not None:
797 oprot.writeFieldBegin('template_UUID', TType.STRING, 6)
798 oprot.writeString(self.template_UUID)
799 oprot.writeFieldEnd()
800 oprot.writeFieldStop()
801 oprot.writeStructEnd()
809 value = (value * 31) ^ hash(self.messageType)
810 value = (value * 31) ^ hash(self.domino_udid)
811 value = (value * 31) ^ hash(self.seq_no)
812 value = (value * 31) ^ hash(self.template_type)
813 value = (value * 31) ^ hash(self.template)
814 value = (value * 31) ^ hash(self.template_UUID)
818 L = ['%s=%r' % (key, value)
819 for key, value in self.__dict__.iteritems()]
820 return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
822 def __eq__(self, other):
823 return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
825 def __ne__(self, other):
826 return not (self == other)
828 class PublishResponseMessage:
841 (1, TType.BYTE, 'messageType', None, 7, ), # 1
842 (2, TType.STRING, 'domino_udid', None, None, ), # 2
843 (3, TType.I64, 'seq_no', None, None, ), # 3
844 (4, TType.BYTE, 'responseCode', None, None, ), # 4
845 (5, TType.STRING, 'template_UUID', None, None, ), # 5
846 (6, TType.LIST, 'comments', (TType.STRING,None), None, ), # 6
849 def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, responseCode=None, template_UUID=None, comments=None,):
850 if messageType is self.thrift_spec[1][4]:
852 self.messageType = messageType
853 self.domino_udid = domino_udid
855 self.responseCode = responseCode
856 self.template_UUID = template_UUID
857 self.comments = comments
859 def read(self, iprot):
860 if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
861 fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
863 iprot.readStructBegin()
865 (fname, ftype, fid) = iprot.readFieldBegin()
866 if ftype == TType.STOP:
869 if ftype == TType.BYTE:
870 self.messageType = iprot.readByte()
874 if ftype == TType.STRING:
875 self.domino_udid = iprot.readString()
879 if ftype == TType.I64:
880 self.seq_no = iprot.readI64()
884 if ftype == TType.BYTE:
885 self.responseCode = iprot.readByte()
889 if ftype == TType.STRING:
890 self.template_UUID = iprot.readString()
894 if ftype == TType.LIST:
896 (_etype45, _size42) = iprot.readListBegin()
897 for _i46 in xrange(_size42):
898 _elem47 = iprot.readString()
899 self.comments.append(_elem47)
906 iprot.readStructEnd()
908 def write(self, oprot):
909 if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
910 oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
912 oprot.writeStructBegin('PublishResponseMessage')
913 if self.messageType is not None:
914 oprot.writeFieldBegin('messageType', TType.BYTE, 1)
915 oprot.writeByte(self.messageType)
916 oprot.writeFieldEnd()
917 if self.domino_udid is not None:
918 oprot.writeFieldBegin('domino_udid', TType.STRING, 2)
919 oprot.writeString(self.domino_udid)
920 oprot.writeFieldEnd()
921 if self.seq_no is not None:
922 oprot.writeFieldBegin('seq_no', TType.I64, 3)
923 oprot.writeI64(self.seq_no)
924 oprot.writeFieldEnd()
925 if self.responseCode is not None:
926 oprot.writeFieldBegin('responseCode', TType.BYTE, 4)
927 oprot.writeByte(self.responseCode)
928 oprot.writeFieldEnd()
929 if self.template_UUID is not None:
930 oprot.writeFieldBegin('template_UUID', TType.STRING, 5)
931 oprot.writeString(self.template_UUID)
932 oprot.writeFieldEnd()
933 if self.comments is not None:
934 oprot.writeFieldBegin('comments', TType.LIST, 6)
935 oprot.writeListBegin(TType.STRING, len(self.comments))
936 for iter48 in self.comments:
937 oprot.writeString(iter48)
939 oprot.writeFieldEnd()
940 oprot.writeFieldStop()
941 oprot.writeStructEnd()
949 value = (value * 31) ^ hash(self.messageType)
950 value = (value * 31) ^ hash(self.domino_udid)
951 value = (value * 31) ^ hash(self.seq_no)
952 value = (value * 31) ^ hash(self.responseCode)
953 value = (value * 31) ^ hash(self.template_UUID)
954 value = (value * 31) ^ hash(self.comments)
958 L = ['%s=%r' % (key, value)
959 for key, value in self.__dict__.iteritems()]
960 return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
962 def __eq__(self, other):
963 return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
965 def __ne__(self, other):
966 return not (self == other)
981 (1, TType.BYTE, 'messageType', None, 8, ), # 1
982 (2, TType.STRING, 'domino_udid', None, None, ), # 2
983 (3, TType.I64, 'seq_no', None, None, ), # 3
984 (4, TType.STRING, 'template_type', None, None, ), # 4
985 (5, TType.LIST, 'template', (TType.STRING,None), None, ), # 5
986 (6, TType.STRING, 'template_UUID', None, None, ), # 6
989 def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, template_type=None, template=None, template_UUID=None,):
990 if messageType is self.thrift_spec[1][4]:
992 self.messageType = messageType
993 self.domino_udid = domino_udid
995 self.template_type = template_type
996 self.template = template
997 self.template_UUID = template_UUID
999 def read(self, iprot):
1000 if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1001 fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1003 iprot.readStructBegin()
1005 (fname, ftype, fid) = iprot.readFieldBegin()
1006 if ftype == TType.STOP:
1009 if ftype == TType.BYTE:
1010 self.messageType = iprot.readByte()
1014 if ftype == TType.STRING:
1015 self.domino_udid = iprot.readString()
1019 if ftype == TType.I64:
1020 self.seq_no = iprot.readI64()
1024 if ftype == TType.STRING:
1025 self.template_type = iprot.readString()
1029 if ftype == TType.LIST:
1031 (_etype52, _size49) = iprot.readListBegin()
1032 for _i53 in xrange(_size49):
1033 _elem54 = iprot.readString()
1034 self.template.append(_elem54)
1039 if ftype == TType.STRING:
1040 self.template_UUID = iprot.readString()
1045 iprot.readFieldEnd()
1046 iprot.readStructEnd()
1048 def write(self, oprot):
1049 if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1050 oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1052 oprot.writeStructBegin('PushMessage')
1053 if self.messageType is not None:
1054 oprot.writeFieldBegin('messageType', TType.BYTE, 1)
1055 oprot.writeByte(self.messageType)
1056 oprot.writeFieldEnd()
1057 if self.domino_udid is not None:
1058 oprot.writeFieldBegin('domino_udid', TType.STRING, 2)
1059 oprot.writeString(self.domino_udid)
1060 oprot.writeFieldEnd()
1061 if self.seq_no is not None:
1062 oprot.writeFieldBegin('seq_no', TType.I64, 3)
1063 oprot.writeI64(self.seq_no)
1064 oprot.writeFieldEnd()
1065 if self.template_type is not None:
1066 oprot.writeFieldBegin('template_type', TType.STRING, 4)
1067 oprot.writeString(self.template_type)
1068 oprot.writeFieldEnd()
1069 if self.template is not None:
1070 oprot.writeFieldBegin('template', TType.LIST, 5)
1071 oprot.writeListBegin(TType.STRING, len(self.template))
1072 for iter55 in self.template:
1073 oprot.writeString(iter55)
1074 oprot.writeListEnd()
1075 oprot.writeFieldEnd()
1076 if self.template_UUID is not None:
1077 oprot.writeFieldBegin('template_UUID', TType.STRING, 6)
1078 oprot.writeString(self.template_UUID)
1079 oprot.writeFieldEnd()
1080 oprot.writeFieldStop()
1081 oprot.writeStructEnd()
1089 value = (value * 31) ^ hash(self.messageType)
1090 value = (value * 31) ^ hash(self.domino_udid)
1091 value = (value * 31) ^ hash(self.seq_no)
1092 value = (value * 31) ^ hash(self.template_type)
1093 value = (value * 31) ^ hash(self.template)
1094 value = (value * 31) ^ hash(self.template_UUID)
1098 L = ['%s=%r' % (key, value)
1099 for key, value in self.__dict__.iteritems()]
1100 return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1102 def __eq__(self, other):
1103 return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1105 def __ne__(self, other):
1106 return not (self == other)
1108 class PushResponseMessage:
1120 (1, TType.BYTE, 'messageType', None, 9, ), # 1
1121 (2, TType.STRING, 'domino_udid', None, None, ), # 2
1122 (3, TType.I64, 'seq_no', None, None, ), # 3
1123 (4, TType.BYTE, 'responseCode', None, None, ), # 4
1124 (5, TType.LIST, 'comments', (TType.STRING,None), None, ), # 5
1127 def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, responseCode=None, comments=None,):
1128 if messageType is self.thrift_spec[1][4]:
1130 self.messageType = messageType
1131 self.domino_udid = domino_udid
1132 self.seq_no = seq_no
1133 self.responseCode = responseCode
1134 self.comments = comments
1136 def read(self, iprot):
1137 if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1138 fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1140 iprot.readStructBegin()
1142 (fname, ftype, fid) = iprot.readFieldBegin()
1143 if ftype == TType.STOP:
1146 if ftype == TType.BYTE:
1147 self.messageType = iprot.readByte()
1151 if ftype == TType.STRING:
1152 self.domino_udid = iprot.readString()
1156 if ftype == TType.I64:
1157 self.seq_no = iprot.readI64()
1161 if ftype == TType.BYTE:
1162 self.responseCode = iprot.readByte()
1166 if ftype == TType.LIST:
1168 (_etype59, _size56) = iprot.readListBegin()
1169 for _i60 in xrange(_size56):
1170 _elem61 = iprot.readString()
1171 self.comments.append(_elem61)
1177 iprot.readFieldEnd()
1178 iprot.readStructEnd()
1180 def write(self, oprot):
1181 if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1182 oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1184 oprot.writeStructBegin('PushResponseMessage')
1185 if self.messageType is not None:
1186 oprot.writeFieldBegin('messageType', TType.BYTE, 1)
1187 oprot.writeByte(self.messageType)
1188 oprot.writeFieldEnd()
1189 if self.domino_udid is not None:
1190 oprot.writeFieldBegin('domino_udid', TType.STRING, 2)
1191 oprot.writeString(self.domino_udid)
1192 oprot.writeFieldEnd()
1193 if self.seq_no is not None:
1194 oprot.writeFieldBegin('seq_no', TType.I64, 3)
1195 oprot.writeI64(self.seq_no)
1196 oprot.writeFieldEnd()
1197 if self.responseCode is not None:
1198 oprot.writeFieldBegin('responseCode', TType.BYTE, 4)
1199 oprot.writeByte(self.responseCode)
1200 oprot.writeFieldEnd()
1201 if self.comments is not None:
1202 oprot.writeFieldBegin('comments', TType.LIST, 5)
1203 oprot.writeListBegin(TType.STRING, len(self.comments))
1204 for iter62 in self.comments:
1205 oprot.writeString(iter62)
1206 oprot.writeListEnd()
1207 oprot.writeFieldEnd()
1208 oprot.writeFieldStop()
1209 oprot.writeStructEnd()
1217 value = (value * 31) ^ hash(self.messageType)
1218 value = (value * 31) ^ hash(self.domino_udid)
1219 value = (value * 31) ^ hash(self.seq_no)
1220 value = (value * 31) ^ hash(self.responseCode)
1221 value = (value * 31) ^ hash(self.comments)
1225 L = ['%s=%r' % (key, value)
1226 for key, value in self.__dict__.iteritems()]
1227 return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1229 def __eq__(self, other):
1230 return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1232 def __ne__(self, other):
1233 return not (self == other)
1247 (1, TType.BYTE, 'messageType', None, 10, ), # 1
1248 (2, TType.STRING, 'domino_udid', None, None, ), # 2
1249 (3, TType.I64, 'seq_no', None, None, ), # 3
1250 (4, TType.LIST, 'queryString', (TType.STRING,None), None, ), # 4
1251 (5, TType.STRING, 'template_UUID', None, None, ), # 5
1254 def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, queryString=None, template_UUID=None,):
1255 if messageType is self.thrift_spec[1][4]:
1257 self.messageType = messageType
1258 self.domino_udid = domino_udid
1259 self.seq_no = seq_no
1260 self.queryString = queryString
1261 self.template_UUID = template_UUID
1263 def read(self, iprot):
1264 if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1265 fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1267 iprot.readStructBegin()
1269 (fname, ftype, fid) = iprot.readFieldBegin()
1270 if ftype == TType.STOP:
1273 if ftype == TType.BYTE:
1274 self.messageType = iprot.readByte()
1278 if ftype == TType.STRING:
1279 self.domino_udid = iprot.readString()
1283 if ftype == TType.I64:
1284 self.seq_no = iprot.readI64()
1288 if ftype == TType.LIST:
1289 self.queryString = []
1290 (_etype66, _size63) = iprot.readListBegin()
1291 for _i67 in xrange(_size63):
1292 _elem68 = iprot.readString()
1293 self.queryString.append(_elem68)
1298 if ftype == TType.STRING:
1299 self.template_UUID = iprot.readString()
1304 iprot.readFieldEnd()
1305 iprot.readStructEnd()
1307 def write(self, oprot):
1308 if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1309 oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1311 oprot.writeStructBegin('QueryMessage')
1312 if self.messageType is not None:
1313 oprot.writeFieldBegin('messageType', TType.BYTE, 1)
1314 oprot.writeByte(self.messageType)
1315 oprot.writeFieldEnd()
1316 if self.domino_udid is not None:
1317 oprot.writeFieldBegin('domino_udid', TType.STRING, 2)
1318 oprot.writeString(self.domino_udid)
1319 oprot.writeFieldEnd()
1320 if self.seq_no is not None:
1321 oprot.writeFieldBegin('seq_no', TType.I64, 3)
1322 oprot.writeI64(self.seq_no)
1323 oprot.writeFieldEnd()
1324 if self.queryString is not None:
1325 oprot.writeFieldBegin('queryString', TType.LIST, 4)
1326 oprot.writeListBegin(TType.STRING, len(self.queryString))
1327 for iter69 in self.queryString:
1328 oprot.writeString(iter69)
1329 oprot.writeListEnd()
1330 oprot.writeFieldEnd()
1331 if self.template_UUID is not None:
1332 oprot.writeFieldBegin('template_UUID', TType.STRING, 5)
1333 oprot.writeString(self.template_UUID)
1334 oprot.writeFieldEnd()
1335 oprot.writeFieldStop()
1336 oprot.writeStructEnd()
1344 value = (value * 31) ^ hash(self.messageType)
1345 value = (value * 31) ^ hash(self.domino_udid)
1346 value = (value * 31) ^ hash(self.seq_no)
1347 value = (value * 31) ^ hash(self.queryString)
1348 value = (value * 31) ^ hash(self.template_UUID)
1352 L = ['%s=%r' % (key, value)
1353 for key, value in self.__dict__.iteritems()]
1354 return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1356 def __eq__(self, other):
1357 return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1359 def __ne__(self, other):
1360 return not (self == other)
1362 class QueryResponseMessage:
1374 (1, TType.BYTE, 'messageType', None, 11, ), # 1
1375 (2, TType.STRING, 'domino_udid', None, None, ), # 2
1376 (3, TType.I64, 'seq_no', None, None, ), # 3
1377 (4, TType.BYTE, 'responseCode', None, None, ), # 4
1378 (5, TType.LIST, 'queryResponse', (TType.STRING,None), None, ), # 5
1381 def __init__(self, messageType=thrift_spec[1][4], domino_udid=None, seq_no=None, responseCode=None, queryResponse=None,):
1382 if messageType is self.thrift_spec[1][4]:
1384 self.messageType = messageType
1385 self.domino_udid = domino_udid
1386 self.seq_no = seq_no
1387 self.responseCode = responseCode
1388 self.queryResponse = queryResponse
1390 def read(self, iprot):
1391 if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
1392 fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
1394 iprot.readStructBegin()
1396 (fname, ftype, fid) = iprot.readFieldBegin()
1397 if ftype == TType.STOP:
1400 if ftype == TType.BYTE:
1401 self.messageType = iprot.readByte()
1405 if ftype == TType.STRING:
1406 self.domino_udid = iprot.readString()
1410 if ftype == TType.I64:
1411 self.seq_no = iprot.readI64()
1415 if ftype == TType.BYTE:
1416 self.responseCode = iprot.readByte()
1420 if ftype == TType.LIST:
1421 self.queryResponse = []
1422 (_etype73, _size70) = iprot.readListBegin()
1423 for _i74 in xrange(_size70):
1424 _elem75 = iprot.readString()
1425 self.queryResponse.append(_elem75)
1431 iprot.readFieldEnd()
1432 iprot.readStructEnd()
1434 def write(self, oprot):
1435 if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
1436 oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
1438 oprot.writeStructBegin('QueryResponseMessage')
1439 if self.messageType is not None:
1440 oprot.writeFieldBegin('messageType', TType.BYTE, 1)
1441 oprot.writeByte(self.messageType)
1442 oprot.writeFieldEnd()
1443 if self.domino_udid is not None:
1444 oprot.writeFieldBegin('domino_udid', TType.STRING, 2)
1445 oprot.writeString(self.domino_udid)
1446 oprot.writeFieldEnd()
1447 if self.seq_no is not None:
1448 oprot.writeFieldBegin('seq_no', TType.I64, 3)
1449 oprot.writeI64(self.seq_no)
1450 oprot.writeFieldEnd()
1451 if self.responseCode is not None:
1452 oprot.writeFieldBegin('responseCode', TType.BYTE, 4)
1453 oprot.writeByte(self.responseCode)
1454 oprot.writeFieldEnd()
1455 if self.queryResponse is not None:
1456 oprot.writeFieldBegin('queryResponse', TType.LIST, 5)
1457 oprot.writeListBegin(TType.STRING, len(self.queryResponse))
1458 for iter76 in self.queryResponse:
1459 oprot.writeString(iter76)
1460 oprot.writeListEnd()
1461 oprot.writeFieldEnd()
1462 oprot.writeFieldStop()
1463 oprot.writeStructEnd()
1471 value = (value * 31) ^ hash(self.messageType)
1472 value = (value * 31) ^ hash(self.domino_udid)
1473 value = (value * 31) ^ hash(self.seq_no)
1474 value = (value * 31) ^ hash(self.responseCode)
1475 value = (value * 31) ^ hash(self.queryResponse)
1479 L = ['%s=%r' % (key, value)
1480 for key, value in self.__dict__.iteritems()]
1481 return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
1483 def __eq__(self, other):
1484 return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
1486 def __ne__(self, other):
1487 return not (self == other)