serializer_types.go 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595
  1. /*
  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
  9. *
  10. * http://www.apache.org/licenses/LICENSE-2.0
  11. *
  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
  17. * under the License.
  18. */
  19. package thrift
  20. // Autogenerated by Thrift Compiler (1.0.0-dev)
  21. // DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
  22. /* THE FOLLOWING THRIFT FILE WAS USED TO CREATE THIS
  23. enum TestEnum {
  24. FIRST = 1,
  25. SECOND = 2,
  26. THIRD = 3,
  27. FOURTH = 4,
  28. }
  29. struct TestStruct {
  30. 1: bool on,
  31. 2: byte b,
  32. 3: i16 int16,
  33. 4: i32 int32,
  34. 5: i64 int64,
  35. 6: double d,
  36. 7: string st,
  37. 8: binary bin,
  38. 9: map<string, string> stringMap,
  39. 10: list<string> stringList,
  40. 11: set<string> stringSet,
  41. 12: TestEnum e,
  42. }
  43. */
  44. import (
  45. "fmt"
  46. )
  47. // (needed to ensure safety because of naive import list construction.)
  48. var _ = ZERO
  49. var _ = fmt.Printf
  50. var GoUnusedProtection__ int
  51. type TestEnum int64
  52. const (
  53. TestEnum_FIRST TestEnum = 1
  54. TestEnum_SECOND TestEnum = 2
  55. TestEnum_THIRD TestEnum = 3
  56. TestEnum_FOURTH TestEnum = 4
  57. )
  58. func (p TestEnum) String() string {
  59. switch p {
  60. case TestEnum_FIRST:
  61. return "TestEnum_FIRST"
  62. case TestEnum_SECOND:
  63. return "TestEnum_SECOND"
  64. case TestEnum_THIRD:
  65. return "TestEnum_THIRD"
  66. case TestEnum_FOURTH:
  67. return "TestEnum_FOURTH"
  68. }
  69. return "<UNSET>"
  70. }
  71. func TestEnumFromString(s string) (TestEnum, error) {
  72. switch s {
  73. case "TestEnum_FIRST":
  74. return TestEnum_FIRST, nil
  75. case "TestEnum_SECOND":
  76. return TestEnum_SECOND, nil
  77. case "TestEnum_THIRD":
  78. return TestEnum_THIRD, nil
  79. case "TestEnum_FOURTH":
  80. return TestEnum_FOURTH, nil
  81. }
  82. return TestEnum(0), fmt.Errorf("not a valid TestEnum string")
  83. }
  84. func TestEnumPtr(v TestEnum) *TestEnum { return &v }
  85. type TestStruct struct {
  86. On bool `thrift:"on,1"`
  87. B int8 `thrift:"b,2"`
  88. Int16 int16 `thrift:"int16,3"`
  89. Int32 int32 `thrift:"int32,4"`
  90. Int64 int64 `thrift:"int64,5"`
  91. D float64 `thrift:"d,6"`
  92. St string `thrift:"st,7"`
  93. Bin []byte `thrift:"bin,8"`
  94. StringMap map[string]string `thrift:"stringMap,9"`
  95. StringList []string `thrift:"stringList,10"`
  96. StringSet map[string]bool `thrift:"stringSet,11"`
  97. E TestEnum `thrift:"e,12"`
  98. }
  99. func NewTestStruct() *TestStruct {
  100. rval := &TestStruct{}
  101. return rval
  102. }
  103. func (p *TestStruct) Read(iprot TProtocol) error {
  104. if _, err := iprot.ReadStructBegin(); err != nil {
  105. return fmt.Errorf("%T read error: %s", p, err)
  106. }
  107. for {
  108. _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin()
  109. if err != nil {
  110. return fmt.Errorf("%T field %d read error: %s", p, fieldId, err)
  111. }
  112. if fieldTypeId == STOP {
  113. break
  114. }
  115. switch fieldId {
  116. case 1:
  117. if err := p.readField1(iprot); err != nil {
  118. return err
  119. }
  120. case 2:
  121. if err := p.readField2(iprot); err != nil {
  122. return err
  123. }
  124. case 3:
  125. if err := p.readField3(iprot); err != nil {
  126. return err
  127. }
  128. case 4:
  129. if err := p.readField4(iprot); err != nil {
  130. return err
  131. }
  132. case 5:
  133. if err := p.readField5(iprot); err != nil {
  134. return err
  135. }
  136. case 6:
  137. if err := p.readField6(iprot); err != nil {
  138. return err
  139. }
  140. case 7:
  141. if err := p.readField7(iprot); err != nil {
  142. return err
  143. }
  144. case 8:
  145. if err := p.readField8(iprot); err != nil {
  146. return err
  147. }
  148. case 9:
  149. if err := p.readField9(iprot); err != nil {
  150. return err
  151. }
  152. case 10:
  153. if err := p.readField10(iprot); err != nil {
  154. return err
  155. }
  156. case 11:
  157. if err := p.readField11(iprot); err != nil {
  158. return err
  159. }
  160. case 12:
  161. if err := p.readField12(iprot); err != nil {
  162. return err
  163. }
  164. default:
  165. if err := iprot.Skip(fieldTypeId); err != nil {
  166. return err
  167. }
  168. }
  169. if err := iprot.ReadFieldEnd(); err != nil {
  170. return err
  171. }
  172. }
  173. if err := iprot.ReadStructEnd(); err != nil {
  174. return fmt.Errorf("%T read struct end error: %s", p, err)
  175. }
  176. return nil
  177. }
  178. func (p *TestStruct) readField1(iprot TProtocol) error {
  179. if v, err := iprot.ReadBool(); err != nil {
  180. return fmt.Errorf("error reading field 1: %s", err)
  181. } else {
  182. p.On = v
  183. }
  184. return nil
  185. }
  186. func (p *TestStruct) readField2(iprot TProtocol) error {
  187. if v, err := iprot.ReadByte(); err != nil {
  188. return fmt.Errorf("error reading field 2: %s", err)
  189. } else {
  190. temp := int8(v)
  191. p.B = temp
  192. }
  193. return nil
  194. }
  195. func (p *TestStruct) readField3(iprot TProtocol) error {
  196. if v, err := iprot.ReadI16(); err != nil {
  197. return fmt.Errorf("error reading field 3: %s", err)
  198. } else {
  199. p.Int16 = v
  200. }
  201. return nil
  202. }
  203. func (p *TestStruct) readField4(iprot TProtocol) error {
  204. if v, err := iprot.ReadI32(); err != nil {
  205. return fmt.Errorf("error reading field 4: %s", err)
  206. } else {
  207. p.Int32 = v
  208. }
  209. return nil
  210. }
  211. func (p *TestStruct) readField5(iprot TProtocol) error {
  212. if v, err := iprot.ReadI64(); err != nil {
  213. return fmt.Errorf("error reading field 5: %s", err)
  214. } else {
  215. p.Int64 = v
  216. }
  217. return nil
  218. }
  219. func (p *TestStruct) readField6(iprot TProtocol) error {
  220. if v, err := iprot.ReadDouble(); err != nil {
  221. return fmt.Errorf("error reading field 6: %s", err)
  222. } else {
  223. p.D = v
  224. }
  225. return nil
  226. }
  227. func (p *TestStruct) readField7(iprot TProtocol) error {
  228. if v, err := iprot.ReadString(); err != nil {
  229. return fmt.Errorf("error reading field 7: %s", err)
  230. } else {
  231. p.St = v
  232. }
  233. return nil
  234. }
  235. func (p *TestStruct) readField8(iprot TProtocol) error {
  236. if v, err := iprot.ReadBinary(); err != nil {
  237. return fmt.Errorf("error reading field 8: %s", err)
  238. } else {
  239. p.Bin = v
  240. }
  241. return nil
  242. }
  243. func (p *TestStruct) readField9(iprot TProtocol) error {
  244. _, _, size, err := iprot.ReadMapBegin()
  245. if err != nil {
  246. return fmt.Errorf("error reading map begin: %s")
  247. }
  248. tMap := make(map[string]string, size)
  249. p.StringMap = tMap
  250. for i := 0; i < size; i++ {
  251. var _key0 string
  252. if v, err := iprot.ReadString(); err != nil {
  253. return fmt.Errorf("error reading field 0: %s", err)
  254. } else {
  255. _key0 = v
  256. }
  257. var _val1 string
  258. if v, err := iprot.ReadString(); err != nil {
  259. return fmt.Errorf("error reading field 0: %s", err)
  260. } else {
  261. _val1 = v
  262. }
  263. p.StringMap[_key0] = _val1
  264. }
  265. if err := iprot.ReadMapEnd(); err != nil {
  266. return fmt.Errorf("error reading map end: %s")
  267. }
  268. return nil
  269. }
  270. func (p *TestStruct) readField10(iprot TProtocol) error {
  271. _, size, err := iprot.ReadListBegin()
  272. if err != nil {
  273. return fmt.Errorf("error reading list begin: %s")
  274. }
  275. tSlice := make([]string, 0, size)
  276. p.StringList = tSlice
  277. for i := 0; i < size; i++ {
  278. var _elem2 string
  279. if v, err := iprot.ReadString(); err != nil {
  280. return fmt.Errorf("error reading field 0: %s", err)
  281. } else {
  282. _elem2 = v
  283. }
  284. p.StringList = append(p.StringList, _elem2)
  285. }
  286. if err := iprot.ReadListEnd(); err != nil {
  287. return fmt.Errorf("error reading list end: %s")
  288. }
  289. return nil
  290. }
  291. func (p *TestStruct) readField11(iprot TProtocol) error {
  292. _, size, err := iprot.ReadSetBegin()
  293. if err != nil {
  294. return fmt.Errorf("error reading set begin: %s")
  295. }
  296. tSet := make(map[string]bool, size)
  297. p.StringSet = tSet
  298. for i := 0; i < size; i++ {
  299. var _elem3 string
  300. if v, err := iprot.ReadString(); err != nil {
  301. return fmt.Errorf("error reading field 0: %s", err)
  302. } else {
  303. _elem3 = v
  304. }
  305. p.StringSet[_elem3] = true
  306. }
  307. if err := iprot.ReadSetEnd(); err != nil {
  308. return fmt.Errorf("error reading set end: %s")
  309. }
  310. return nil
  311. }
  312. func (p *TestStruct) readField12(iprot TProtocol) error {
  313. if v, err := iprot.ReadI32(); err != nil {
  314. return fmt.Errorf("error reading field 12: %s", err)
  315. } else {
  316. temp := TestEnum(v)
  317. p.E = temp
  318. }
  319. return nil
  320. }
  321. func (p *TestStruct) Write(oprot TProtocol) error {
  322. if err := oprot.WriteStructBegin("TestStruct"); err != nil {
  323. return fmt.Errorf("%T write struct begin error: %s", p, err)
  324. }
  325. if err := p.writeField1(oprot); err != nil {
  326. return err
  327. }
  328. if err := p.writeField2(oprot); err != nil {
  329. return err
  330. }
  331. if err := p.writeField3(oprot); err != nil {
  332. return err
  333. }
  334. if err := p.writeField4(oprot); err != nil {
  335. return err
  336. }
  337. if err := p.writeField5(oprot); err != nil {
  338. return err
  339. }
  340. if err := p.writeField6(oprot); err != nil {
  341. return err
  342. }
  343. if err := p.writeField7(oprot); err != nil {
  344. return err
  345. }
  346. if err := p.writeField8(oprot); err != nil {
  347. return err
  348. }
  349. if err := p.writeField9(oprot); err != nil {
  350. return err
  351. }
  352. if err := p.writeField10(oprot); err != nil {
  353. return err
  354. }
  355. if err := p.writeField11(oprot); err != nil {
  356. return err
  357. }
  358. if err := p.writeField12(oprot); err != nil {
  359. return err
  360. }
  361. if err := oprot.WriteFieldStop(); err != nil {
  362. return fmt.Errorf("write field stop error: %s", err)
  363. }
  364. if err := oprot.WriteStructEnd(); err != nil {
  365. return fmt.Errorf("write struct stop error: %s", err)
  366. }
  367. return nil
  368. }
  369. func (p *TestStruct) writeField1(oprot TProtocol) (err error) {
  370. if err := oprot.WriteFieldBegin("on", BOOL, 1); err != nil {
  371. return fmt.Errorf("%T write field begin error 1:on: %s", p, err)
  372. }
  373. if err := oprot.WriteBool(bool(p.On)); err != nil {
  374. return fmt.Errorf("%T.on (1) field write error: %s", p, err)
  375. }
  376. if err := oprot.WriteFieldEnd(); err != nil {
  377. return fmt.Errorf("%T write field end error 1:on: %s", p, err)
  378. }
  379. return err
  380. }
  381. func (p *TestStruct) writeField2(oprot TProtocol) (err error) {
  382. if err := oprot.WriteFieldBegin("b", BYTE, 2); err != nil {
  383. return fmt.Errorf("%T write field begin error 2:b: %s", p, err)
  384. }
  385. if err := oprot.WriteByte(byte(p.B)); err != nil {
  386. return fmt.Errorf("%T.b (2) field write error: %s", p, err)
  387. }
  388. if err := oprot.WriteFieldEnd(); err != nil {
  389. return fmt.Errorf("%T write field end error 2:b: %s", p, err)
  390. }
  391. return err
  392. }
  393. func (p *TestStruct) writeField3(oprot TProtocol) (err error) {
  394. if err := oprot.WriteFieldBegin("int16", I16, 3); err != nil {
  395. return fmt.Errorf("%T write field begin error 3:int16: %s", p, err)
  396. }
  397. if err := oprot.WriteI16(int16(p.Int16)); err != nil {
  398. return fmt.Errorf("%T.int16 (3) field write error: %s", p, err)
  399. }
  400. if err := oprot.WriteFieldEnd(); err != nil {
  401. return fmt.Errorf("%T write field end error 3:int16: %s", p, err)
  402. }
  403. return err
  404. }
  405. func (p *TestStruct) writeField4(oprot TProtocol) (err error) {
  406. if err := oprot.WriteFieldBegin("int32", I32, 4); err != nil {
  407. return fmt.Errorf("%T write field begin error 4:int32: %s", p, err)
  408. }
  409. if err := oprot.WriteI32(int32(p.Int32)); err != nil {
  410. return fmt.Errorf("%T.int32 (4) field write error: %s", p, err)
  411. }
  412. if err := oprot.WriteFieldEnd(); err != nil {
  413. return fmt.Errorf("%T write field end error 4:int32: %s", p, err)
  414. }
  415. return err
  416. }
  417. func (p *TestStruct) writeField5(oprot TProtocol) (err error) {
  418. if err := oprot.WriteFieldBegin("int64", I64, 5); err != nil {
  419. return fmt.Errorf("%T write field begin error 5:int64: %s", p, err)
  420. }
  421. if err := oprot.WriteI64(int64(p.Int64)); err != nil {
  422. return fmt.Errorf("%T.int64 (5) field write error: %s", p, err)
  423. }
  424. if err := oprot.WriteFieldEnd(); err != nil {
  425. return fmt.Errorf("%T write field end error 5:int64: %s", p, err)
  426. }
  427. return err
  428. }
  429. func (p *TestStruct) writeField6(oprot TProtocol) (err error) {
  430. if err := oprot.WriteFieldBegin("d", DOUBLE, 6); err != nil {
  431. return fmt.Errorf("%T write field begin error 6:d: %s", p, err)
  432. }
  433. if err := oprot.WriteDouble(float64(p.D)); err != nil {
  434. return fmt.Errorf("%T.d (6) field write error: %s", p, err)
  435. }
  436. if err := oprot.WriteFieldEnd(); err != nil {
  437. return fmt.Errorf("%T write field end error 6:d: %s", p, err)
  438. }
  439. return err
  440. }
  441. func (p *TestStruct) writeField7(oprot TProtocol) (err error) {
  442. if err := oprot.WriteFieldBegin("st", STRING, 7); err != nil {
  443. return fmt.Errorf("%T write field begin error 7:st: %s", p, err)
  444. }
  445. if err := oprot.WriteString(string(p.St)); err != nil {
  446. return fmt.Errorf("%T.st (7) field write error: %s", p, err)
  447. }
  448. if err := oprot.WriteFieldEnd(); err != nil {
  449. return fmt.Errorf("%T write field end error 7:st: %s", p, err)
  450. }
  451. return err
  452. }
  453. func (p *TestStruct) writeField8(oprot TProtocol) (err error) {
  454. if p.Bin != nil {
  455. if err := oprot.WriteFieldBegin("bin", STRING, 8); err != nil {
  456. return fmt.Errorf("%T write field begin error 8:bin: %s", p, err)
  457. }
  458. if err := oprot.WriteBinary(p.Bin); err != nil {
  459. return fmt.Errorf("%T.bin (8) field write error: %s", p, err)
  460. }
  461. if err := oprot.WriteFieldEnd(); err != nil {
  462. return fmt.Errorf("%T write field end error 8:bin: %s", p, err)
  463. }
  464. }
  465. return err
  466. }
  467. func (p *TestStruct) writeField9(oprot TProtocol) (err error) {
  468. if p.StringMap != nil {
  469. if err := oprot.WriteFieldBegin("stringMap", MAP, 9); err != nil {
  470. return fmt.Errorf("%T write field begin error 9:stringMap: %s", p, err)
  471. }
  472. if err := oprot.WriteMapBegin(STRING, STRING, len(p.StringMap)); err != nil {
  473. return fmt.Errorf("error writing map begin: %s")
  474. }
  475. for k, v := range p.StringMap {
  476. if err := oprot.WriteString(string(k)); err != nil {
  477. return fmt.Errorf("%T. (0) field write error: %s", p, err)
  478. }
  479. if err := oprot.WriteString(string(v)); err != nil {
  480. return fmt.Errorf("%T. (0) field write error: %s", p, err)
  481. }
  482. }
  483. if err := oprot.WriteMapEnd(); err != nil {
  484. return fmt.Errorf("error writing map end: %s")
  485. }
  486. if err := oprot.WriteFieldEnd(); err != nil {
  487. return fmt.Errorf("%T write field end error 9:stringMap: %s", p, err)
  488. }
  489. }
  490. return err
  491. }
  492. func (p *TestStruct) writeField10(oprot TProtocol) (err error) {
  493. if p.StringList != nil {
  494. if err := oprot.WriteFieldBegin("stringList", LIST, 10); err != nil {
  495. return fmt.Errorf("%T write field begin error 10:stringList: %s", p, err)
  496. }
  497. if err := oprot.WriteListBegin(STRING, len(p.StringList)); err != nil {
  498. return fmt.Errorf("error writing list begin: %s")
  499. }
  500. for _, v := range p.StringList {
  501. if err := oprot.WriteString(string(v)); err != nil {
  502. return fmt.Errorf("%T. (0) field write error: %s", p, err)
  503. }
  504. }
  505. if err := oprot.WriteListEnd(); err != nil {
  506. return fmt.Errorf("error writing list end: %s")
  507. }
  508. if err := oprot.WriteFieldEnd(); err != nil {
  509. return fmt.Errorf("%T write field end error 10:stringList: %s", p, err)
  510. }
  511. }
  512. return err
  513. }
  514. func (p *TestStruct) writeField11(oprot TProtocol) (err error) {
  515. if p.StringSet != nil {
  516. if err := oprot.WriteFieldBegin("stringSet", SET, 11); err != nil {
  517. return fmt.Errorf("%T write field begin error 11:stringSet: %s", p, err)
  518. }
  519. if err := oprot.WriteSetBegin(STRING, len(p.StringSet)); err != nil {
  520. return fmt.Errorf("error writing set begin: %s")
  521. }
  522. for v, _ := range p.StringSet {
  523. if err := oprot.WriteString(string(v)); err != nil {
  524. return fmt.Errorf("%T. (0) field write error: %s", p, err)
  525. }
  526. }
  527. if err := oprot.WriteSetEnd(); err != nil {
  528. return fmt.Errorf("error writing set end: %s")
  529. }
  530. if err := oprot.WriteFieldEnd(); err != nil {
  531. return fmt.Errorf("%T write field end error 11:stringSet: %s", p, err)
  532. }
  533. }
  534. return err
  535. }
  536. func (p *TestStruct) writeField12(oprot TProtocol) (err error) {
  537. if err := oprot.WriteFieldBegin("e", I32, 12); err != nil {
  538. return fmt.Errorf("%T write field begin error 12:e: %s", p, err)
  539. }
  540. if err := oprot.WriteI32(int32(p.E)); err != nil {
  541. return fmt.Errorf("%T.e (12) field write error: %s", p, err)
  542. }
  543. if err := oprot.WriteFieldEnd(); err != nil {
  544. return fmt.Errorf("%T write field end error 12:e: %s", p, err)
  545. }
  546. return err
  547. }
  548. func (p *TestStruct) String() string {
  549. if p == nil {
  550. return "<nil>"
  551. }
  552. return fmt.Sprintf("TestStruct(%+v)", *p)
  553. }