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

Method Write

rpc/client.go:2780–2795  ·  view source on GitHub ↗
(ctx context.Context, oprot thrift.TProtocol)

Source from the content-addressed store, hash-verified

2778}
2779
2780func (p *TSOpenSessionReq) Write(ctx context.Context, oprot thrift.TProtocol) error {
2781 if err := oprot.WriteStructBegin(ctx, "TSOpenSessionReq"); err != nil {
2782 return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) }
2783 if p != nil {
2784 if err := p.writeField1(ctx, oprot); err != nil { return err }
2785 if err := p.writeField2(ctx, oprot); err != nil { return err }
2786 if err := p.writeField3(ctx, oprot); err != nil { return err }
2787 if err := p.writeField4(ctx, oprot); err != nil { return err }
2788 if err := p.writeField5(ctx, oprot); err != nil { return err }
2789 }
2790 if err := oprot.WriteFieldStop(ctx); err != nil {
2791 return thrift.PrependError("write field stop error: ", err) }
2792 if err := oprot.WriteStructEnd(ctx); err != nil {
2793 return thrift.PrependError("write struct stop error: ", err) }
2794 return nil
2795}
2796
2797func (p *TSOpenSessionReq) writeField1(ctx context.Context, oprot thrift.TProtocol) (err error) {
2798 if err := oprot.WriteFieldBegin(ctx, "client_protocol", thrift.I32, 1); err != nil {

Callers

nothing calls this directly

Calls 5

writeField1Method · 0.95
writeField2Method · 0.95
writeField3Method · 0.95
writeField4Method · 0.95
writeField5Method · 0.95

Tested by

no test coverage detected