| 33742 | } |
| 33743 | |
| 33744 | func (p *IClientRPCServiceInsertRecordsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { |
| 33745 | if _, err := iprot.ReadStructBegin(ctx); err != nil { |
| 33746 | return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) |
| 33747 | } |
| 33748 | |
| 33749 | |
| 33750 | for { |
| 33751 | _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) |
| 33752 | if err != nil { |
| 33753 | return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) |
| 33754 | } |
| 33755 | if fieldTypeId == thrift.STOP { break; } |
| 33756 | switch fieldId { |
| 33757 | case 1: |
| 33758 | if fieldTypeId == thrift.STRUCT { |
| 33759 | if err := p.ReadField1(ctx, iprot); err != nil { |
| 33760 | return err |
| 33761 | } |
| 33762 | } else { |
| 33763 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 33764 | return err |
| 33765 | } |
| 33766 | } |
| 33767 | default: |
| 33768 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 33769 | return err |
| 33770 | } |
| 33771 | } |
| 33772 | if err := iprot.ReadFieldEnd(ctx); err != nil { |
| 33773 | return err |
| 33774 | } |
| 33775 | } |
| 33776 | if err := iprot.ReadStructEnd(ctx); err != nil { |
| 33777 | return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) |
| 33778 | } |
| 33779 | return nil |
| 33780 | } |
| 33781 | |
| 33782 | func (p *IClientRPCServiceInsertRecordsArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { |
| 33783 | p.Req = &TSInsertRecordsReq{} |