| 28317 | } |
| 28318 | |
| 28319 | func (p *IClientRPCServiceFetchResultsV2Args) Read(ctx context.Context, iprot thrift.TProtocol) error { |
| 28320 | if _, err := iprot.ReadStructBegin(ctx); err != nil { |
| 28321 | return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) |
| 28322 | } |
| 28323 | |
| 28324 | |
| 28325 | for { |
| 28326 | _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) |
| 28327 | if err != nil { |
| 28328 | return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) |
| 28329 | } |
| 28330 | if fieldTypeId == thrift.STOP { break; } |
| 28331 | switch fieldId { |
| 28332 | case 1: |
| 28333 | if fieldTypeId == thrift.STRUCT { |
| 28334 | if err := p.ReadField1(ctx, iprot); err != nil { |
| 28335 | return err |
| 28336 | } |
| 28337 | } else { |
| 28338 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 28339 | return err |
| 28340 | } |
| 28341 | } |
| 28342 | default: |
| 28343 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 28344 | return err |
| 28345 | } |
| 28346 | } |
| 28347 | if err := iprot.ReadFieldEnd(ctx); err != nil { |
| 28348 | return err |
| 28349 | } |
| 28350 | } |
| 28351 | if err := iprot.ReadStructEnd(ctx); err != nil { |
| 28352 | return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) |
| 28353 | } |
| 28354 | return nil |
| 28355 | } |
| 28356 | |
| 28357 | func (p *IClientRPCServiceFetchResultsV2Args) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { |
| 28358 | p.Req = &TSFetchResultsReq{} |