| 36118 | } |
| 36119 | |
| 36120 | func (p *IClientRPCServiceExecuteRawDataQueryArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { |
| 36121 | if _, err := iprot.ReadStructBegin(ctx); err != nil { |
| 36122 | return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) |
| 36123 | } |
| 36124 | |
| 36125 | |
| 36126 | for { |
| 36127 | _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) |
| 36128 | if err != nil { |
| 36129 | return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) |
| 36130 | } |
| 36131 | if fieldTypeId == thrift.STOP { break; } |
| 36132 | switch fieldId { |
| 36133 | case 1: |
| 36134 | if fieldTypeId == thrift.STRUCT { |
| 36135 | if err := p.ReadField1(ctx, iprot); err != nil { |
| 36136 | return err |
| 36137 | } |
| 36138 | } else { |
| 36139 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 36140 | return err |
| 36141 | } |
| 36142 | } |
| 36143 | default: |
| 36144 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 36145 | return err |
| 36146 | } |
| 36147 | } |
| 36148 | if err := iprot.ReadFieldEnd(ctx); err != nil { |
| 36149 | return err |
| 36150 | } |
| 36151 | } |
| 36152 | if err := iprot.ReadStructEnd(ctx); err != nil { |
| 36153 | return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) |
| 36154 | } |
| 36155 | return nil |
| 36156 | } |
| 36157 | |
| 36158 | func (p *IClientRPCServiceExecuteRawDataQueryArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { |
| 36159 | p.Req = &TSRawDataQueryReq{} |