2 * Licensed to the Apache Software Foundation (ASF) under one
3 * or more contributor license agreements. See the NOTICE file
4 * distributed with this work for additional information
5 * regarding copyright ownership. The ASF licenses this file
6 * to you under the Apache License, Version 2.0 (the
7 * "License"); you may not use this file except in compliance
8 * with the License. You may obtain a copy of the License at
10 * http://www.apache.org/licenses/LICENSE-2.0
12 * Unless required by applicable law or agreed to in writing,
13 * software distributed under the License is distributed on an
14 * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
15 * KIND, either express or implied. See the License for the
16 * specific language governing permissions and limitations
22 // Autogenerated by Thrift Compiler (FIXME)
23 // DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
25 /* THE FOLLOWING THRIFT FILE WAS USED TO CREATE THIS
43 9: map<string, string> stringMap,
44 10: list<string> stringList,
45 11: set<string> stringSet,
54 // (needed to ensure safety because of naive import list construction.)
58 var GoUnusedProtection__ int
63 MyTestEnum_FIRST MyTestEnum = 1
64 MyTestEnum_SECOND MyTestEnum = 2
65 MyTestEnum_THIRD MyTestEnum = 3
66 MyTestEnum_FOURTH MyTestEnum = 4
69 func (p MyTestEnum) String() string {
71 case MyTestEnum_FIRST:
73 case MyTestEnum_SECOND:
75 case MyTestEnum_THIRD:
77 case MyTestEnum_FOURTH:
83 func MyTestEnumFromString(s string) (MyTestEnum, error) {
86 return MyTestEnum_FIRST, nil
88 return MyTestEnum_SECOND, nil
90 return MyTestEnum_THIRD, nil
92 return MyTestEnum_FOURTH, nil
94 return MyTestEnum(0), fmt.Errorf("not a valid MyTestEnum string")
97 func MyTestEnumPtr(v MyTestEnum) *MyTestEnum { return &v }
99 type MyTestStruct struct {
100 On bool `thrift:"on,1" json:"on"`
101 B int8 `thrift:"b,2" json:"b"`
102 Int16 int16 `thrift:"int16,3" json:"int16"`
103 Int32 int32 `thrift:"int32,4" json:"int32"`
104 Int64 int64 `thrift:"int64,5" json:"int64"`
105 D float64 `thrift:"d,6" json:"d"`
106 St string `thrift:"st,7" json:"st"`
107 Bin []byte `thrift:"bin,8" json:"bin"`
108 StringMap map[string]string `thrift:"stringMap,9" json:"stringMap"`
109 StringList []string `thrift:"stringList,10" json:"stringList"`
110 StringSet map[string]struct{} `thrift:"stringSet,11" json:"stringSet"`
111 E MyTestEnum `thrift:"e,12" json:"e"`
114 func NewMyTestStruct() *MyTestStruct {
115 return &MyTestStruct{}
118 func (p *MyTestStruct) GetOn() bool {
122 func (p *MyTestStruct) GetB() int8 {
126 func (p *MyTestStruct) GetInt16() int16 {
130 func (p *MyTestStruct) GetInt32() int32 {
134 func (p *MyTestStruct) GetInt64() int64 {
138 func (p *MyTestStruct) GetD() float64 {
142 func (p *MyTestStruct) GetSt() string {
146 func (p *MyTestStruct) GetBin() []byte {
150 func (p *MyTestStruct) GetStringMap() map[string]string {
154 func (p *MyTestStruct) GetStringList() []string {
158 func (p *MyTestStruct) GetStringSet() map[string]struct{} {
162 func (p *MyTestStruct) GetE() MyTestEnum {
165 func (p *MyTestStruct) Read(iprot TProtocol) error {
166 if _, err := iprot.ReadStructBegin(); err != nil {
167 return PrependError(fmt.Sprintf("%T read error: ", p), err)
170 _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin()
172 return PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err)
174 if fieldTypeId == STOP {
179 if err := p.readField1(iprot); err != nil {
183 if err := p.readField2(iprot); err != nil {
187 if err := p.readField3(iprot); err != nil {
191 if err := p.readField4(iprot); err != nil {
195 if err := p.readField5(iprot); err != nil {
199 if err := p.readField6(iprot); err != nil {
203 if err := p.readField7(iprot); err != nil {
207 if err := p.readField8(iprot); err != nil {
211 if err := p.readField9(iprot); err != nil {
215 if err := p.readField10(iprot); err != nil {
219 if err := p.readField11(iprot); err != nil {
223 if err := p.readField12(iprot); err != nil {
227 if err := iprot.Skip(fieldTypeId); err != nil {
231 if err := iprot.ReadFieldEnd(); err != nil {
235 if err := iprot.ReadStructEnd(); err != nil {
236 return PrependError(fmt.Sprintf("%T read struct end error: ", p), err)
241 func (p *MyTestStruct) readField1(iprot TProtocol) error {
242 if v, err := iprot.ReadBool(); err != nil {
243 return PrependError("error reading field 1: ", err)
250 func (p *MyTestStruct) readField2(iprot TProtocol) error {
251 if v, err := iprot.ReadByte(); err != nil {
252 return PrependError("error reading field 2: ", err)
260 func (p *MyTestStruct) readField3(iprot TProtocol) error {
261 if v, err := iprot.ReadI16(); err != nil {
262 return PrependError("error reading field 3: ", err)
269 func (p *MyTestStruct) readField4(iprot TProtocol) error {
270 if v, err := iprot.ReadI32(); err != nil {
271 return PrependError("error reading field 4: ", err)
278 func (p *MyTestStruct) readField5(iprot TProtocol) error {
279 if v, err := iprot.ReadI64(); err != nil {
280 return PrependError("error reading field 5: ", err)
287 func (p *MyTestStruct) readField6(iprot TProtocol) error {
288 if v, err := iprot.ReadDouble(); err != nil {
289 return PrependError("error reading field 6: ", err)
296 func (p *MyTestStruct) readField7(iprot TProtocol) error {
297 if v, err := iprot.ReadString(); err != nil {
298 return PrependError("error reading field 7: ", err)
305 func (p *MyTestStruct) readField8(iprot TProtocol) error {
306 if v, err := iprot.ReadBinary(); err != nil {
307 return PrependError("error reading field 8: ", err)
314 func (p *MyTestStruct) readField9(iprot TProtocol) error {
315 _, _, size, err := iprot.ReadMapBegin()
317 return PrependError("error reading map begin: ", err)
319 tMap := make(map[string]string, size)
321 for i := 0; i < size; i++ {
323 if v, err := iprot.ReadString(); err != nil {
324 return PrependError("error reading field 0: ", err)
329 if v, err := iprot.ReadString(); err != nil {
330 return PrependError("error reading field 0: ", err)
334 p.StringMap[_key0] = _val1
336 if err := iprot.ReadMapEnd(); err != nil {
337 return PrependError("error reading map end: ", err)
342 func (p *MyTestStruct) readField10(iprot TProtocol) error {
343 _, size, err := iprot.ReadListBegin()
345 return PrependError("error reading list begin: ", err)
347 tSlice := make([]string, 0, size)
348 p.StringList = tSlice
349 for i := 0; i < size; i++ {
351 if v, err := iprot.ReadString(); err != nil {
352 return PrependError("error reading field 0: ", err)
356 p.StringList = append(p.StringList, _elem2)
358 if err := iprot.ReadListEnd(); err != nil {
359 return PrependError("error reading list end: ", err)
364 func (p *MyTestStruct) readField11(iprot TProtocol) error {
365 _, size, err := iprot.ReadSetBegin()
367 return PrependError("error reading set begin: ", err)
369 tSet := make(map[string]struct{}, size)
371 for i := 0; i < size; i++ {
373 if v, err := iprot.ReadString(); err != nil {
374 return PrependError("error reading field 0: ", err)
378 p.StringSet[_elem3] = struct{}{}
380 if err := iprot.ReadSetEnd(); err != nil {
381 return PrependError("error reading set end: ", err)
386 func (p *MyTestStruct) readField12(iprot TProtocol) error {
387 if v, err := iprot.ReadI32(); err != nil {
388 return PrependError("error reading field 12: ", err)
390 temp := MyTestEnum(v)
396 func (p *MyTestStruct) Write(oprot TProtocol) error {
397 if err := oprot.WriteStructBegin("MyTestStruct"); err != nil {
398 return PrependError(fmt.Sprintf("%T write struct begin error: ", p), err)
400 if err := p.writeField1(oprot); err != nil {
403 if err := p.writeField2(oprot); err != nil {
406 if err := p.writeField3(oprot); err != nil {
409 if err := p.writeField4(oprot); err != nil {
412 if err := p.writeField5(oprot); err != nil {
415 if err := p.writeField6(oprot); err != nil {
418 if err := p.writeField7(oprot); err != nil {
421 if err := p.writeField8(oprot); err != nil {
424 if err := p.writeField9(oprot); err != nil {
427 if err := p.writeField10(oprot); err != nil {
430 if err := p.writeField11(oprot); err != nil {
433 if err := p.writeField12(oprot); err != nil {
436 if err := oprot.WriteFieldStop(); err != nil {
437 return PrependError("write field stop error: ", err)
439 if err := oprot.WriteStructEnd(); err != nil {
440 return PrependError("write struct stop error: ", err)
445 func (p *MyTestStruct) writeField1(oprot TProtocol) (err error) {
446 if err := oprot.WriteFieldBegin("on", BOOL, 1); err != nil {
447 return PrependError(fmt.Sprintf("%T write field begin error 1:on: ", p), err)
449 if err := oprot.WriteBool(bool(p.On)); err != nil {
450 return PrependError(fmt.Sprintf("%T.on (1) field write error: ", p), err)
452 if err := oprot.WriteFieldEnd(); err != nil {
453 return PrependError(fmt.Sprintf("%T write field end error 1:on: ", p), err)
458 func (p *MyTestStruct) writeField2(oprot TProtocol) (err error) {
459 if err := oprot.WriteFieldBegin("b", BYTE, 2); err != nil {
460 return PrependError(fmt.Sprintf("%T write field begin error 2:b: ", p), err)
462 if err := oprot.WriteByte(int8(p.B)); err != nil {
463 return PrependError(fmt.Sprintf("%T.b (2) field write error: ", p), err)
465 if err := oprot.WriteFieldEnd(); err != nil {
466 return PrependError(fmt.Sprintf("%T write field end error 2:b: ", p), err)
471 func (p *MyTestStruct) writeField3(oprot TProtocol) (err error) {
472 if err := oprot.WriteFieldBegin("int16", I16, 3); err != nil {
473 return PrependError(fmt.Sprintf("%T write field begin error 3:int16: ", p), err)
475 if err := oprot.WriteI16(int16(p.Int16)); err != nil {
476 return PrependError(fmt.Sprintf("%T.int16 (3) field write error: ", p), err)
478 if err := oprot.WriteFieldEnd(); err != nil {
479 return PrependError(fmt.Sprintf("%T write field end error 3:int16: ", p), err)
484 func (p *MyTestStruct) writeField4(oprot TProtocol) (err error) {
485 if err := oprot.WriteFieldBegin("int32", I32, 4); err != nil {
486 return PrependError(fmt.Sprintf("%T write field begin error 4:int32: ", p), err)
488 if err := oprot.WriteI32(int32(p.Int32)); err != nil {
489 return PrependError(fmt.Sprintf("%T.int32 (4) field write error: ", p), err)
491 if err := oprot.WriteFieldEnd(); err != nil {
492 return PrependError(fmt.Sprintf("%T write field end error 4:int32: ", p), err)
497 func (p *MyTestStruct) writeField5(oprot TProtocol) (err error) {
498 if err := oprot.WriteFieldBegin("int64", I64, 5); err != nil {
499 return PrependError(fmt.Sprintf("%T write field begin error 5:int64: ", p), err)
501 if err := oprot.WriteI64(int64(p.Int64)); err != nil {
502 return PrependError(fmt.Sprintf("%T.int64 (5) field write error: ", p), err)
504 if err := oprot.WriteFieldEnd(); err != nil {
505 return PrependError(fmt.Sprintf("%T write field end error 5:int64: ", p), err)
510 func (p *MyTestStruct) writeField6(oprot TProtocol) (err error) {
511 if err := oprot.WriteFieldBegin("d", DOUBLE, 6); err != nil {
512 return PrependError(fmt.Sprintf("%T write field begin error 6:d: ", p), err)
514 if err := oprot.WriteDouble(float64(p.D)); err != nil {
515 return PrependError(fmt.Sprintf("%T.d (6) field write error: ", p), err)
517 if err := oprot.WriteFieldEnd(); err != nil {
518 return PrependError(fmt.Sprintf("%T write field end error 6:d: ", p), err)
523 func (p *MyTestStruct) writeField7(oprot TProtocol) (err error) {
524 if err := oprot.WriteFieldBegin("st", STRING, 7); err != nil {
525 return PrependError(fmt.Sprintf("%T write field begin error 7:st: ", p), err)
527 if err := oprot.WriteString(string(p.St)); err != nil {
528 return PrependError(fmt.Sprintf("%T.st (7) field write error: ", p), err)
530 if err := oprot.WriteFieldEnd(); err != nil {
531 return PrependError(fmt.Sprintf("%T write field end error 7:st: ", p), err)
536 func (p *MyTestStruct) writeField8(oprot TProtocol) (err error) {
537 if err := oprot.WriteFieldBegin("bin", STRING, 8); err != nil {
538 return PrependError(fmt.Sprintf("%T write field begin error 8:bin: ", p), err)
540 if err := oprot.WriteBinary(p.Bin); err != nil {
541 return PrependError(fmt.Sprintf("%T.bin (8) field write error: ", p), err)
543 if err := oprot.WriteFieldEnd(); err != nil {
544 return PrependError(fmt.Sprintf("%T write field end error 8:bin: ", p), err)
549 func (p *MyTestStruct) writeField9(oprot TProtocol) (err error) {
550 if err := oprot.WriteFieldBegin("stringMap", MAP, 9); err != nil {
551 return PrependError(fmt.Sprintf("%T write field begin error 9:stringMap: ", p), err)
553 if err := oprot.WriteMapBegin(STRING, STRING, len(p.StringMap)); err != nil {
554 return PrependError("error writing map begin: ", err)
556 for k, v := range p.StringMap {
557 if err := oprot.WriteString(string(k)); err != nil {
558 return PrependError(fmt.Sprintf("%T. (0) field write error: ", p), err)
560 if err := oprot.WriteString(string(v)); err != nil {
561 return PrependError(fmt.Sprintf("%T. (0) field write error: ", p), err)
564 if err := oprot.WriteMapEnd(); err != nil {
565 return PrependError("error writing map end: ", err)
567 if err := oprot.WriteFieldEnd(); err != nil {
568 return PrependError(fmt.Sprintf("%T write field end error 9:stringMap: ", p), err)
573 func (p *MyTestStruct) writeField10(oprot TProtocol) (err error) {
574 if err := oprot.WriteFieldBegin("stringList", LIST, 10); err != nil {
575 return PrependError(fmt.Sprintf("%T write field begin error 10:stringList: ", p), err)
577 if err := oprot.WriteListBegin(STRING, len(p.StringList)); err != nil {
578 return PrependError("error writing list begin: ", err)
580 for _, v := range p.StringList {
581 if err := oprot.WriteString(string(v)); err != nil {
582 return PrependError(fmt.Sprintf("%T. (0) field write error: ", p), err)
585 if err := oprot.WriteListEnd(); err != nil {
586 return PrependError("error writing list end: ", err)
588 if err := oprot.WriteFieldEnd(); err != nil {
589 return PrependError(fmt.Sprintf("%T write field end error 10:stringList: ", p), err)
594 func (p *MyTestStruct) writeField11(oprot TProtocol) (err error) {
595 if err := oprot.WriteFieldBegin("stringSet", SET, 11); err != nil {
596 return PrependError(fmt.Sprintf("%T write field begin error 11:stringSet: ", p), err)
598 if err := oprot.WriteSetBegin(STRING, len(p.StringSet)); err != nil {
599 return PrependError("error writing set begin: ", err)
601 for v := range p.StringSet {
602 if err := oprot.WriteString(string(v)); err != nil {
603 return PrependError(fmt.Sprintf("%T. (0) field write error: ", p), err)
606 if err := oprot.WriteSetEnd(); err != nil {
607 return PrependError("error writing set end: ", err)
609 if err := oprot.WriteFieldEnd(); err != nil {
610 return PrependError(fmt.Sprintf("%T write field end error 11:stringSet: ", p), err)
615 func (p *MyTestStruct) writeField12(oprot TProtocol) (err error) {
616 if err := oprot.WriteFieldBegin("e", I32, 12); err != nil {
617 return PrependError(fmt.Sprintf("%T write field begin error 12:e: ", p), err)
619 if err := oprot.WriteI32(int32(p.E)); err != nil {
620 return PrependError(fmt.Sprintf("%T.e (12) field write error: ", p), err)
622 if err := oprot.WriteFieldEnd(); err != nil {
623 return PrependError(fmt.Sprintf("%T write field end error 12:e: ", p), err)
628 func (p *MyTestStruct) String() string {
632 return fmt.Sprintf("MyTestStruct(%+v)", *p)