| 31860 | } |
| 31861 | |
| 31862 | func (p *IClientRPCServiceCreateTimeseriesArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { |
| 31863 | if _, err := iprot.ReadStructBegin(ctx); err != nil { |
| 31864 | return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) |
| 31865 | } |
| 31866 | |
| 31867 | |
| 31868 | for { |
| 31869 | _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) |
| 31870 | if err != nil { |
| 31871 | return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) |
| 31872 | } |
| 31873 | if fieldTypeId == thrift.STOP { break; } |
| 31874 | switch fieldId { |
| 31875 | case 1: |
| 31876 | if fieldTypeId == thrift.STRUCT { |
| 31877 | if err := p.ReadField1(ctx, iprot); err != nil { |
| 31878 | return err |
| 31879 | } |
| 31880 | } else { |
| 31881 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 31882 | return err |
| 31883 | } |
| 31884 | } |
| 31885 | default: |
| 31886 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 31887 | return err |
| 31888 | } |
| 31889 | } |
| 31890 | if err := iprot.ReadFieldEnd(ctx); err != nil { |
| 31891 | return err |
| 31892 | } |
| 31893 | } |
| 31894 | if err := iprot.ReadStructEnd(ctx); err != nil { |
| 31895 | return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) |
| 31896 | } |
| 31897 | return nil |
| 31898 | } |
| 31899 | |
| 31900 | func (p *IClientRPCServiceCreateTimeseriesArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { |
| 31901 | p.Req = &TSCreateTimeseriesReq{} |