| 36705 | return p.SessionId |
| 36706 | } |
| 36707 | func (p *IClientRPCServiceRequestStatementIdArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { |
| 36708 | if _, err := iprot.ReadStructBegin(ctx); err != nil { |
| 36709 | return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) |
| 36710 | } |
| 36711 | |
| 36712 | |
| 36713 | for { |
| 36714 | _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) |
| 36715 | if err != nil { |
| 36716 | return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) |
| 36717 | } |
| 36718 | if fieldTypeId == thrift.STOP { break; } |
| 36719 | switch fieldId { |
| 36720 | case 1: |
| 36721 | if fieldTypeId == thrift.I64 { |
| 36722 | if err := p.ReadField1(ctx, iprot); err != nil { |
| 36723 | return err |
| 36724 | } |
| 36725 | } else { |
| 36726 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 36727 | return err |
| 36728 | } |
| 36729 | } |
| 36730 | default: |
| 36731 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 36732 | return err |
| 36733 | } |
| 36734 | } |
| 36735 | if err := iprot.ReadFieldEnd(ctx); err != nil { |
| 36736 | return err |
| 36737 | } |
| 36738 | } |
| 36739 | if err := iprot.ReadStructEnd(ctx); err != nil { |
| 36740 | return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) |
| 36741 | } |
| 36742 | return nil |
| 36743 | } |
| 36744 | |
| 36745 | func (p *IClientRPCServiceRequestStatementIdArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { |
| 36746 | if v, err := iprot.ReadI64(ctx); err != nil { |