(ctx context.Context, iprot thrift.TProtocol)
| 32453 | return p.Path |
| 32454 | } |
| 32455 | func (p *IClientRPCServiceDeleteTimeseriesArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { |
| 32456 | if _, err := iprot.ReadStructBegin(ctx); err != nil { |
| 32457 | return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) |
| 32458 | } |
| 32459 | |
| 32460 | |
| 32461 | for { |
| 32462 | _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) |
| 32463 | if err != nil { |
| 32464 | return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) |
| 32465 | } |
| 32466 | if fieldTypeId == thrift.STOP { break; } |
| 32467 | switch fieldId { |
| 32468 | case 1: |
| 32469 | if fieldTypeId == thrift.I64 { |
| 32470 | if err := p.ReadField1(ctx, iprot); err != nil { |
| 32471 | return err |
| 32472 | } |
| 32473 | } else { |
| 32474 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 32475 | return err |
| 32476 | } |
| 32477 | } |
| 32478 | case 2: |
| 32479 | if fieldTypeId == thrift.LIST { |
| 32480 | if err := p.ReadField2(ctx, iprot); err != nil { |
| 32481 | return err |
| 32482 | } |
| 32483 | } else { |
| 32484 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 32485 | return err |
| 32486 | } |
| 32487 | } |
| 32488 | default: |
| 32489 | if err := iprot.Skip(ctx, fieldTypeId); err != nil { |
| 32490 | return err |
| 32491 | } |
| 32492 | } |
| 32493 | if err := iprot.ReadFieldEnd(ctx); err != nil { |
| 32494 | return err |
| 32495 | } |
| 32496 | } |
| 32497 | if err := iprot.ReadStructEnd(ctx); err != nil { |
| 32498 | return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) |
| 32499 | } |
| 32500 | return nil |
| 32501 | } |
| 32502 | |
| 32503 | func (p *IClientRPCServiceDeleteTimeseriesArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { |
| 32504 | if v, err := iprot.ReadI64(ctx); err != nil { |
no test coverage detected