MCPcopy Create free account
hub / github.com/apache/iotdb-client-go / Read

Method Read

rpc/client.go:35922–35958  ·  view source on GitHub ↗
(ctx context.Context, iprot thrift.TProtocol)

Source from the content-addressed store, hash-verified

35920}
35921
35922func (p *IClientRPCServiceDeleteDataArgs) Read(ctx context.Context, iprot thrift.TProtocol) error {
35923 if _, err := iprot.ReadStructBegin(ctx); err != nil {
35924 return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err)
35925 }
35926
35927
35928 for {
35929 _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx)
35930 if err != nil {
35931 return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err)
35932 }
35933 if fieldTypeId == thrift.STOP { break; }
35934 switch fieldId {
35935 case 1:
35936 if fieldTypeId == thrift.STRUCT {
35937 if err := p.ReadField1(ctx, iprot); err != nil {
35938 return err
35939 }
35940 } else {
35941 if err := iprot.Skip(ctx, fieldTypeId); err != nil {
35942 return err
35943 }
35944 }
35945 default:
35946 if err := iprot.Skip(ctx, fieldTypeId); err != nil {
35947 return err
35948 }
35949 }
35950 if err := iprot.ReadFieldEnd(ctx); err != nil {
35951 return err
35952 }
35953 }
35954 if err := iprot.ReadStructEnd(ctx); err != nil {
35955 return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err)
35956 }
35957 return nil
35958}
35959
35960func (p *IClientRPCServiceDeleteDataArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error {
35961 p.Req = &TSDeleteDataReq{}

Callers 1

ProcessMethod · 0.95

Calls 1

ReadField1Method · 0.95

Tested by

no test coverage detected