| 33148 | } |
| 33149 | |
| 33150 | func (p *IClientRPCServiceInsertStringRecordArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { |
| 33151 | if _, err := iprot.ReadStructBegin(ctx); err != nil { |
| 33152 | return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) |
| 33153 | } |
| 33154 | |
| 33155 | |
| 33156 | for { |
| 33157 | _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) |
| 33158 | if err != nil { |
| 33159 | return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) |
| 33160 | } |
| 33161 | if fieldTypeId == thrift.STOP { break; } |
| 33162 | switch fieldId { |
| 33163 | case 1: |
| 33164 | if fieldTypeId == thrift.STRUCT { |
| 33165 | if err := p.ReadField1(ctx, iprot); err != nil { |
| 33166 | return err |
| 33167 | } |
| 33168 | } else { |
| 33169 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 33170 | return err |
| 33171 | } |
| 33172 | } |
| 33173 | default: |
| 33174 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 33175 | return err |
| 33176 | } |
| 33177 | } |
| 33178 | if err := iprot.ReadFieldEnd(ctx); err != nil { |
| 33179 | return err |
| 33180 | } |
| 33181 | } |
| 33182 | if err := iprot.ReadStructEnd(ctx); err != nil { |
| 33183 | return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) |
| 33184 | } |
| 33185 | return nil |
| 33186 | } |
| 33187 | |
| 33188 | func (p *IClientRPCServiceInsertStringRecordArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { |
| 33189 | p.Req = &TSInsertStringRecordReq{} |