| 32950 | } |
| 32951 | |
| 32952 | func (p *IClientRPCServiceInsertRecordArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { |
| 32953 | if _, err := iprot.ReadStructBegin(ctx); err != nil { |
| 32954 | return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) |
| 32955 | } |
| 32956 | |
| 32957 | |
| 32958 | for { |
| 32959 | _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) |
| 32960 | if err != nil { |
| 32961 | return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) |
| 32962 | } |
| 32963 | if fieldTypeId == thrift.STOP { break; } |
| 32964 | switch fieldId { |
| 32965 | case 1: |
| 32966 | if fieldTypeId == thrift.STRUCT { |
| 32967 | if err := p.ReadField1(ctx, iprot); err != nil { |
| 32968 | return err |
| 32969 | } |
| 32970 | } else { |
| 32971 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 32972 | return err |
| 32973 | } |
| 32974 | } |
| 32975 | default: |
| 32976 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 32977 | return err |
| 32978 | } |
| 32979 | } |
| 32980 | if err := iprot.ReadFieldEnd(ctx); err != nil { |
| 32981 | return err |
| 32982 | } |
| 32983 | } |
| 32984 | if err := iprot.ReadStructEnd(ctx); err != nil { |
| 32985 | return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) |
| 32986 | } |
| 32987 | return nil |
| 32988 | } |
| 32989 | |
| 32990 | func (p *IClientRPCServiceInsertRecordArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { |
| 32991 | p.Req = &TSInsertRecordReq{} |