add ExecuteGroupByQueryIntervalQuery api
diff --git a/client/session.go b/client/session.go index 8307c1f..1a48c65 100644 --- a/client/session.go +++ b/client/session.go
@@ -534,6 +534,33 @@ } } +func (s *Session) ExecuteGroupByQueryIntervalQuery(database *string, device, measurement string, aggregationType common.TAggregationType, + dataType int32, startTime *int64, endTime *int64, interval *int64, timeoutMs *int64) (*SessionDataSet, error) { + + request := rpc.TSGroupByQueryIntervalReq{SessionId: s.sessionId, StatementId: s.requestStatementId, + Database: database, Device: device, Measurement: measurement, AggregationType: aggregationType, DataType: dataType, + StartTime: startTime, EndTime: endTime, Interval: interval, FetchSize: &s.config.FetchSize, + Timeout: timeoutMs} + if resp, err := s.client.ExecuteGroupByQueryIntervalQuery(context.Background(), &request); err == nil { + if statusErr := VerifySuccess(resp.Status); statusErr == nil { + return NewSessionDataSet("", resp.Columns, resp.DataTypeList, resp.ColumnNameIndexMap, *resp.QueryId, s.client, s.sessionId, resp.QueryDataSet, resp.IgnoreTimeStamp != nil && *resp.IgnoreTimeStamp, s.config.FetchSize, timeoutMs), err + } else { + return nil, statusErr + } + } else { + if s.reconnect() { + request.SessionId = s.sessionId + resp, err = s.client.ExecuteGroupByQueryIntervalQuery(context.Background(), &request) + if statusErr := VerifySuccess(resp.Status); statusErr == nil { + return NewSessionDataSet("", resp.Columns, resp.DataTypeList, resp.ColumnNameIndexMap, *resp.QueryId, s.client, s.sessionId, resp.QueryDataSet, resp.IgnoreTimeStamp != nil && *resp.IgnoreTimeStamp, s.config.FetchSize, timeoutMs), err + } else { + return nil, statusErr + } + } + return nil, err + } +} + func (s *Session) genTSInsertRecordReq(deviceId string, time int64, measurements []string, types []TSDataType, @@ -587,54 +614,6 @@ return r, err } -func (s *Session) genFastInsertRecordReq(deviceIds []string, - timestamps []int64, - dataTypes [][]TSDataType, - values [][]interface{}) (*rpc.TSFastInsertRecordsReq, error) { - length := len(deviceIds) - if length != len(timestamps) || length != len(values) { - return nil, errLength - } - - request := rpc.TSFastInsertRecordsReq{ - SessionId: s.sessionId, - PrefixPaths: deviceIds, - Timestamps: timestamps, - } - - v := make([][]byte, length) - for i := 0; i < len(timestamps); i++ { - if bys, err := valuesToBytesForFast(dataTypes[i], values[i]); err == nil { - v[i] = bys - } else { - return nil, err - } - } - - request.ValuesList = v - return &request, nil -} - -func (s *Session) FastInsertRecords(deviceIds []string, - dataTypes [][]TSDataType, - values [][]interface{}, - timestamps []int64) (r *common.TSStatus, err error) { - request, err := s.genFastInsertRecordReq(deviceIds, timestamps, dataTypes, values) - if err != nil { - return nil, err - } else { - r, err = s.client.FastInsertRecords(context.Background(), request) - if err != nil && r == nil { - if s.reconnect() { - request.SessionId = s.sessionId - r, err = s.client.FastInsertRecords(context.Background(), request) - } - } - } - - return r, err -} - type deviceData struct { timestamps []int64 measurementsSlice [][]string
diff --git a/example/session_example.go b/example/session_example.go index c49e189..c4eea36 100644 --- a/example/session_example.go +++ b/example/session_example.go
@@ -57,7 +57,7 @@ } defer session.Close() - fastInsertRecords() + // testExecuteGroupByQueryIntervalQuery() setStorageGroup("root.ln1") deleteStorageGroup("root.ln1") @@ -145,6 +145,24 @@ deleteTimeseries("root.ln.device1.*") } +func testExecuteGroupByQueryIntervalQuery() { + db := "root.sg" + device := "root.sg.cpu.host_1" + measurement := "usage_user" + aggregationType := common.TAggregationType_MAX_VALUE + dateType := int32(2) + startTime := int64(1451754531000) + endTime := int64(1451758131000) + interval := int64(60000) + timeOut := int64(60000) + + ret, err := session.ExecuteGroupByQueryIntervalQuery(&db, device, measurement, aggregationType, + dateType, &startTime, &endTime, &interval, &timeOut) + if err == nil { + printDataSet1(ret) + } +} + func printDevice1(sds *client.SessionDataSet) { showTimestamp := !sds.IsIgnoreTimeStamp() if showTimestamp { @@ -383,26 +401,6 @@ fmt.Println() } -func fastInsertRecords() { - var ( - deviceIds = []string{"root.fast.d1", "root.fast.d2"} - dataTypes = [][]client.TSDataType{{client.INT32, client.INT32}, {client.INT32, client.INT32}} - values = [][]interface{}{{int32(120), int32(121)}, {int32(130), int32(131)}} - timestamp = []int64{12, 13} - ) - checkError(session.FastInsertRecords(deviceIds, dataTypes, values, timestamp)) - sessionDataSet, err := session.ExecuteStatement("show devices") - if err == nil { - printDataSet0(sessionDataSet) - sessionDataSet.Close() - } else { - log.Println(err) - } - - deleteTimeseries("root.fast.**") - fmt.Println() -} - func insertRecords() { var ( deviceId = []string{"root.sg1.dev1"}
diff --git a/rpc/client.go b/rpc/client.go index b3668b8..d9ec8b0 100644 --- a/rpc/client.go +++ b/rpc/client.go
@@ -7256,314 +7256,6 @@ // Attributes: // - SessionId // - PrefixPaths -// - Timestamps -// - ValuesList -type TSFastInsertRecordsReq struct { - SessionId int64 `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"` - PrefixPaths []string `thrift:"prefixPaths,2,required" db:"prefixPaths" json:"prefixPaths"` - // unused field # 3 - ValuesList [][]byte `thrift:"valuesList,4,required" db:"valuesList" json:"valuesList"` - Timestamps []int64 `thrift:"timestamps,5,required" db:"timestamps" json:"timestamps"` -} - -func NewTSFastInsertRecordsReq() *TSFastInsertRecordsReq { - return &TSFastInsertRecordsReq{} -} - - -func (p *TSFastInsertRecordsReq) GetSessionId() int64 { - return p.SessionId -} - -func (p *TSFastInsertRecordsReq) GetPrefixPaths() []string { - return p.PrefixPaths -} - -func (p *TSFastInsertRecordsReq) GetTimestamps() []int64 { - return p.Timestamps -} - -func (p *TSFastInsertRecordsReq) GetValuesList() [][]byte { - return p.ValuesList -} -func (p *TSFastInsertRecordsReq) Read(ctx context.Context, iprot thrift.TProtocol) error { - if _, err := iprot.ReadStructBegin(ctx); err != nil { - return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) - } - - var issetSessionId bool = false; - var issetPrefixPaths bool = false; - var issetTimestamps bool = false; - var issetValuesList bool = false; - - for { - _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) - if err != nil { - return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) - } - if fieldTypeId == thrift.STOP { break; } - switch fieldId { - case 1: - if fieldTypeId == thrift.I64 { - if err := p.ReadField1(ctx, iprot); err != nil { - return err - } - issetSessionId = true - } else { - if err := iprot.Skip(ctx, fieldTypeId); err != nil { - return err - } - } - case 2: - if fieldTypeId == thrift.LIST { - if err := p.ReadField2(ctx, iprot); err != nil { - return err - } - issetPrefixPaths = true - } else { - if err := iprot.Skip(ctx, fieldTypeId); err != nil { - return err - } - } - case 5: - if fieldTypeId == thrift.LIST { - if err := p.ReadField5(ctx, iprot); err != nil { - return err - } - issetTimestamps = true - } else { - if err := iprot.Skip(ctx, fieldTypeId); err != nil { - return err - } - } - case 4: - if fieldTypeId == thrift.LIST { - if err := p.ReadField4(ctx, iprot); err != nil { - return err - } - issetValuesList = true - } else { - if err := iprot.Skip(ctx, fieldTypeId); err != nil { - return err - } - } - default: - if err := iprot.Skip(ctx, fieldTypeId); err != nil { - return err - } - } - if err := iprot.ReadFieldEnd(ctx); err != nil { - return err - } - } - if err := iprot.ReadStructEnd(ctx); err != nil { - return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) - } - if !issetSessionId{ - return thrift.NewTProtocolExceptionWithType(thrift.INVALID_DATA, fmt.Errorf("Required field SessionId is not set")); - } - if !issetPrefixPaths{ - return thrift.NewTProtocolExceptionWithType(thrift.INVALID_DATA, fmt.Errorf("Required field PrefixPaths is not set")); - } - if !issetTimestamps{ - return thrift.NewTProtocolExceptionWithType(thrift.INVALID_DATA, fmt.Errorf("Required field Timestamps is not set")); - } - if !issetValuesList{ - return thrift.NewTProtocolExceptionWithType(thrift.INVALID_DATA, fmt.Errorf("Required field ValuesList is not set")); - } - return nil -} - -func (p *TSFastInsertRecordsReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { - if v, err := iprot.ReadI64(ctx); err != nil { - return thrift.PrependError("error reading field 1: ", err) -} else { - p.SessionId = v -} - return nil -} - -func (p *TSFastInsertRecordsReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error { - _, size, err := iprot.ReadListBegin(ctx) - if err != nil { - return thrift.PrependError("error reading list begin: ", err) - } - tSlice := make([]string, 0, size) - p.PrefixPaths = tSlice - for i := 0; i < size; i ++ { -var _elem63 string - if v, err := iprot.ReadString(ctx); err != nil { - return thrift.PrependError("error reading field 0: ", err) -} else { - _elem63 = v -} - p.PrefixPaths = append(p.PrefixPaths, _elem63) - } - if err := iprot.ReadListEnd(ctx); err != nil { - return thrift.PrependError("error reading list end: ", err) - } - return nil -} - -func (p *TSFastInsertRecordsReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error { - _, size, err := iprot.ReadListBegin(ctx) - if err != nil { - return thrift.PrependError("error reading list begin: ", err) - } - tSlice := make([]int64, 0, size) - p.Timestamps = tSlice - for i := 0; i < size; i ++ { -var _elem64 int64 - if v, err := iprot.ReadI64(ctx); err != nil { - return thrift.PrependError("error reading field 0: ", err) -} else { - _elem64 = v -} - p.Timestamps = append(p.Timestamps, _elem64) - } - if err := iprot.ReadListEnd(ctx); err != nil { - return thrift.PrependError("error reading list end: ", err) - } - return nil -} - -func (p *TSFastInsertRecordsReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error { - _, size, err := iprot.ReadListBegin(ctx) - if err != nil { - return thrift.PrependError("error reading list begin: ", err) - } - tSlice := make([][]byte, 0, size) - p.ValuesList = tSlice - for i := 0; i < size; i ++ { -var _elem65 []byte - if v, err := iprot.ReadBinary(ctx); err != nil { - return thrift.PrependError("error reading field 0: ", err) -} else { - _elem65 = v -} - p.ValuesList = append(p.ValuesList, _elem65) - } - if err := iprot.ReadListEnd(ctx); err != nil { - return thrift.PrependError("error reading list end: ", err) - } - return nil -} - -func (p *TSFastInsertRecordsReq) Write(ctx context.Context, oprot thrift.TProtocol) error { - if err := oprot.WriteStructBegin(ctx, "TSFastInsertRecordsReq"); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } - if p != nil { - if err := p.writeField1(ctx, oprot); err != nil { return err } - if err := p.writeField2(ctx, oprot); err != nil { return err } - if err := p.writeField4(ctx, oprot); err != nil { return err } - if err := p.writeField5(ctx, oprot); err != nil { return err } - } - if err := oprot.WriteFieldStop(ctx); err != nil { - return thrift.PrependError("write field stop error: ", err) } - if err := oprot.WriteStructEnd(ctx); err != nil { - return thrift.PrependError("write struct stop error: ", err) } - return nil -} - -func (p *TSFastInsertRecordsReq) writeField1(ctx context.Context, oprot thrift.TProtocol) (err error) { - if err := oprot.WriteFieldBegin(ctx, "sessionId", thrift.I64, 1); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:sessionId: ", p), err) } - if err := oprot.WriteI64(ctx, int64(p.SessionId)); err != nil { - return thrift.PrependError(fmt.Sprintf("%T.sessionId (1) field write error: ", p), err) } - if err := oprot.WriteFieldEnd(ctx); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field end error 1:sessionId: ", p), err) } - return err -} - -func (p *TSFastInsertRecordsReq) writeField2(ctx context.Context, oprot thrift.TProtocol) (err error) { - if err := oprot.WriteFieldBegin(ctx, "prefixPaths", thrift.LIST, 2); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:prefixPaths: ", p), err) } - if err := oprot.WriteListBegin(ctx, thrift.STRING, len(p.PrefixPaths)); err != nil { - return thrift.PrependError("error writing list begin: ", err) - } - for _, v := range p.PrefixPaths { - if err := oprot.WriteString(ctx, string(v)); err != nil { - return thrift.PrependError(fmt.Sprintf("%T. (0) field write error: ", p), err) } - } - if err := oprot.WriteListEnd(ctx); err != nil { - return thrift.PrependError("error writing list end: ", err) - } - if err := oprot.WriteFieldEnd(ctx); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field end error 2:prefixPaths: ", p), err) } - return err -} - -func (p *TSFastInsertRecordsReq) writeField4(ctx context.Context, oprot thrift.TProtocol) (err error) { - if err := oprot.WriteFieldBegin(ctx, "valuesList", thrift.LIST, 4); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field begin error 4:valuesList: ", p), err) } - if err := oprot.WriteListBegin(ctx, thrift.STRING, len(p.ValuesList)); err != nil { - return thrift.PrependError("error writing list begin: ", err) - } - for _, v := range p.ValuesList { - if err := oprot.WriteBinary(ctx, v); err != nil { - return thrift.PrependError(fmt.Sprintf("%T. (0) field write error: ", p), err) } - } - if err := oprot.WriteListEnd(ctx); err != nil { - return thrift.PrependError("error writing list end: ", err) - } - if err := oprot.WriteFieldEnd(ctx); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field end error 4:valuesList: ", p), err) } - return err -} - -func (p *TSFastInsertRecordsReq) writeField5(ctx context.Context, oprot thrift.TProtocol) (err error) { - if err := oprot.WriteFieldBegin(ctx, "timestamps", thrift.LIST, 5); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field begin error 5:timestamps: ", p), err) } - if err := oprot.WriteListBegin(ctx, thrift.I64, len(p.Timestamps)); err != nil { - return thrift.PrependError("error writing list begin: ", err) - } - for _, v := range p.Timestamps { - if err := oprot.WriteI64(ctx, int64(v)); err != nil { - return thrift.PrependError(fmt.Sprintf("%T. (0) field write error: ", p), err) } - } - if err := oprot.WriteListEnd(ctx); err != nil { - return thrift.PrependError("error writing list end: ", err) - } - if err := oprot.WriteFieldEnd(ctx); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field end error 5:timestamps: ", p), err) } - return err -} - -func (p *TSFastInsertRecordsReq) Equals(other *TSFastInsertRecordsReq) bool { - if p == other { - return true - } else if p == nil || other == nil { - return false - } - if p.SessionId != other.SessionId { return false } - if len(p.PrefixPaths) != len(other.PrefixPaths) { return false } - for i, _tgt := range p.PrefixPaths { - _src66 := other.PrefixPaths[i] - if _tgt != _src66 { return false } - } - if len(p.ValuesList) != len(other.ValuesList) { return false } - for i, _tgt := range p.ValuesList { - _src67 := other.ValuesList[i] - if bytes.Compare(_tgt, _src67) != 0 { return false } - } - if len(p.Timestamps) != len(other.Timestamps) { return false } - for i, _tgt := range p.Timestamps { - _src68 := other.Timestamps[i] - if _tgt != _src68 { return false } - } - return true -} - -func (p *TSFastInsertRecordsReq) String() string { - if p == nil { - return "<nil>" - } - return fmt.Sprintf("TSFastInsertRecordsReq(%+v)", *p) -} - -// Attributes: -// - SessionId -// - PrefixPaths // - MeasurementsList // - ValuesList // - Timestamps @@ -7742,13 +7434,13 @@ tSlice := make([]string, 0, size) p.PrefixPaths = tSlice for i := 0; i < size; i ++ { -var _elem69 string +var _elem63 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem69 = v + _elem63 = v } - p.PrefixPaths = append(p.PrefixPaths, _elem69) + p.PrefixPaths = append(p.PrefixPaths, _elem63) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -7769,20 +7461,20 @@ return thrift.PrependError("error reading list begin: ", err) } tSlice := make([]string, 0, size) - _elem70 := tSlice + _elem64 := tSlice for i := 0; i < size; i ++ { -var _elem71 string +var _elem65 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem71 = v + _elem65 = v } - _elem70 = append(_elem70, _elem71) + _elem64 = append(_elem64, _elem65) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) } - p.MeasurementsList = append(p.MeasurementsList, _elem70) + p.MeasurementsList = append(p.MeasurementsList, _elem64) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -7798,13 +7490,13 @@ tSlice := make([][]byte, 0, size) p.ValuesList = tSlice for i := 0; i < size; i ++ { -var _elem72 []byte +var _elem66 []byte if v, err := iprot.ReadBinary(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem72 = v + _elem66 = v } - p.ValuesList = append(p.ValuesList, _elem72) + p.ValuesList = append(p.ValuesList, _elem66) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -7820,13 +7512,13 @@ tSlice := make([]int64, 0, size) p.Timestamps = tSlice for i := 0; i < size; i ++ { -var _elem73 int64 +var _elem67 int64 if v, err := iprot.ReadI64(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem73 = v + _elem67 = v } - p.Timestamps = append(p.Timestamps, _elem73) + p.Timestamps = append(p.Timestamps, _elem67) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -7972,27 +7664,27 @@ if p.SessionId != other.SessionId { return false } if len(p.PrefixPaths) != len(other.PrefixPaths) { return false } for i, _tgt := range p.PrefixPaths { - _src74 := other.PrefixPaths[i] - if _tgt != _src74 { return false } + _src68 := other.PrefixPaths[i] + if _tgt != _src68 { return false } } if len(p.MeasurementsList) != len(other.MeasurementsList) { return false } for i, _tgt := range p.MeasurementsList { - _src75 := other.MeasurementsList[i] - if len(_tgt) != len(_src75) { return false } + _src69 := other.MeasurementsList[i] + if len(_tgt) != len(_src69) { return false } for i, _tgt := range _tgt { - _src76 := _src75[i] - if _tgt != _src76 { return false } + _src70 := _src69[i] + if _tgt != _src70 { return false } } } if len(p.ValuesList) != len(other.ValuesList) { return false } for i, _tgt := range p.ValuesList { - _src77 := other.ValuesList[i] - if bytes.Compare(_tgt, _src77) != 0 { return false } + _src71 := other.ValuesList[i] + if bytes.Compare(_tgt, _src71) != 0 { return false } } if len(p.Timestamps) != len(other.Timestamps) { return false } for i, _tgt := range p.Timestamps { - _src78 := other.Timestamps[i] - if _tgt != _src78 { return false } + _src72 := other.Timestamps[i] + if _tgt != _src72 { return false } } if p.IsAligned != other.IsAligned { if p.IsAligned == nil || other.IsAligned == nil { @@ -8205,20 +7897,20 @@ return thrift.PrependError("error reading list begin: ", err) } tSlice := make([]string, 0, size) - _elem79 := tSlice + _elem73 := tSlice for i := 0; i < size; i ++ { -var _elem80 string +var _elem74 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem80 = v + _elem74 = v } - _elem79 = append(_elem79, _elem80) + _elem73 = append(_elem73, _elem74) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) } - p.MeasurementsList = append(p.MeasurementsList, _elem79) + p.MeasurementsList = append(p.MeasurementsList, _elem73) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -8234,13 +7926,13 @@ tSlice := make([][]byte, 0, size) p.ValuesList = tSlice for i := 0; i < size; i ++ { -var _elem81 []byte +var _elem75 []byte if v, err := iprot.ReadBinary(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem81 = v + _elem75 = v } - p.ValuesList = append(p.ValuesList, _elem81) + p.ValuesList = append(p.ValuesList, _elem75) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -8256,13 +7948,13 @@ tSlice := make([]int64, 0, size) p.Timestamps = tSlice for i := 0; i < size; i ++ { -var _elem82 int64 +var _elem76 int64 if v, err := iprot.ReadI64(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem82 = v + _elem76 = v } - p.Timestamps = append(p.Timestamps, _elem82) + p.Timestamps = append(p.Timestamps, _elem76) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -8401,22 +8093,22 @@ if p.PrefixPath != other.PrefixPath { return false } if len(p.MeasurementsList) != len(other.MeasurementsList) { return false } for i, _tgt := range p.MeasurementsList { - _src83 := other.MeasurementsList[i] - if len(_tgt) != len(_src83) { return false } + _src77 := other.MeasurementsList[i] + if len(_tgt) != len(_src77) { return false } for i, _tgt := range _tgt { - _src84 := _src83[i] - if _tgt != _src84 { return false } + _src78 := _src77[i] + if _tgt != _src78 { return false } } } if len(p.ValuesList) != len(other.ValuesList) { return false } for i, _tgt := range p.ValuesList { - _src85 := other.ValuesList[i] - if bytes.Compare(_tgt, _src85) != 0 { return false } + _src79 := other.ValuesList[i] + if bytes.Compare(_tgt, _src79) != 0 { return false } } if len(p.Timestamps) != len(other.Timestamps) { return false } for i, _tgt := range p.Timestamps { - _src86 := other.Timestamps[i] - if _tgt != _src86 { return false } + _src80 := other.Timestamps[i] + if _tgt != _src80 { return false } } if p.IsAligned != other.IsAligned { if p.IsAligned == nil || other.IsAligned == nil { @@ -8629,20 +8321,20 @@ return thrift.PrependError("error reading list begin: ", err) } tSlice := make([]string, 0, size) - _elem87 := tSlice + _elem81 := tSlice for i := 0; i < size; i ++ { -var _elem88 string +var _elem82 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem88 = v + _elem82 = v } - _elem87 = append(_elem87, _elem88) + _elem81 = append(_elem81, _elem82) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) } - p.MeasurementsList = append(p.MeasurementsList, _elem87) + p.MeasurementsList = append(p.MeasurementsList, _elem81) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -8663,20 +8355,20 @@ return thrift.PrependError("error reading list begin: ", err) } tSlice := make([]string, 0, size) - _elem89 := tSlice + _elem83 := tSlice for i := 0; i < size; i ++ { -var _elem90 string +var _elem84 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem90 = v + _elem84 = v } - _elem89 = append(_elem89, _elem90) + _elem83 = append(_elem83, _elem84) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) } - p.ValuesList = append(p.ValuesList, _elem89) + p.ValuesList = append(p.ValuesList, _elem83) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -8692,13 +8384,13 @@ tSlice := make([]int64, 0, size) p.Timestamps = tSlice for i := 0; i < size; i ++ { -var _elem91 int64 +var _elem85 int64 if v, err := iprot.ReadI64(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem91 = v + _elem85 = v } - p.Timestamps = append(p.Timestamps, _elem91) + p.Timestamps = append(p.Timestamps, _elem85) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -8845,26 +8537,26 @@ if p.PrefixPath != other.PrefixPath { return false } if len(p.MeasurementsList) != len(other.MeasurementsList) { return false } for i, _tgt := range p.MeasurementsList { - _src92 := other.MeasurementsList[i] - if len(_tgt) != len(_src92) { return false } + _src86 := other.MeasurementsList[i] + if len(_tgt) != len(_src86) { return false } for i, _tgt := range _tgt { - _src93 := _src92[i] - if _tgt != _src93 { return false } + _src87 := _src86[i] + if _tgt != _src87 { return false } } } if len(p.ValuesList) != len(other.ValuesList) { return false } for i, _tgt := range p.ValuesList { - _src94 := other.ValuesList[i] - if len(_tgt) != len(_src94) { return false } + _src88 := other.ValuesList[i] + if len(_tgt) != len(_src88) { return false } for i, _tgt := range _tgt { - _src95 := _src94[i] - if _tgt != _src95 { return false } + _src89 := _src88[i] + if _tgt != _src89 { return false } } } if len(p.Timestamps) != len(other.Timestamps) { return false } for i, _tgt := range p.Timestamps { - _src96 := other.Timestamps[i] - if _tgt != _src96 { return false } + _src90 := other.Timestamps[i] + if _tgt != _src90 { return false } } if p.IsAligned != other.IsAligned { if p.IsAligned == nil || other.IsAligned == nil { @@ -9063,13 +8755,13 @@ tSlice := make([]string, 0, size) p.PrefixPaths = tSlice for i := 0; i < size; i ++ { -var _elem97 string +var _elem91 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem97 = v + _elem91 = v } - p.PrefixPaths = append(p.PrefixPaths, _elem97) + p.PrefixPaths = append(p.PrefixPaths, _elem91) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -9090,20 +8782,20 @@ return thrift.PrependError("error reading list begin: ", err) } tSlice := make([]string, 0, size) - _elem98 := tSlice + _elem92 := tSlice for i := 0; i < size; i ++ { -var _elem99 string +var _elem93 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem99 = v + _elem93 = v } - _elem98 = append(_elem98, _elem99) + _elem92 = append(_elem92, _elem93) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) } - p.MeasurementsList = append(p.MeasurementsList, _elem98) + p.MeasurementsList = append(p.MeasurementsList, _elem92) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -9124,20 +8816,20 @@ return thrift.PrependError("error reading list begin: ", err) } tSlice := make([]string, 0, size) - _elem100 := tSlice + _elem94 := tSlice for i := 0; i < size; i ++ { -var _elem101 string +var _elem95 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem101 = v + _elem95 = v } - _elem100 = append(_elem100, _elem101) + _elem94 = append(_elem94, _elem95) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) } - p.ValuesList = append(p.ValuesList, _elem100) + p.ValuesList = append(p.ValuesList, _elem94) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -9153,13 +8845,13 @@ tSlice := make([]int64, 0, size) p.Timestamps = tSlice for i := 0; i < size; i ++ { -var _elem102 int64 +var _elem96 int64 if v, err := iprot.ReadI64(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem102 = v + _elem96 = v } - p.Timestamps = append(p.Timestamps, _elem102) + p.Timestamps = append(p.Timestamps, _elem96) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -9313,31 +9005,31 @@ if p.SessionId != other.SessionId { return false } if len(p.PrefixPaths) != len(other.PrefixPaths) { return false } for i, _tgt := range p.PrefixPaths { - _src103 := other.PrefixPaths[i] - if _tgt != _src103 { return false } + _src97 := other.PrefixPaths[i] + if _tgt != _src97 { return false } } if len(p.MeasurementsList) != len(other.MeasurementsList) { return false } for i, _tgt := range p.MeasurementsList { - _src104 := other.MeasurementsList[i] - if len(_tgt) != len(_src104) { return false } + _src98 := other.MeasurementsList[i] + if len(_tgt) != len(_src98) { return false } for i, _tgt := range _tgt { - _src105 := _src104[i] - if _tgt != _src105 { return false } + _src99 := _src98[i] + if _tgt != _src99 { return false } } } if len(p.ValuesList) != len(other.ValuesList) { return false } for i, _tgt := range p.ValuesList { - _src106 := other.ValuesList[i] - if len(_tgt) != len(_src106) { return false } + _src100 := other.ValuesList[i] + if len(_tgt) != len(_src100) { return false } for i, _tgt := range _tgt { - _src107 := _src106[i] - if _tgt != _src107 { return false } + _src101 := _src100[i] + if _tgt != _src101 { return false } } } if len(p.Timestamps) != len(other.Timestamps) { return false } for i, _tgt := range p.Timestamps { - _src108 := other.Timestamps[i] - if _tgt != _src108 { return false } + _src102 := other.Timestamps[i] + if _tgt != _src102 { return false } } if p.IsAligned != other.IsAligned { if p.IsAligned == nil || other.IsAligned == nil { @@ -9492,13 +9184,13 @@ tSlice := make([]string, 0, size) p.Paths = tSlice for i := 0; i < size; i ++ { -var _elem109 string +var _elem103 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem109 = v + _elem103 = v } - p.Paths = append(p.Paths, _elem109) + p.Paths = append(p.Paths, _elem103) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -9597,8 +9289,8 @@ if p.SessionId != other.SessionId { return false } if len(p.Paths) != len(other.Paths) { return false } for i, _tgt := range p.Paths { - _src110 := other.Paths[i] - if _tgt != _src110 { return false } + _src104 := other.Paths[i] + if _tgt != _src104 { return false } } if p.StartTime != other.StartTime { return false } if p.EndTime != other.EndTime { return false } @@ -9892,19 +9584,19 @@ tMap := make(map[string]string, size) p.Props = tMap for i := 0; i < size; i ++ { -var _key111 string +var _key105 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _key111 = v + _key105 = v } -var _val112 string +var _val106 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _val112 = v + _val106 = v } - p.Props[_key111] = _val112 + p.Props[_key105] = _val106 } if err := iprot.ReadMapEnd(ctx); err != nil { return thrift.PrependError("error reading map end: ", err) @@ -9920,19 +9612,19 @@ tMap := make(map[string]string, size) p.Tags = tMap for i := 0; i < size; i ++ { -var _key113 string +var _key107 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _key113 = v + _key107 = v } -var _val114 string +var _val108 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _val114 = v + _val108 = v } - p.Tags[_key113] = _val114 + p.Tags[_key107] = _val108 } if err := iprot.ReadMapEnd(ctx); err != nil { return thrift.PrependError("error reading map end: ", err) @@ -9948,19 +9640,19 @@ tMap := make(map[string]string, size) p.Attributes = tMap for i := 0; i < size; i ++ { -var _key115 string +var _key109 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _key115 = v + _key109 = v } -var _val116 string +var _val110 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _val116 = v + _val110 = v } - p.Attributes[_key115] = _val116 + p.Attributes[_key109] = _val110 } if err := iprot.ReadMapEnd(ctx); err != nil { return thrift.PrependError("error reading map end: ", err) @@ -10139,18 +9831,18 @@ if p.Compressor != other.Compressor { return false } if len(p.Props) != len(other.Props) { return false } for k, _tgt := range p.Props { - _src117 := other.Props[k] - if _tgt != _src117 { return false } + _src111 := other.Props[k] + if _tgt != _src111 { return false } } if len(p.Tags) != len(other.Tags) { return false } for k, _tgt := range p.Tags { - _src118 := other.Tags[k] - if _tgt != _src118 { return false } + _src112 := other.Tags[k] + if _tgt != _src112 { return false } } if len(p.Attributes) != len(other.Attributes) { return false } for k, _tgt := range p.Attributes { - _src119 := other.Attributes[k] - if _tgt != _src119 { return false } + _src113 := other.Attributes[k] + if _tgt != _src113 { return false } } if p.MeasurementAlias != other.MeasurementAlias { if p.MeasurementAlias == nil || other.MeasurementAlias == nil { @@ -10419,13 +10111,13 @@ tSlice := make([]string, 0, size) p.Measurements = tSlice for i := 0; i < size; i ++ { -var _elem120 string +var _elem114 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem120 = v + _elem114 = v } - p.Measurements = append(p.Measurements, _elem120) + p.Measurements = append(p.Measurements, _elem114) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -10441,13 +10133,13 @@ tSlice := make([]int32, 0, size) p.DataTypes = tSlice for i := 0; i < size; i ++ { -var _elem121 int32 +var _elem115 int32 if v, err := iprot.ReadI32(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem121 = v + _elem115 = v } - p.DataTypes = append(p.DataTypes, _elem121) + p.DataTypes = append(p.DataTypes, _elem115) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -10463,13 +10155,13 @@ tSlice := make([]int32, 0, size) p.Encodings = tSlice for i := 0; i < size; i ++ { -var _elem122 int32 +var _elem116 int32 if v, err := iprot.ReadI32(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem122 = v + _elem116 = v } - p.Encodings = append(p.Encodings, _elem122) + p.Encodings = append(p.Encodings, _elem116) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -10485,13 +10177,13 @@ tSlice := make([]int32, 0, size) p.Compressors = tSlice for i := 0; i < size; i ++ { -var _elem123 int32 +var _elem117 int32 if v, err := iprot.ReadI32(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem123 = v + _elem117 = v } - p.Compressors = append(p.Compressors, _elem123) + p.Compressors = append(p.Compressors, _elem117) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -10507,13 +10199,13 @@ tSlice := make([]string, 0, size) p.MeasurementAlias = tSlice for i := 0; i < size; i ++ { -var _elem124 string +var _elem118 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem124 = v + _elem118 = v } - p.MeasurementAlias = append(p.MeasurementAlias, _elem124) + p.MeasurementAlias = append(p.MeasurementAlias, _elem118) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -10534,26 +10226,26 @@ return thrift.PrependError("error reading map begin: ", err) } tMap := make(map[string]string, size) - _elem125 := tMap + _elem119 := tMap for i := 0; i < size; i ++ { -var _key126 string +var _key120 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _key126 = v + _key120 = v } -var _val127 string +var _val121 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _val127 = v + _val121 = v } - _elem125[_key126] = _val127 + _elem119[_key120] = _val121 } if err := iprot.ReadMapEnd(ctx); err != nil { return thrift.PrependError("error reading map end: ", err) } - p.TagsList = append(p.TagsList, _elem125) + p.TagsList = append(p.TagsList, _elem119) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -10574,26 +10266,26 @@ return thrift.PrependError("error reading map begin: ", err) } tMap := make(map[string]string, size) - _elem128 := tMap + _elem122 := tMap for i := 0; i < size; i ++ { -var _key129 string +var _key123 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _key129 = v + _key123 = v } -var _val130 string +var _val124 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _val130 = v + _val124 = v } - _elem128[_key129] = _val130 + _elem122[_key123] = _val124 } if err := iprot.ReadMapEnd(ctx); err != nil { return thrift.PrependError("error reading map end: ", err) } - p.AttributesList = append(p.AttributesList, _elem128) + p.AttributesList = append(p.AttributesList, _elem122) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -10804,45 +10496,45 @@ if p.PrefixPath != other.PrefixPath { return false } if len(p.Measurements) != len(other.Measurements) { return false } for i, _tgt := range p.Measurements { - _src131 := other.Measurements[i] - if _tgt != _src131 { return false } + _src125 := other.Measurements[i] + if _tgt != _src125 { return false } } if len(p.DataTypes) != len(other.DataTypes) { return false } for i, _tgt := range p.DataTypes { - _src132 := other.DataTypes[i] - if _tgt != _src132 { return false } + _src126 := other.DataTypes[i] + if _tgt != _src126 { return false } } if len(p.Encodings) != len(other.Encodings) { return false } for i, _tgt := range p.Encodings { - _src133 := other.Encodings[i] - if _tgt != _src133 { return false } + _src127 := other.Encodings[i] + if _tgt != _src127 { return false } } if len(p.Compressors) != len(other.Compressors) { return false } for i, _tgt := range p.Compressors { - _src134 := other.Compressors[i] - if _tgt != _src134 { return false } + _src128 := other.Compressors[i] + if _tgt != _src128 { return false } } if len(p.MeasurementAlias) != len(other.MeasurementAlias) { return false } for i, _tgt := range p.MeasurementAlias { - _src135 := other.MeasurementAlias[i] - if _tgt != _src135 { return false } + _src129 := other.MeasurementAlias[i] + if _tgt != _src129 { return false } } if len(p.TagsList) != len(other.TagsList) { return false } for i, _tgt := range p.TagsList { - _src136 := other.TagsList[i] - if len(_tgt) != len(_src136) { return false } + _src130 := other.TagsList[i] + if len(_tgt) != len(_src130) { return false } for k, _tgt := range _tgt { - _src137 := _src136[k] - if _tgt != _src137 { return false } + _src131 := _src130[k] + if _tgt != _src131 { return false } } } if len(p.AttributesList) != len(other.AttributesList) { return false } for i, _tgt := range p.AttributesList { - _src138 := other.AttributesList[i] - if len(_tgt) != len(_src138) { return false } + _src132 := other.AttributesList[i] + if len(_tgt) != len(_src132) { return false } for k, _tgt := range _tgt { - _src139 := _src138[k] - if _tgt != _src139 { return false } + _src133 := _src132[k] + if _tgt != _src133 { return false } } } return true @@ -11128,13 +10820,13 @@ tSlice := make([]string, 0, size) p.Paths = tSlice for i := 0; i < size; i ++ { -var _elem140 string +var _elem134 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem140 = v + _elem134 = v } - p.Paths = append(p.Paths, _elem140) + p.Paths = append(p.Paths, _elem134) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -11363,8 +11055,8 @@ if p.SessionId != other.SessionId { return false } if len(p.Paths) != len(other.Paths) { return false } for i, _tgt := range p.Paths { - _src141 := other.Paths[i] - if _tgt != _src141 { return false } + _src135 := other.Paths[i] + if _tgt != _src135 { return false } } if p.FetchSize != other.FetchSize { if p.FetchSize == nil || other.FetchSize == nil { @@ -11661,13 +11353,13 @@ tSlice := make([]string, 0, size) p.Paths = tSlice for i := 0; i < size; i ++ { -var _elem142 string +var _elem136 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem142 = v + _elem136 = v } - p.Paths = append(p.Paths, _elem142) + p.Paths = append(p.Paths, _elem136) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -11876,8 +11568,8 @@ if p.SessionId != other.SessionId { return false } if len(p.Paths) != len(other.Paths) { return false } for i, _tgt := range p.Paths { - _src143 := other.Paths[i] - if _tgt != _src143 { return false } + _src137 := other.Paths[i] + if _tgt != _src137 { return false } } if p.FetchSize != other.FetchSize { if p.FetchSize == nil || other.FetchSize == nil { @@ -12228,13 +11920,13 @@ tSlice := make([]string, 0, size) p.Paths = tSlice for i := 0; i < size; i ++ { -var _elem144 string +var _elem138 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem144 = v + _elem138 = v } - p.Paths = append(p.Paths, _elem144) + p.Paths = append(p.Paths, _elem138) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -12250,14 +11942,14 @@ tSlice := make([]common.TAggregationType, 0, size) p.Aggregations = tSlice for i := 0; i < size; i ++ { -var _elem145 common.TAggregationType +var _elem139 common.TAggregationType if v, err := iprot.ReadI32(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { temp := common.TAggregationType(v) - _elem145 = temp + _elem139 = temp } - p.Aggregations = append(p.Aggregations, _elem145) + p.Aggregations = append(p.Aggregations, _elem139) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -12501,13 +12193,13 @@ if p.StatementId != other.StatementId { return false } if len(p.Paths) != len(other.Paths) { return false } for i, _tgt := range p.Paths { - _src146 := other.Paths[i] - if _tgt != _src146 { return false } + _src140 := other.Paths[i] + if _tgt != _src140 { return false } } if len(p.Aggregations) != len(other.Aggregations) { return false } for i, _tgt := range p.Aggregations { - _src147 := other.Aggregations[i] - if _tgt != _src147 { return false } + _src141 := other.Aggregations[i] + if _tgt != _src141 { return false } } if p.StartTime != other.StartTime { if p.StartTime == nil || other.StartTime == nil { @@ -12563,6 +12255,629 @@ // Attributes: // - SessionId +// - StatementId +// - Device +// - Measurement +// - DataType +// - AggregationType +// - Database +// - StartTime +// - EndTime +// - Interval +// - FetchSize +// - Timeout +type TSGroupByQueryIntervalReq struct { + SessionId int64 `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"` + StatementId int64 `thrift:"statementId,2,required" db:"statementId" json:"statementId"` + Device string `thrift:"device,3,required" db:"device" json:"device"` + Measurement string `thrift:"measurement,4,required" db:"measurement" json:"measurement"` + DataType int32 `thrift:"dataType,5,required" db:"dataType" json:"dataType"` + AggregationType common.TAggregationType `thrift:"aggregationType,6,required" db:"aggregationType" json:"aggregationType"` + Database *string `thrift:"database,7" db:"database" json:"database,omitempty"` + StartTime *int64 `thrift:"startTime,8" db:"startTime" json:"startTime,omitempty"` + EndTime *int64 `thrift:"endTime,9" db:"endTime" json:"endTime,omitempty"` + Interval *int64 `thrift:"interval,10" db:"interval" json:"interval,omitempty"` + FetchSize *int32 `thrift:"fetchSize,11" db:"fetchSize" json:"fetchSize,omitempty"` + Timeout *int64 `thrift:"timeout,12" db:"timeout" json:"timeout,omitempty"` +} + +func NewTSGroupByQueryIntervalReq() *TSGroupByQueryIntervalReq { + return &TSGroupByQueryIntervalReq{} +} + + +func (p *TSGroupByQueryIntervalReq) GetSessionId() int64 { + return p.SessionId +} + +func (p *TSGroupByQueryIntervalReq) GetStatementId() int64 { + return p.StatementId +} + +func (p *TSGroupByQueryIntervalReq) GetDevice() string { + return p.Device +} + +func (p *TSGroupByQueryIntervalReq) GetMeasurement() string { + return p.Measurement +} + +func (p *TSGroupByQueryIntervalReq) GetDataType() int32 { + return p.DataType +} + +func (p *TSGroupByQueryIntervalReq) GetAggregationType() common.TAggregationType { + return p.AggregationType +} +var TSGroupByQueryIntervalReq_Database_DEFAULT string +func (p *TSGroupByQueryIntervalReq) GetDatabase() string { + if !p.IsSetDatabase() { + return TSGroupByQueryIntervalReq_Database_DEFAULT + } +return *p.Database +} +var TSGroupByQueryIntervalReq_StartTime_DEFAULT int64 +func (p *TSGroupByQueryIntervalReq) GetStartTime() int64 { + if !p.IsSetStartTime() { + return TSGroupByQueryIntervalReq_StartTime_DEFAULT + } +return *p.StartTime +} +var TSGroupByQueryIntervalReq_EndTime_DEFAULT int64 +func (p *TSGroupByQueryIntervalReq) GetEndTime() int64 { + if !p.IsSetEndTime() { + return TSGroupByQueryIntervalReq_EndTime_DEFAULT + } +return *p.EndTime +} +var TSGroupByQueryIntervalReq_Interval_DEFAULT int64 +func (p *TSGroupByQueryIntervalReq) GetInterval() int64 { + if !p.IsSetInterval() { + return TSGroupByQueryIntervalReq_Interval_DEFAULT + } +return *p.Interval +} +var TSGroupByQueryIntervalReq_FetchSize_DEFAULT int32 +func (p *TSGroupByQueryIntervalReq) GetFetchSize() int32 { + if !p.IsSetFetchSize() { + return TSGroupByQueryIntervalReq_FetchSize_DEFAULT + } +return *p.FetchSize +} +var TSGroupByQueryIntervalReq_Timeout_DEFAULT int64 +func (p *TSGroupByQueryIntervalReq) GetTimeout() int64 { + if !p.IsSetTimeout() { + return TSGroupByQueryIntervalReq_Timeout_DEFAULT + } +return *p.Timeout +} +func (p *TSGroupByQueryIntervalReq) IsSetDatabase() bool { + return p.Database != nil +} + +func (p *TSGroupByQueryIntervalReq) IsSetStartTime() bool { + return p.StartTime != nil +} + +func (p *TSGroupByQueryIntervalReq) IsSetEndTime() bool { + return p.EndTime != nil +} + +func (p *TSGroupByQueryIntervalReq) IsSetInterval() bool { + return p.Interval != nil +} + +func (p *TSGroupByQueryIntervalReq) IsSetFetchSize() bool { + return p.FetchSize != nil +} + +func (p *TSGroupByQueryIntervalReq) IsSetTimeout() bool { + return p.Timeout != nil +} + +func (p *TSGroupByQueryIntervalReq) Read(ctx context.Context, iprot thrift.TProtocol) error { + if _, err := iprot.ReadStructBegin(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) + } + + var issetSessionId bool = false; + var issetStatementId bool = false; + var issetDevice bool = false; + var issetMeasurement bool = false; + var issetDataType bool = false; + var issetAggregationType bool = false; + + for { + _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) + if err != nil { + return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) + } + if fieldTypeId == thrift.STOP { break; } + switch fieldId { + case 1: + if fieldTypeId == thrift.I64 { + if err := p.ReadField1(ctx, iprot); err != nil { + return err + } + issetSessionId = true + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + case 2: + if fieldTypeId == thrift.I64 { + if err := p.ReadField2(ctx, iprot); err != nil { + return err + } + issetStatementId = true + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + case 3: + if fieldTypeId == thrift.STRING { + if err := p.ReadField3(ctx, iprot); err != nil { + return err + } + issetDevice = true + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + case 4: + if fieldTypeId == thrift.STRING { + if err := p.ReadField4(ctx, iprot); err != nil { + return err + } + issetMeasurement = true + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + case 5: + if fieldTypeId == thrift.I32 { + if err := p.ReadField5(ctx, iprot); err != nil { + return err + } + issetDataType = true + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + case 6: + if fieldTypeId == thrift.I32 { + if err := p.ReadField6(ctx, iprot); err != nil { + return err + } + issetAggregationType = true + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + case 7: + if fieldTypeId == thrift.STRING { + if err := p.ReadField7(ctx, iprot); err != nil { + return err + } + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + case 8: + if fieldTypeId == thrift.I64 { + if err := p.ReadField8(ctx, iprot); err != nil { + return err + } + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + case 9: + if fieldTypeId == thrift.I64 { + if err := p.ReadField9(ctx, iprot); err != nil { + return err + } + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + case 10: + if fieldTypeId == thrift.I64 { + if err := p.ReadField10(ctx, iprot); err != nil { + return err + } + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + case 11: + if fieldTypeId == thrift.I32 { + if err := p.ReadField11(ctx, iprot); err != nil { + return err + } + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + case 12: + if fieldTypeId == thrift.I64 { + if err := p.ReadField12(ctx, iprot); err != nil { + return err + } + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + default: + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + if err := iprot.ReadFieldEnd(ctx); err != nil { + return err + } + } + if err := iprot.ReadStructEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) + } + if !issetSessionId{ + return thrift.NewTProtocolExceptionWithType(thrift.INVALID_DATA, fmt.Errorf("Required field SessionId is not set")); + } + if !issetStatementId{ + return thrift.NewTProtocolExceptionWithType(thrift.INVALID_DATA, fmt.Errorf("Required field StatementId is not set")); + } + if !issetDevice{ + return thrift.NewTProtocolExceptionWithType(thrift.INVALID_DATA, fmt.Errorf("Required field Device is not set")); + } + if !issetMeasurement{ + return thrift.NewTProtocolExceptionWithType(thrift.INVALID_DATA, fmt.Errorf("Required field Measurement is not set")); + } + if !issetDataType{ + return thrift.NewTProtocolExceptionWithType(thrift.INVALID_DATA, fmt.Errorf("Required field DataType is not set")); + } + if !issetAggregationType{ + return thrift.NewTProtocolExceptionWithType(thrift.INVALID_DATA, fmt.Errorf("Required field AggregationType is not set")); + } + return nil +} + +func (p *TSGroupByQueryIntervalReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadI64(ctx); err != nil { + return thrift.PrependError("error reading field 1: ", err) +} else { + p.SessionId = v +} + return nil +} + +func (p *TSGroupByQueryIntervalReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadI64(ctx); err != nil { + return thrift.PrependError("error reading field 2: ", err) +} else { + p.StatementId = v +} + return nil +} + +func (p *TSGroupByQueryIntervalReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadString(ctx); err != nil { + return thrift.PrependError("error reading field 3: ", err) +} else { + p.Device = v +} + return nil +} + +func (p *TSGroupByQueryIntervalReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadString(ctx); err != nil { + return thrift.PrependError("error reading field 4: ", err) +} else { + p.Measurement = v +} + return nil +} + +func (p *TSGroupByQueryIntervalReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadI32(ctx); err != nil { + return thrift.PrependError("error reading field 5: ", err) +} else { + p.DataType = v +} + return nil +} + +func (p *TSGroupByQueryIntervalReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadI32(ctx); err != nil { + return thrift.PrependError("error reading field 6: ", err) +} else { + temp := common.TAggregationType(v) + p.AggregationType = temp +} + return nil +} + +func (p *TSGroupByQueryIntervalReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadString(ctx); err != nil { + return thrift.PrependError("error reading field 7: ", err) +} else { + p.Database = &v +} + return nil +} + +func (p *TSGroupByQueryIntervalReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadI64(ctx); err != nil { + return thrift.PrependError("error reading field 8: ", err) +} else { + p.StartTime = &v +} + return nil +} + +func (p *TSGroupByQueryIntervalReq) ReadField9(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadI64(ctx); err != nil { + return thrift.PrependError("error reading field 9: ", err) +} else { + p.EndTime = &v +} + return nil +} + +func (p *TSGroupByQueryIntervalReq) ReadField10(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadI64(ctx); err != nil { + return thrift.PrependError("error reading field 10: ", err) +} else { + p.Interval = &v +} + return nil +} + +func (p *TSGroupByQueryIntervalReq) ReadField11(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadI32(ctx); err != nil { + return thrift.PrependError("error reading field 11: ", err) +} else { + p.FetchSize = &v +} + return nil +} + +func (p *TSGroupByQueryIntervalReq) ReadField12(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadI64(ctx); err != nil { + return thrift.PrependError("error reading field 12: ", err) +} else { + p.Timeout = &v +} + return nil +} + +func (p *TSGroupByQueryIntervalReq) Write(ctx context.Context, oprot thrift.TProtocol) error { + if err := oprot.WriteStructBegin(ctx, "TSGroupByQueryIntervalReq"); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } + if p != nil { + if err := p.writeField1(ctx, oprot); err != nil { return err } + if err := p.writeField2(ctx, oprot); err != nil { return err } + if err := p.writeField3(ctx, oprot); err != nil { return err } + if err := p.writeField4(ctx, oprot); err != nil { return err } + if err := p.writeField5(ctx, oprot); err != nil { return err } + if err := p.writeField6(ctx, oprot); err != nil { return err } + if err := p.writeField7(ctx, oprot); err != nil { return err } + if err := p.writeField8(ctx, oprot); err != nil { return err } + if err := p.writeField9(ctx, oprot); err != nil { return err } + if err := p.writeField10(ctx, oprot); err != nil { return err } + if err := p.writeField11(ctx, oprot); err != nil { return err } + if err := p.writeField12(ctx, oprot); err != nil { return err } + } + if err := oprot.WriteFieldStop(ctx); err != nil { + return thrift.PrependError("write field stop error: ", err) } + if err := oprot.WriteStructEnd(ctx); err != nil { + return thrift.PrependError("write struct stop error: ", err) } + return nil +} + +func (p *TSGroupByQueryIntervalReq) writeField1(ctx context.Context, oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin(ctx, "sessionId", thrift.I64, 1); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:sessionId: ", p), err) } + if err := oprot.WriteI64(ctx, int64(p.SessionId)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.sessionId (1) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 1:sessionId: ", p), err) } + return err +} + +func (p *TSGroupByQueryIntervalReq) writeField2(ctx context.Context, oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin(ctx, "statementId", thrift.I64, 2); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:statementId: ", p), err) } + if err := oprot.WriteI64(ctx, int64(p.StatementId)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.statementId (2) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 2:statementId: ", p), err) } + return err +} + +func (p *TSGroupByQueryIntervalReq) writeField3(ctx context.Context, oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin(ctx, "device", thrift.STRING, 3); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 3:device: ", p), err) } + if err := oprot.WriteString(ctx, string(p.Device)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.device (3) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 3:device: ", p), err) } + return err +} + +func (p *TSGroupByQueryIntervalReq) writeField4(ctx context.Context, oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin(ctx, "measurement", thrift.STRING, 4); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 4:measurement: ", p), err) } + if err := oprot.WriteString(ctx, string(p.Measurement)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.measurement (4) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 4:measurement: ", p), err) } + return err +} + +func (p *TSGroupByQueryIntervalReq) writeField5(ctx context.Context, oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin(ctx, "dataType", thrift.I32, 5); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 5:dataType: ", p), err) } + if err := oprot.WriteI32(ctx, int32(p.DataType)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.dataType (5) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 5:dataType: ", p), err) } + return err +} + +func (p *TSGroupByQueryIntervalReq) writeField6(ctx context.Context, oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin(ctx, "aggregationType", thrift.I32, 6); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 6:aggregationType: ", p), err) } + if err := oprot.WriteI32(ctx, int32(p.AggregationType)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.aggregationType (6) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 6:aggregationType: ", p), err) } + return err +} + +func (p *TSGroupByQueryIntervalReq) writeField7(ctx context.Context, oprot thrift.TProtocol) (err error) { + if p.IsSetDatabase() { + if err := oprot.WriteFieldBegin(ctx, "database", thrift.STRING, 7); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 7:database: ", p), err) } + if err := oprot.WriteString(ctx, string(*p.Database)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.database (7) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 7:database: ", p), err) } + } + return err +} + +func (p *TSGroupByQueryIntervalReq) writeField8(ctx context.Context, oprot thrift.TProtocol) (err error) { + if p.IsSetStartTime() { + if err := oprot.WriteFieldBegin(ctx, "startTime", thrift.I64, 8); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 8:startTime: ", p), err) } + if err := oprot.WriteI64(ctx, int64(*p.StartTime)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.startTime (8) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 8:startTime: ", p), err) } + } + return err +} + +func (p *TSGroupByQueryIntervalReq) writeField9(ctx context.Context, oprot thrift.TProtocol) (err error) { + if p.IsSetEndTime() { + if err := oprot.WriteFieldBegin(ctx, "endTime", thrift.I64, 9); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 9:endTime: ", p), err) } + if err := oprot.WriteI64(ctx, int64(*p.EndTime)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.endTime (9) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 9:endTime: ", p), err) } + } + return err +} + +func (p *TSGroupByQueryIntervalReq) writeField10(ctx context.Context, oprot thrift.TProtocol) (err error) { + if p.IsSetInterval() { + if err := oprot.WriteFieldBegin(ctx, "interval", thrift.I64, 10); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 10:interval: ", p), err) } + if err := oprot.WriteI64(ctx, int64(*p.Interval)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.interval (10) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 10:interval: ", p), err) } + } + return err +} + +func (p *TSGroupByQueryIntervalReq) writeField11(ctx context.Context, oprot thrift.TProtocol) (err error) { + if p.IsSetFetchSize() { + if err := oprot.WriteFieldBegin(ctx, "fetchSize", thrift.I32, 11); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 11:fetchSize: ", p), err) } + if err := oprot.WriteI32(ctx, int32(*p.FetchSize)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.fetchSize (11) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 11:fetchSize: ", p), err) } + } + return err +} + +func (p *TSGroupByQueryIntervalReq) writeField12(ctx context.Context, oprot thrift.TProtocol) (err error) { + if p.IsSetTimeout() { + if err := oprot.WriteFieldBegin(ctx, "timeout", thrift.I64, 12); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 12:timeout: ", p), err) } + if err := oprot.WriteI64(ctx, int64(*p.Timeout)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.timeout (12) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 12:timeout: ", p), err) } + } + return err +} + +func (p *TSGroupByQueryIntervalReq) Equals(other *TSGroupByQueryIntervalReq) bool { + if p == other { + return true + } else if p == nil || other == nil { + return false + } + if p.SessionId != other.SessionId { return false } + if p.StatementId != other.StatementId { return false } + if p.Device != other.Device { return false } + if p.Measurement != other.Measurement { return false } + if p.DataType != other.DataType { return false } + if p.AggregationType != other.AggregationType { return false } + if p.Database != other.Database { + if p.Database == nil || other.Database == nil { + return false + } + if (*p.Database) != (*other.Database) { return false } + } + if p.StartTime != other.StartTime { + if p.StartTime == nil || other.StartTime == nil { + return false + } + if (*p.StartTime) != (*other.StartTime) { return false } + } + if p.EndTime != other.EndTime { + if p.EndTime == nil || other.EndTime == nil { + return false + } + if (*p.EndTime) != (*other.EndTime) { return false } + } + if p.Interval != other.Interval { + if p.Interval == nil || other.Interval == nil { + return false + } + if (*p.Interval) != (*other.Interval) { return false } + } + if p.FetchSize != other.FetchSize { + if p.FetchSize == nil || other.FetchSize == nil { + return false + } + if (*p.FetchSize) != (*other.FetchSize) { return false } + } + if p.Timeout != other.Timeout { + if p.Timeout == nil || other.Timeout == nil { + return false + } + if (*p.Timeout) != (*other.Timeout) { return false } + } + return true +} + +func (p *TSGroupByQueryIntervalReq) String() string { + if p == nil { + return "<nil>" + } + return fmt.Sprintf("TSGroupByQueryIntervalReq(%+v)", *p) +} + +// Attributes: +// - SessionId // - Paths // - DataTypes // - Encodings @@ -12803,13 +13118,13 @@ tSlice := make([]string, 0, size) p.Paths = tSlice for i := 0; i < size; i ++ { -var _elem148 string +var _elem142 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem148 = v + _elem142 = v } - p.Paths = append(p.Paths, _elem148) + p.Paths = append(p.Paths, _elem142) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -12825,13 +13140,13 @@ tSlice := make([]int32, 0, size) p.DataTypes = tSlice for i := 0; i < size; i ++ { -var _elem149 int32 +var _elem143 int32 if v, err := iprot.ReadI32(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem149 = v + _elem143 = v } - p.DataTypes = append(p.DataTypes, _elem149) + p.DataTypes = append(p.DataTypes, _elem143) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -12847,13 +13162,13 @@ tSlice := make([]int32, 0, size) p.Encodings = tSlice for i := 0; i < size; i ++ { -var _elem150 int32 +var _elem144 int32 if v, err := iprot.ReadI32(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem150 = v + _elem144 = v } - p.Encodings = append(p.Encodings, _elem150) + p.Encodings = append(p.Encodings, _elem144) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -12869,13 +13184,13 @@ tSlice := make([]int32, 0, size) p.Compressors = tSlice for i := 0; i < size; i ++ { -var _elem151 int32 +var _elem145 int32 if v, err := iprot.ReadI32(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem151 = v + _elem145 = v } - p.Compressors = append(p.Compressors, _elem151) + p.Compressors = append(p.Compressors, _elem145) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -12896,6 +13211,86 @@ return thrift.PrependError("error reading map begin: ", err) } tMap := make(map[string]string, size) + _elem146 := tMap + for i := 0; i < size; i ++ { +var _key147 string + if v, err := iprot.ReadString(ctx); err != nil { + return thrift.PrependError("error reading field 0: ", err) +} else { + _key147 = v +} +var _val148 string + if v, err := iprot.ReadString(ctx); err != nil { + return thrift.PrependError("error reading field 0: ", err) +} else { + _val148 = v +} + _elem146[_key147] = _val148 + } + if err := iprot.ReadMapEnd(ctx); err != nil { + return thrift.PrependError("error reading map end: ", err) + } + p.PropsList = append(p.PropsList, _elem146) + } + if err := iprot.ReadListEnd(ctx); err != nil { + return thrift.PrependError("error reading list end: ", err) + } + return nil +} + +func (p *TSCreateMultiTimeseriesReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error { + _, size, err := iprot.ReadListBegin(ctx) + if err != nil { + return thrift.PrependError("error reading list begin: ", err) + } + tSlice := make([]map[string]string, 0, size) + p.TagsList = tSlice + for i := 0; i < size; i ++ { + _, _, size, err := iprot.ReadMapBegin(ctx) + if err != nil { + return thrift.PrependError("error reading map begin: ", err) + } + tMap := make(map[string]string, size) + _elem149 := tMap + for i := 0; i < size; i ++ { +var _key150 string + if v, err := iprot.ReadString(ctx); err != nil { + return thrift.PrependError("error reading field 0: ", err) +} else { + _key150 = v +} +var _val151 string + if v, err := iprot.ReadString(ctx); err != nil { + return thrift.PrependError("error reading field 0: ", err) +} else { + _val151 = v +} + _elem149[_key150] = _val151 + } + if err := iprot.ReadMapEnd(ctx); err != nil { + return thrift.PrependError("error reading map end: ", err) + } + p.TagsList = append(p.TagsList, _elem149) + } + if err := iprot.ReadListEnd(ctx); err != nil { + return thrift.PrependError("error reading list end: ", err) + } + return nil +} + +func (p *TSCreateMultiTimeseriesReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error { + _, size, err := iprot.ReadListBegin(ctx) + if err != nil { + return thrift.PrependError("error reading list begin: ", err) + } + tSlice := make([]map[string]string, 0, size) + p.AttributesList = tSlice + for i := 0; i < size; i ++ { + _, _, size, err := iprot.ReadMapBegin(ctx) + if err != nil { + return thrift.PrependError("error reading map begin: ", err) + } + tMap := make(map[string]string, size) _elem152 := tMap for i := 0; i < size; i ++ { var _key153 string @@ -12915,87 +13310,7 @@ if err := iprot.ReadMapEnd(ctx); err != nil { return thrift.PrependError("error reading map end: ", err) } - p.PropsList = append(p.PropsList, _elem152) - } - if err := iprot.ReadListEnd(ctx); err != nil { - return thrift.PrependError("error reading list end: ", err) - } - return nil -} - -func (p *TSCreateMultiTimeseriesReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error { - _, size, err := iprot.ReadListBegin(ctx) - if err != nil { - return thrift.PrependError("error reading list begin: ", err) - } - tSlice := make([]map[string]string, 0, size) - p.TagsList = tSlice - for i := 0; i < size; i ++ { - _, _, size, err := iprot.ReadMapBegin(ctx) - if err != nil { - return thrift.PrependError("error reading map begin: ", err) - } - tMap := make(map[string]string, size) - _elem155 := tMap - for i := 0; i < size; i ++ { -var _key156 string - if v, err := iprot.ReadString(ctx); err != nil { - return thrift.PrependError("error reading field 0: ", err) -} else { - _key156 = v -} -var _val157 string - if v, err := iprot.ReadString(ctx); err != nil { - return thrift.PrependError("error reading field 0: ", err) -} else { - _val157 = v -} - _elem155[_key156] = _val157 - } - if err := iprot.ReadMapEnd(ctx); err != nil { - return thrift.PrependError("error reading map end: ", err) - } - p.TagsList = append(p.TagsList, _elem155) - } - if err := iprot.ReadListEnd(ctx); err != nil { - return thrift.PrependError("error reading list end: ", err) - } - return nil -} - -func (p *TSCreateMultiTimeseriesReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error { - _, size, err := iprot.ReadListBegin(ctx) - if err != nil { - return thrift.PrependError("error reading list begin: ", err) - } - tSlice := make([]map[string]string, 0, size) - p.AttributesList = tSlice - for i := 0; i < size; i ++ { - _, _, size, err := iprot.ReadMapBegin(ctx) - if err != nil { - return thrift.PrependError("error reading map begin: ", err) - } - tMap := make(map[string]string, size) - _elem158 := tMap - for i := 0; i < size; i ++ { -var _key159 string - if v, err := iprot.ReadString(ctx); err != nil { - return thrift.PrependError("error reading field 0: ", err) -} else { - _key159 = v -} -var _val160 string - if v, err := iprot.ReadString(ctx); err != nil { - return thrift.PrependError("error reading field 0: ", err) -} else { - _val160 = v -} - _elem158[_key159] = _val160 - } - if err := iprot.ReadMapEnd(ctx); err != nil { - return thrift.PrependError("error reading map end: ", err) - } - p.AttributesList = append(p.AttributesList, _elem158) + p.AttributesList = append(p.AttributesList, _elem152) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -13011,13 +13326,13 @@ tSlice := make([]string, 0, size) p.MeasurementAliasList = tSlice for i := 0; i < size; i ++ { -var _elem161 string +var _elem155 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem161 = v + _elem155 = v } - p.MeasurementAliasList = append(p.MeasurementAliasList, _elem161) + p.MeasurementAliasList = append(p.MeasurementAliasList, _elem155) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -13247,55 +13562,55 @@ if p.SessionId != other.SessionId { return false } if len(p.Paths) != len(other.Paths) { return false } for i, _tgt := range p.Paths { - _src162 := other.Paths[i] - if _tgt != _src162 { return false } + _src156 := other.Paths[i] + if _tgt != _src156 { return false } } if len(p.DataTypes) != len(other.DataTypes) { return false } for i, _tgt := range p.DataTypes { - _src163 := other.DataTypes[i] - if _tgt != _src163 { return false } + _src157 := other.DataTypes[i] + if _tgt != _src157 { return false } } if len(p.Encodings) != len(other.Encodings) { return false } for i, _tgt := range p.Encodings { - _src164 := other.Encodings[i] - if _tgt != _src164 { return false } + _src158 := other.Encodings[i] + if _tgt != _src158 { return false } } if len(p.Compressors) != len(other.Compressors) { return false } for i, _tgt := range p.Compressors { - _src165 := other.Compressors[i] - if _tgt != _src165 { return false } + _src159 := other.Compressors[i] + if _tgt != _src159 { return false } } if len(p.PropsList) != len(other.PropsList) { return false } for i, _tgt := range p.PropsList { - _src166 := other.PropsList[i] - if len(_tgt) != len(_src166) { return false } + _src160 := other.PropsList[i] + if len(_tgt) != len(_src160) { return false } for k, _tgt := range _tgt { - _src167 := _src166[k] - if _tgt != _src167 { return false } + _src161 := _src160[k] + if _tgt != _src161 { return false } } } if len(p.TagsList) != len(other.TagsList) { return false } for i, _tgt := range p.TagsList { - _src168 := other.TagsList[i] - if len(_tgt) != len(_src168) { return false } + _src162 := other.TagsList[i] + if len(_tgt) != len(_src162) { return false } for k, _tgt := range _tgt { - _src169 := _src168[k] - if _tgt != _src169 { return false } + _src163 := _src162[k] + if _tgt != _src163 { return false } } } if len(p.AttributesList) != len(other.AttributesList) { return false } for i, _tgt := range p.AttributesList { - _src170 := other.AttributesList[i] - if len(_tgt) != len(_src170) { return false } + _src164 := other.AttributesList[i] + if len(_tgt) != len(_src164) { return false } for k, _tgt := range _tgt { - _src171 := _src170[k] - if _tgt != _src171 { return false } + _src165 := _src164[k] + if _tgt != _src165 { return false } } } if len(p.MeasurementAliasList) != len(other.MeasurementAliasList) { return false } for i, _tgt := range p.MeasurementAliasList { - _src172 := other.MeasurementAliasList[i] - if _tgt != _src172 { return false } + _src166 := other.MeasurementAliasList[i] + if _tgt != _src166 { return false } } return true } @@ -13623,13 +13938,13 @@ tSlice := make([]string, 0, size) p.SupportedTimeAggregationOperations = tSlice for i := 0; i < size; i ++ { -var _elem173 string +var _elem167 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem173 = v + _elem167 = v } - p.SupportedTimeAggregationOperations = append(p.SupportedTimeAggregationOperations, _elem173) + p.SupportedTimeAggregationOperations = append(p.SupportedTimeAggregationOperations, _elem167) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -13904,8 +14219,8 @@ if p.Version != other.Version { return false } if len(p.SupportedTimeAggregationOperations) != len(other.SupportedTimeAggregationOperations) { return false } for i, _tgt := range p.SupportedTimeAggregationOperations { - _src174 := other.SupportedTimeAggregationOperations[i] - if _tgt != _src174 { return false } + _src168 := other.SupportedTimeAggregationOperations[i] + if _tgt != _src168 { return false } } if p.TimestampPrecision != other.TimestampPrecision { return false } if p.MaxConcurrentClientNum != other.MaxConcurrentClientNum { return false } @@ -14565,13 +14880,13 @@ tSlice := make([]string, 0, size) p.Measurements = tSlice for i := 0; i < size; i ++ { -var _elem175 string +var _elem169 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem175 = v + _elem169 = v } - p.Measurements = append(p.Measurements, _elem175) + p.Measurements = append(p.Measurements, _elem169) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -14587,13 +14902,13 @@ tSlice := make([]int32, 0, size) p.DataTypes = tSlice for i := 0; i < size; i ++ { -var _elem176 int32 +var _elem170 int32 if v, err := iprot.ReadI32(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem176 = v + _elem170 = v } - p.DataTypes = append(p.DataTypes, _elem176) + p.DataTypes = append(p.DataTypes, _elem170) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -14609,13 +14924,13 @@ tSlice := make([]int32, 0, size) p.Encodings = tSlice for i := 0; i < size; i ++ { -var _elem177 int32 +var _elem171 int32 if v, err := iprot.ReadI32(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem177 = v + _elem171 = v } - p.Encodings = append(p.Encodings, _elem177) + p.Encodings = append(p.Encodings, _elem171) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -14631,13 +14946,13 @@ tSlice := make([]int32, 0, size) p.Compressors = tSlice for i := 0; i < size; i ++ { -var _elem178 int32 +var _elem172 int32 if v, err := iprot.ReadI32(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem178 = v + _elem172 = v } - p.Compressors = append(p.Compressors, _elem178) + p.Compressors = append(p.Compressors, _elem172) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -14777,23 +15092,23 @@ if p.IsAligned != other.IsAligned { return false } if len(p.Measurements) != len(other.Measurements) { return false } for i, _tgt := range p.Measurements { - _src179 := other.Measurements[i] - if _tgt != _src179 { return false } + _src173 := other.Measurements[i] + if _tgt != _src173 { return false } } if len(p.DataTypes) != len(other.DataTypes) { return false } for i, _tgt := range p.DataTypes { - _src180 := other.DataTypes[i] - if _tgt != _src180 { return false } + _src174 := other.DataTypes[i] + if _tgt != _src174 { return false } } if len(p.Encodings) != len(other.Encodings) { return false } for i, _tgt := range p.Encodings { - _src181 := other.Encodings[i] - if _tgt != _src181 { return false } + _src175 := other.Encodings[i] + if _tgt != _src175 { return false } } if len(p.Compressors) != len(other.Compressors) { return false } for i, _tgt := range p.Compressors { - _src182 := other.Compressors[i] - if _tgt != _src182 { return false } + _src176 := other.Compressors[i] + if _tgt != _src176 { return false } } return true } @@ -15431,13 +15746,13 @@ tSlice := make([]string, 0, size) p.Measurements = tSlice for i := 0; i < size; i ++ { -var _elem183 string +var _elem177 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem183 = v + _elem177 = v } - p.Measurements = append(p.Measurements, _elem183) + p.Measurements = append(p.Measurements, _elem177) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -15549,8 +15864,8 @@ } if len(p.Measurements) != len(other.Measurements) { return false } for i, _tgt := range p.Measurements { - _src184 := other.Measurements[i] - if _tgt != _src184 { return false } + _src178 := other.Measurements[i] + if _tgt != _src178 { return false } } return true } @@ -15995,13 +16310,13 @@ tSlice := make([]string, 0, size) p.DevicePathList = tSlice for i := 0; i < size; i ++ { -var _elem185 string +var _elem179 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem185 = v + _elem179 = v } - p.DevicePathList = append(p.DevicePathList, _elem185) + p.DevicePathList = append(p.DevicePathList, _elem179) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -16060,8 +16375,8 @@ if p.SessionId != other.SessionId { return false } if len(p.DevicePathList) != len(other.DevicePathList) { return false } for i, _tgt := range p.DevicePathList { - _src186 := other.DevicePathList[i] - if _tgt != _src186 { return false } + _src180 := other.DevicePathList[i] + if _tgt != _src180 { return false } } return true } @@ -16454,6 +16769,354 @@ } // Attributes: +// - Version +// - Type +// - Body +type TPipeTransferReq struct { + Version int8 `thrift:"version,1,required" db:"version" json:"version"` + Type int16 `thrift:"type,2,required" db:"type" json:"type"` + Body []byte `thrift:"body,3,required" db:"body" json:"body"` +} + +func NewTPipeTransferReq() *TPipeTransferReq { + return &TPipeTransferReq{} +} + + +func (p *TPipeTransferReq) GetVersion() int8 { + return p.Version +} + +func (p *TPipeTransferReq) GetType() int16 { + return p.Type +} + +func (p *TPipeTransferReq) GetBody() []byte { + return p.Body +} +func (p *TPipeTransferReq) Read(ctx context.Context, iprot thrift.TProtocol) error { + if _, err := iprot.ReadStructBegin(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) + } + + var issetVersion bool = false; + var issetType bool = false; + var issetBody bool = false; + + for { + _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) + if err != nil { + return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) + } + if fieldTypeId == thrift.STOP { break; } + switch fieldId { + case 1: + if fieldTypeId == thrift.BYTE { + if err := p.ReadField1(ctx, iprot); err != nil { + return err + } + issetVersion = true + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + case 2: + if fieldTypeId == thrift.I16 { + if err := p.ReadField2(ctx, iprot); err != nil { + return err + } + issetType = true + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + case 3: + if fieldTypeId == thrift.STRING { + if err := p.ReadField3(ctx, iprot); err != nil { + return err + } + issetBody = true + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + default: + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + if err := iprot.ReadFieldEnd(ctx); err != nil { + return err + } + } + if err := iprot.ReadStructEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) + } + if !issetVersion{ + return thrift.NewTProtocolExceptionWithType(thrift.INVALID_DATA, fmt.Errorf("Required field Version is not set")); + } + if !issetType{ + return thrift.NewTProtocolExceptionWithType(thrift.INVALID_DATA, fmt.Errorf("Required field Type is not set")); + } + if !issetBody{ + return thrift.NewTProtocolExceptionWithType(thrift.INVALID_DATA, fmt.Errorf("Required field Body is not set")); + } + return nil +} + +func (p *TPipeTransferReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadByte(ctx); err != nil { + return thrift.PrependError("error reading field 1: ", err) +} else { + temp := int8(v) + p.Version = temp +} + return nil +} + +func (p *TPipeTransferReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadI16(ctx); err != nil { + return thrift.PrependError("error reading field 2: ", err) +} else { + p.Type = v +} + return nil +} + +func (p *TPipeTransferReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadBinary(ctx); err != nil { + return thrift.PrependError("error reading field 3: ", err) +} else { + p.Body = v +} + return nil +} + +func (p *TPipeTransferReq) Write(ctx context.Context, oprot thrift.TProtocol) error { + if err := oprot.WriteStructBegin(ctx, "TPipeTransferReq"); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } + if p != nil { + if err := p.writeField1(ctx, oprot); err != nil { return err } + if err := p.writeField2(ctx, oprot); err != nil { return err } + if err := p.writeField3(ctx, oprot); err != nil { return err } + } + if err := oprot.WriteFieldStop(ctx); err != nil { + return thrift.PrependError("write field stop error: ", err) } + if err := oprot.WriteStructEnd(ctx); err != nil { + return thrift.PrependError("write struct stop error: ", err) } + return nil +} + +func (p *TPipeTransferReq) writeField1(ctx context.Context, oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin(ctx, "version", thrift.BYTE, 1); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:version: ", p), err) } + if err := oprot.WriteByte(ctx, int8(p.Version)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.version (1) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 1:version: ", p), err) } + return err +} + +func (p *TPipeTransferReq) writeField2(ctx context.Context, oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin(ctx, "type", thrift.I16, 2); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:type: ", p), err) } + if err := oprot.WriteI16(ctx, int16(p.Type)); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.type (2) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 2:type: ", p), err) } + return err +} + +func (p *TPipeTransferReq) writeField3(ctx context.Context, oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin(ctx, "body", thrift.STRING, 3); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 3:body: ", p), err) } + if err := oprot.WriteBinary(ctx, p.Body); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.body (3) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 3:body: ", p), err) } + return err +} + +func (p *TPipeTransferReq) Equals(other *TPipeTransferReq) bool { + if p == other { + return true + } else if p == nil || other == nil { + return false + } + if p.Version != other.Version { return false } + if p.Type != other.Type { return false } + if bytes.Compare(p.Body, other.Body) != 0 { return false } + return true +} + +func (p *TPipeTransferReq) String() string { + if p == nil { + return "<nil>" + } + return fmt.Sprintf("TPipeTransferReq(%+v)", *p) +} + +// Attributes: +// - Status +// - Body +type TPipeTransferResp struct { + Status *common.TSStatus `thrift:"status,1,required" db:"status" json:"status"` + Body []byte `thrift:"body,2" db:"body" json:"body,omitempty"` +} + +func NewTPipeTransferResp() *TPipeTransferResp { + return &TPipeTransferResp{} +} + +var TPipeTransferResp_Status_DEFAULT *common.TSStatus +func (p *TPipeTransferResp) GetStatus() *common.TSStatus { + if !p.IsSetStatus() { + return TPipeTransferResp_Status_DEFAULT + } +return p.Status +} +var TPipeTransferResp_Body_DEFAULT []byte + +func (p *TPipeTransferResp) GetBody() []byte { + return p.Body +} +func (p *TPipeTransferResp) IsSetStatus() bool { + return p.Status != nil +} + +func (p *TPipeTransferResp) IsSetBody() bool { + return p.Body != nil +} + +func (p *TPipeTransferResp) Read(ctx context.Context, iprot thrift.TProtocol) error { + if _, err := iprot.ReadStructBegin(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) + } + + var issetStatus bool = false; + + for { + _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) + if err != nil { + return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) + } + if fieldTypeId == thrift.STOP { break; } + switch fieldId { + case 1: + if fieldTypeId == thrift.STRUCT { + if err := p.ReadField1(ctx, iprot); err != nil { + return err + } + issetStatus = true + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + case 2: + if fieldTypeId == thrift.STRING { + if err := p.ReadField2(ctx, iprot); err != nil { + return err + } + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + default: + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + if err := iprot.ReadFieldEnd(ctx); err != nil { + return err + } + } + if err := iprot.ReadStructEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) + } + if !issetStatus{ + return thrift.NewTProtocolExceptionWithType(thrift.INVALID_DATA, fmt.Errorf("Required field Status is not set")); + } + return nil +} + +func (p *TPipeTransferResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { + p.Status = &common.TSStatus{} + if err := p.Status.Read(ctx, iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Status), err) + } + return nil +} + +func (p *TPipeTransferResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error { + if v, err := iprot.ReadBinary(ctx); err != nil { + return thrift.PrependError("error reading field 2: ", err) +} else { + p.Body = v +} + return nil +} + +func (p *TPipeTransferResp) Write(ctx context.Context, oprot thrift.TProtocol) error { + if err := oprot.WriteStructBegin(ctx, "TPipeTransferResp"); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } + if p != nil { + if err := p.writeField1(ctx, oprot); err != nil { return err } + if err := p.writeField2(ctx, oprot); err != nil { return err } + } + if err := oprot.WriteFieldStop(ctx); err != nil { + return thrift.PrependError("write field stop error: ", err) } + if err := oprot.WriteStructEnd(ctx); err != nil { + return thrift.PrependError("write struct stop error: ", err) } + return nil +} + +func (p *TPipeTransferResp) writeField1(ctx context.Context, oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin(ctx, "status", thrift.STRUCT, 1); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:status: ", p), err) } + if err := p.Status.Write(ctx, oprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Status), err) + } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 1:status: ", p), err) } + return err +} + +func (p *TPipeTransferResp) writeField2(ctx context.Context, oprot thrift.TProtocol) (err error) { + if p.IsSetBody() { + if err := oprot.WriteFieldBegin(ctx, "body", thrift.STRING, 2); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 2:body: ", p), err) } + if err := oprot.WriteBinary(ctx, p.Body); err != nil { + return thrift.PrependError(fmt.Sprintf("%T.body (2) field write error: ", p), err) } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 2:body: ", p), err) } + } + return err +} + +func (p *TPipeTransferResp) Equals(other *TPipeTransferResp) bool { + if p == other { + return true + } else if p == nil || other == nil { + return false + } + if !p.Status.Equals(other.Status) { return false } + if bytes.Compare(p.Body, other.Body) != 0 { return false } + return true +} + +func (p *TPipeTransferResp) String() string { + if p == nil { + return "<nil>" + } + return fmt.Sprintf("TPipeTransferResp(%+v)", *p) +} + +// Attributes: // - Status // - EnableOperationSync // - SecondaryAddress @@ -17017,11 +17680,11 @@ tSlice := make([]*TSConnectionInfo, 0, size) p.ConnectionInfoList = tSlice for i := 0; i < size; i ++ { - _elem187 := &TSConnectionInfo{} - if err := _elem187.Read(ctx, iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem187), err) + _elem181 := &TSConnectionInfo{} + if err := _elem181.Read(ctx, iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", _elem181), err) } - p.ConnectionInfoList = append(p.ConnectionInfoList, _elem187) + p.ConnectionInfoList = append(p.ConnectionInfoList, _elem181) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -17069,8 +17732,8 @@ } if len(p.ConnectionInfoList) != len(other.ConnectionInfoList) { return false } for i, _tgt := range p.ConnectionInfoList { - _src188 := other.ConnectionInfoList[i] - if !_tgt.Equals(_src188) { return false } + _src182 := other.ConnectionInfoList[i] + if !_tgt.Equals(_src182) { return false } } return true } @@ -17179,9 +17842,6 @@ InsertRecords(ctx context.Context, req *TSInsertRecordsReq) (_r *common.TSStatus, _err error) // Parameters: // - Req - FastInsertRecords(ctx context.Context, req *TSFastInsertRecordsReq) (_r *common.TSStatus, _err error) - // Parameters: - // - Req InsertRecordsOfOneDevice(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error) // Parameters: // - Req @@ -17223,6 +17883,9 @@ // - Req ExecuteAggregationQuery(ctx context.Context, req *TSAggregationQueryReq) (_r *TSExecuteStatementResp, _err error) // Parameters: + // - Req + ExecuteGroupByQueryIntervalQuery(ctx context.Context, req *TSGroupByQueryIntervalReq) (_r *TSExecuteStatementResp, _err error) + // Parameters: // - SessionId RequestStatementId(ctx context.Context, sessionId int64) (_r int64, _err error) // Parameters: @@ -17259,6 +17922,9 @@ // - MetaInfo // - Buff SendFile(ctx context.Context, metaInfo *TSyncTransportMetaInfo, buff []byte) (_r *common.TSStatus, _err error) + // Parameters: + // - Req + PipeTransfer(ctx context.Context, req *TPipeTransferReq) (_r *TPipeTransferResp, _err error) GetBackupConfiguration(ctx context.Context) (_r *TSBackupConfigurationResp, _err error) FetchAllConnectionsInfo(ctx context.Context) (_r *TSConnectionInfoResp, _err error) } @@ -17301,11 +17967,41 @@ // Parameters: // - Req func (p *IClientRPCServiceClient) ExecuteQueryStatementV2(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) { - var _args189 IClientRPCServiceExecuteQueryStatementV2Args + var _args183 IClientRPCServiceExecuteQueryStatementV2Args + _args183.Req = req + var _result185 IClientRPCServiceExecuteQueryStatementV2Result + var _meta184 thrift.ResponseMeta + _meta184, _err = p.Client_().Call(ctx, "executeQueryStatementV2", &_args183, &_result185) + p.SetLastResponseMeta_(_meta184) + if _err != nil { + return + } + return _result185.GetSuccess(), nil +} + +// Parameters: +// - Req +func (p *IClientRPCServiceClient) ExecuteUpdateStatementV2(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) { + var _args186 IClientRPCServiceExecuteUpdateStatementV2Args + _args186.Req = req + var _result188 IClientRPCServiceExecuteUpdateStatementV2Result + var _meta187 thrift.ResponseMeta + _meta187, _err = p.Client_().Call(ctx, "executeUpdateStatementV2", &_args186, &_result188) + p.SetLastResponseMeta_(_meta187) + if _err != nil { + return + } + return _result188.GetSuccess(), nil +} + +// Parameters: +// - Req +func (p *IClientRPCServiceClient) ExecuteStatementV2(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) { + var _args189 IClientRPCServiceExecuteStatementV2Args _args189.Req = req - var _result191 IClientRPCServiceExecuteQueryStatementV2Result + var _result191 IClientRPCServiceExecuteStatementV2Result var _meta190 thrift.ResponseMeta - _meta190, _err = p.Client_().Call(ctx, "executeQueryStatementV2", &_args189, &_result191) + _meta190, _err = p.Client_().Call(ctx, "executeStatementV2", &_args189, &_result191) p.SetLastResponseMeta_(_meta190) if _err != nil { return @@ -17315,12 +18011,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) ExecuteUpdateStatementV2(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) { - var _args192 IClientRPCServiceExecuteUpdateStatementV2Args +func (p *IClientRPCServiceClient) ExecuteRawDataQueryV2(ctx context.Context, req *TSRawDataQueryReq) (_r *TSExecuteStatementResp, _err error) { + var _args192 IClientRPCServiceExecuteRawDataQueryV2Args _args192.Req = req - var _result194 IClientRPCServiceExecuteUpdateStatementV2Result + var _result194 IClientRPCServiceExecuteRawDataQueryV2Result var _meta193 thrift.ResponseMeta - _meta193, _err = p.Client_().Call(ctx, "executeUpdateStatementV2", &_args192, &_result194) + _meta193, _err = p.Client_().Call(ctx, "executeRawDataQueryV2", &_args192, &_result194) p.SetLastResponseMeta_(_meta193) if _err != nil { return @@ -17330,12 +18026,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) ExecuteStatementV2(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) { - var _args195 IClientRPCServiceExecuteStatementV2Args +func (p *IClientRPCServiceClient) ExecuteLastDataQueryV2(ctx context.Context, req *TSLastDataQueryReq) (_r *TSExecuteStatementResp, _err error) { + var _args195 IClientRPCServiceExecuteLastDataQueryV2Args _args195.Req = req - var _result197 IClientRPCServiceExecuteStatementV2Result + var _result197 IClientRPCServiceExecuteLastDataQueryV2Result var _meta196 thrift.ResponseMeta - _meta196, _err = p.Client_().Call(ctx, "executeStatementV2", &_args195, &_result197) + _meta196, _err = p.Client_().Call(ctx, "executeLastDataQueryV2", &_args195, &_result197) p.SetLastResponseMeta_(_meta196) if _err != nil { return @@ -17345,12 +18041,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) ExecuteRawDataQueryV2(ctx context.Context, req *TSRawDataQueryReq) (_r *TSExecuteStatementResp, _err error) { - var _args198 IClientRPCServiceExecuteRawDataQueryV2Args +func (p *IClientRPCServiceClient) ExecuteAggregationQueryV2(ctx context.Context, req *TSAggregationQueryReq) (_r *TSExecuteStatementResp, _err error) { + var _args198 IClientRPCServiceExecuteAggregationQueryV2Args _args198.Req = req - var _result200 IClientRPCServiceExecuteRawDataQueryV2Result + var _result200 IClientRPCServiceExecuteAggregationQueryV2Result var _meta199 thrift.ResponseMeta - _meta199, _err = p.Client_().Call(ctx, "executeRawDataQueryV2", &_args198, &_result200) + _meta199, _err = p.Client_().Call(ctx, "executeAggregationQueryV2", &_args198, &_result200) p.SetLastResponseMeta_(_meta199) if _err != nil { return @@ -17360,12 +18056,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) ExecuteLastDataQueryV2(ctx context.Context, req *TSLastDataQueryReq) (_r *TSExecuteStatementResp, _err error) { - var _args201 IClientRPCServiceExecuteLastDataQueryV2Args +func (p *IClientRPCServiceClient) FetchResultsV2(ctx context.Context, req *TSFetchResultsReq) (_r *TSFetchResultsResp, _err error) { + var _args201 IClientRPCServiceFetchResultsV2Args _args201.Req = req - var _result203 IClientRPCServiceExecuteLastDataQueryV2Result + var _result203 IClientRPCServiceFetchResultsV2Result var _meta202 thrift.ResponseMeta - _meta202, _err = p.Client_().Call(ctx, "executeLastDataQueryV2", &_args201, &_result203) + _meta202, _err = p.Client_().Call(ctx, "fetchResultsV2", &_args201, &_result203) p.SetLastResponseMeta_(_meta202) if _err != nil { return @@ -17375,12 +18071,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) ExecuteAggregationQueryV2(ctx context.Context, req *TSAggregationQueryReq) (_r *TSExecuteStatementResp, _err error) { - var _args204 IClientRPCServiceExecuteAggregationQueryV2Args +func (p *IClientRPCServiceClient) OpenSession(ctx context.Context, req *TSOpenSessionReq) (_r *TSOpenSessionResp, _err error) { + var _args204 IClientRPCServiceOpenSessionArgs _args204.Req = req - var _result206 IClientRPCServiceExecuteAggregationQueryV2Result + var _result206 IClientRPCServiceOpenSessionResult var _meta205 thrift.ResponseMeta - _meta205, _err = p.Client_().Call(ctx, "executeAggregationQueryV2", &_args204, &_result206) + _meta205, _err = p.Client_().Call(ctx, "openSession", &_args204, &_result206) p.SetLastResponseMeta_(_meta205) if _err != nil { return @@ -17390,12 +18086,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) FetchResultsV2(ctx context.Context, req *TSFetchResultsReq) (_r *TSFetchResultsResp, _err error) { - var _args207 IClientRPCServiceFetchResultsV2Args +func (p *IClientRPCServiceClient) CloseSession(ctx context.Context, req *TSCloseSessionReq) (_r *common.TSStatus, _err error) { + var _args207 IClientRPCServiceCloseSessionArgs _args207.Req = req - var _result209 IClientRPCServiceFetchResultsV2Result + var _result209 IClientRPCServiceCloseSessionResult var _meta208 thrift.ResponseMeta - _meta208, _err = p.Client_().Call(ctx, "fetchResultsV2", &_args207, &_result209) + _meta208, _err = p.Client_().Call(ctx, "closeSession", &_args207, &_result209) p.SetLastResponseMeta_(_meta208) if _err != nil { return @@ -17405,12 +18101,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) OpenSession(ctx context.Context, req *TSOpenSessionReq) (_r *TSOpenSessionResp, _err error) { - var _args210 IClientRPCServiceOpenSessionArgs +func (p *IClientRPCServiceClient) ExecuteStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) { + var _args210 IClientRPCServiceExecuteStatementArgs _args210.Req = req - var _result212 IClientRPCServiceOpenSessionResult + var _result212 IClientRPCServiceExecuteStatementResult var _meta211 thrift.ResponseMeta - _meta211, _err = p.Client_().Call(ctx, "openSession", &_args210, &_result212) + _meta211, _err = p.Client_().Call(ctx, "executeStatement", &_args210, &_result212) p.SetLastResponseMeta_(_meta211) if _err != nil { return @@ -17420,12 +18116,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) CloseSession(ctx context.Context, req *TSCloseSessionReq) (_r *common.TSStatus, _err error) { - var _args213 IClientRPCServiceCloseSessionArgs +func (p *IClientRPCServiceClient) ExecuteBatchStatement(ctx context.Context, req *TSExecuteBatchStatementReq) (_r *common.TSStatus, _err error) { + var _args213 IClientRPCServiceExecuteBatchStatementArgs _args213.Req = req - var _result215 IClientRPCServiceCloseSessionResult + var _result215 IClientRPCServiceExecuteBatchStatementResult var _meta214 thrift.ResponseMeta - _meta214, _err = p.Client_().Call(ctx, "closeSession", &_args213, &_result215) + _meta214, _err = p.Client_().Call(ctx, "executeBatchStatement", &_args213, &_result215) p.SetLastResponseMeta_(_meta214) if _err != nil { return @@ -17435,12 +18131,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) ExecuteStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) { - var _args216 IClientRPCServiceExecuteStatementArgs +func (p *IClientRPCServiceClient) ExecuteQueryStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) { + var _args216 IClientRPCServiceExecuteQueryStatementArgs _args216.Req = req - var _result218 IClientRPCServiceExecuteStatementResult + var _result218 IClientRPCServiceExecuteQueryStatementResult var _meta217 thrift.ResponseMeta - _meta217, _err = p.Client_().Call(ctx, "executeStatement", &_args216, &_result218) + _meta217, _err = p.Client_().Call(ctx, "executeQueryStatement", &_args216, &_result218) p.SetLastResponseMeta_(_meta217) if _err != nil { return @@ -17450,12 +18146,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) ExecuteBatchStatement(ctx context.Context, req *TSExecuteBatchStatementReq) (_r *common.TSStatus, _err error) { - var _args219 IClientRPCServiceExecuteBatchStatementArgs +func (p *IClientRPCServiceClient) ExecuteUpdateStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) { + var _args219 IClientRPCServiceExecuteUpdateStatementArgs _args219.Req = req - var _result221 IClientRPCServiceExecuteBatchStatementResult + var _result221 IClientRPCServiceExecuteUpdateStatementResult var _meta220 thrift.ResponseMeta - _meta220, _err = p.Client_().Call(ctx, "executeBatchStatement", &_args219, &_result221) + _meta220, _err = p.Client_().Call(ctx, "executeUpdateStatement", &_args219, &_result221) p.SetLastResponseMeta_(_meta220) if _err != nil { return @@ -17465,12 +18161,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) ExecuteQueryStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) { - var _args222 IClientRPCServiceExecuteQueryStatementArgs +func (p *IClientRPCServiceClient) FetchResults(ctx context.Context, req *TSFetchResultsReq) (_r *TSFetchResultsResp, _err error) { + var _args222 IClientRPCServiceFetchResultsArgs _args222.Req = req - var _result224 IClientRPCServiceExecuteQueryStatementResult + var _result224 IClientRPCServiceFetchResultsResult var _meta223 thrift.ResponseMeta - _meta223, _err = p.Client_().Call(ctx, "executeQueryStatement", &_args222, &_result224) + _meta223, _err = p.Client_().Call(ctx, "fetchResults", &_args222, &_result224) p.SetLastResponseMeta_(_meta223) if _err != nil { return @@ -17480,12 +18176,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) ExecuteUpdateStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) { - var _args225 IClientRPCServiceExecuteUpdateStatementArgs +func (p *IClientRPCServiceClient) FetchMetadata(ctx context.Context, req *TSFetchMetadataReq) (_r *TSFetchMetadataResp, _err error) { + var _args225 IClientRPCServiceFetchMetadataArgs _args225.Req = req - var _result227 IClientRPCServiceExecuteUpdateStatementResult + var _result227 IClientRPCServiceFetchMetadataResult var _meta226 thrift.ResponseMeta - _meta226, _err = p.Client_().Call(ctx, "executeUpdateStatement", &_args225, &_result227) + _meta226, _err = p.Client_().Call(ctx, "fetchMetadata", &_args225, &_result227) p.SetLastResponseMeta_(_meta226) if _err != nil { return @@ -17495,12 +18191,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) FetchResults(ctx context.Context, req *TSFetchResultsReq) (_r *TSFetchResultsResp, _err error) { - var _args228 IClientRPCServiceFetchResultsArgs +func (p *IClientRPCServiceClient) CancelOperation(ctx context.Context, req *TSCancelOperationReq) (_r *common.TSStatus, _err error) { + var _args228 IClientRPCServiceCancelOperationArgs _args228.Req = req - var _result230 IClientRPCServiceFetchResultsResult + var _result230 IClientRPCServiceCancelOperationResult var _meta229 thrift.ResponseMeta - _meta229, _err = p.Client_().Call(ctx, "fetchResults", &_args228, &_result230) + _meta229, _err = p.Client_().Call(ctx, "cancelOperation", &_args228, &_result230) p.SetLastResponseMeta_(_meta229) if _err != nil { return @@ -17510,12 +18206,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) FetchMetadata(ctx context.Context, req *TSFetchMetadataReq) (_r *TSFetchMetadataResp, _err error) { - var _args231 IClientRPCServiceFetchMetadataArgs +func (p *IClientRPCServiceClient) CloseOperation(ctx context.Context, req *TSCloseOperationReq) (_r *common.TSStatus, _err error) { + var _args231 IClientRPCServiceCloseOperationArgs _args231.Req = req - var _result233 IClientRPCServiceFetchMetadataResult + var _result233 IClientRPCServiceCloseOperationResult var _meta232 thrift.ResponseMeta - _meta232, _err = p.Client_().Call(ctx, "fetchMetadata", &_args231, &_result233) + _meta232, _err = p.Client_().Call(ctx, "closeOperation", &_args231, &_result233) p.SetLastResponseMeta_(_meta232) if _err != nil { return @@ -17524,13 +18220,13 @@ } // Parameters: -// - Req -func (p *IClientRPCServiceClient) CancelOperation(ctx context.Context, req *TSCancelOperationReq) (_r *common.TSStatus, _err error) { - var _args234 IClientRPCServiceCancelOperationArgs - _args234.Req = req - var _result236 IClientRPCServiceCancelOperationResult +// - SessionId +func (p *IClientRPCServiceClient) GetTimeZone(ctx context.Context, sessionId int64) (_r *TSGetTimeZoneResp, _err error) { + var _args234 IClientRPCServiceGetTimeZoneArgs + _args234.SessionId = sessionId + var _result236 IClientRPCServiceGetTimeZoneResult var _meta235 thrift.ResponseMeta - _meta235, _err = p.Client_().Call(ctx, "cancelOperation", &_args234, &_result236) + _meta235, _err = p.Client_().Call(ctx, "getTimeZone", &_args234, &_result236) p.SetLastResponseMeta_(_meta235) if _err != nil { return @@ -17540,12 +18236,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) CloseOperation(ctx context.Context, req *TSCloseOperationReq) (_r *common.TSStatus, _err error) { - var _args237 IClientRPCServiceCloseOperationArgs +func (p *IClientRPCServiceClient) SetTimeZone(ctx context.Context, req *TSSetTimeZoneReq) (_r *common.TSStatus, _err error) { + var _args237 IClientRPCServiceSetTimeZoneArgs _args237.Req = req - var _result239 IClientRPCServiceCloseOperationResult + var _result239 IClientRPCServiceSetTimeZoneResult var _meta238 thrift.ResponseMeta - _meta238, _err = p.Client_().Call(ctx, "closeOperation", &_args237, &_result239) + _meta238, _err = p.Client_().Call(ctx, "setTimeZone", &_args237, &_result239) p.SetLastResponseMeta_(_meta238) if _err != nil { return @@ -17553,14 +18249,11 @@ return _result239.GetSuccess(), nil } -// Parameters: -// - SessionId -func (p *IClientRPCServiceClient) GetTimeZone(ctx context.Context, sessionId int64) (_r *TSGetTimeZoneResp, _err error) { - var _args240 IClientRPCServiceGetTimeZoneArgs - _args240.SessionId = sessionId - var _result242 IClientRPCServiceGetTimeZoneResult +func (p *IClientRPCServiceClient) GetProperties(ctx context.Context) (_r *ServerProperties, _err error) { + var _args240 IClientRPCServiceGetPropertiesArgs + var _result242 IClientRPCServiceGetPropertiesResult var _meta241 thrift.ResponseMeta - _meta241, _err = p.Client_().Call(ctx, "getTimeZone", &_args240, &_result242) + _meta241, _err = p.Client_().Call(ctx, "getProperties", &_args240, &_result242) p.SetLastResponseMeta_(_meta241) if _err != nil { return @@ -17569,13 +18262,15 @@ } // Parameters: -// - Req -func (p *IClientRPCServiceClient) SetTimeZone(ctx context.Context, req *TSSetTimeZoneReq) (_r *common.TSStatus, _err error) { - var _args243 IClientRPCServiceSetTimeZoneArgs - _args243.Req = req - var _result245 IClientRPCServiceSetTimeZoneResult +// - SessionId +// - StorageGroup +func (p *IClientRPCServiceClient) SetStorageGroup(ctx context.Context, sessionId int64, storageGroup string) (_r *common.TSStatus, _err error) { + var _args243 IClientRPCServiceSetStorageGroupArgs + _args243.SessionId = sessionId + _args243.StorageGroup = storageGroup + var _result245 IClientRPCServiceSetStorageGroupResult var _meta244 thrift.ResponseMeta - _meta244, _err = p.Client_().Call(ctx, "setTimeZone", &_args243, &_result245) + _meta244, _err = p.Client_().Call(ctx, "setStorageGroup", &_args243, &_result245) p.SetLastResponseMeta_(_meta244) if _err != nil { return @@ -17583,11 +18278,14 @@ return _result245.GetSuccess(), nil } -func (p *IClientRPCServiceClient) GetProperties(ctx context.Context) (_r *ServerProperties, _err error) { - var _args246 IClientRPCServiceGetPropertiesArgs - var _result248 IClientRPCServiceGetPropertiesResult +// Parameters: +// - Req +func (p *IClientRPCServiceClient) CreateTimeseries(ctx context.Context, req *TSCreateTimeseriesReq) (_r *common.TSStatus, _err error) { + var _args246 IClientRPCServiceCreateTimeseriesArgs + _args246.Req = req + var _result248 IClientRPCServiceCreateTimeseriesResult var _meta247 thrift.ResponseMeta - _meta247, _err = p.Client_().Call(ctx, "getProperties", &_args246, &_result248) + _meta247, _err = p.Client_().Call(ctx, "createTimeseries", &_args246, &_result248) p.SetLastResponseMeta_(_meta247) if _err != nil { return @@ -17596,15 +18294,13 @@ } // Parameters: -// - SessionId -// - StorageGroup -func (p *IClientRPCServiceClient) SetStorageGroup(ctx context.Context, sessionId int64, storageGroup string) (_r *common.TSStatus, _err error) { - var _args249 IClientRPCServiceSetStorageGroupArgs - _args249.SessionId = sessionId - _args249.StorageGroup = storageGroup - var _result251 IClientRPCServiceSetStorageGroupResult +// - Req +func (p *IClientRPCServiceClient) CreateAlignedTimeseries(ctx context.Context, req *TSCreateAlignedTimeseriesReq) (_r *common.TSStatus, _err error) { + var _args249 IClientRPCServiceCreateAlignedTimeseriesArgs + _args249.Req = req + var _result251 IClientRPCServiceCreateAlignedTimeseriesResult var _meta250 thrift.ResponseMeta - _meta250, _err = p.Client_().Call(ctx, "setStorageGroup", &_args249, &_result251) + _meta250, _err = p.Client_().Call(ctx, "createAlignedTimeseries", &_args249, &_result251) p.SetLastResponseMeta_(_meta250) if _err != nil { return @@ -17614,12 +18310,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) CreateTimeseries(ctx context.Context, req *TSCreateTimeseriesReq) (_r *common.TSStatus, _err error) { - var _args252 IClientRPCServiceCreateTimeseriesArgs +func (p *IClientRPCServiceClient) CreateMultiTimeseries(ctx context.Context, req *TSCreateMultiTimeseriesReq) (_r *common.TSStatus, _err error) { + var _args252 IClientRPCServiceCreateMultiTimeseriesArgs _args252.Req = req - var _result254 IClientRPCServiceCreateTimeseriesResult + var _result254 IClientRPCServiceCreateMultiTimeseriesResult var _meta253 thrift.ResponseMeta - _meta253, _err = p.Client_().Call(ctx, "createTimeseries", &_args252, &_result254) + _meta253, _err = p.Client_().Call(ctx, "createMultiTimeseries", &_args252, &_result254) p.SetLastResponseMeta_(_meta253) if _err != nil { return @@ -17628,13 +18324,15 @@ } // Parameters: -// - Req -func (p *IClientRPCServiceClient) CreateAlignedTimeseries(ctx context.Context, req *TSCreateAlignedTimeseriesReq) (_r *common.TSStatus, _err error) { - var _args255 IClientRPCServiceCreateAlignedTimeseriesArgs - _args255.Req = req - var _result257 IClientRPCServiceCreateAlignedTimeseriesResult +// - SessionId +// - Path +func (p *IClientRPCServiceClient) DeleteTimeseries(ctx context.Context, sessionId int64, path []string) (_r *common.TSStatus, _err error) { + var _args255 IClientRPCServiceDeleteTimeseriesArgs + _args255.SessionId = sessionId + _args255.Path = path + var _result257 IClientRPCServiceDeleteTimeseriesResult var _meta256 thrift.ResponseMeta - _meta256, _err = p.Client_().Call(ctx, "createAlignedTimeseries", &_args255, &_result257) + _meta256, _err = p.Client_().Call(ctx, "deleteTimeseries", &_args255, &_result257) p.SetLastResponseMeta_(_meta256) if _err != nil { return @@ -17643,13 +18341,15 @@ } // Parameters: -// - Req -func (p *IClientRPCServiceClient) CreateMultiTimeseries(ctx context.Context, req *TSCreateMultiTimeseriesReq) (_r *common.TSStatus, _err error) { - var _args258 IClientRPCServiceCreateMultiTimeseriesArgs - _args258.Req = req - var _result260 IClientRPCServiceCreateMultiTimeseriesResult +// - SessionId +// - StorageGroup +func (p *IClientRPCServiceClient) DeleteStorageGroups(ctx context.Context, sessionId int64, storageGroup []string) (_r *common.TSStatus, _err error) { + var _args258 IClientRPCServiceDeleteStorageGroupsArgs + _args258.SessionId = sessionId + _args258.StorageGroup = storageGroup + var _result260 IClientRPCServiceDeleteStorageGroupsResult var _meta259 thrift.ResponseMeta - _meta259, _err = p.Client_().Call(ctx, "createMultiTimeseries", &_args258, &_result260) + _meta259, _err = p.Client_().Call(ctx, "deleteStorageGroups", &_args258, &_result260) p.SetLastResponseMeta_(_meta259) if _err != nil { return @@ -17658,15 +18358,13 @@ } // Parameters: -// - SessionId -// - Path -func (p *IClientRPCServiceClient) DeleteTimeseries(ctx context.Context, sessionId int64, path []string) (_r *common.TSStatus, _err error) { - var _args261 IClientRPCServiceDeleteTimeseriesArgs - _args261.SessionId = sessionId - _args261.Path = path - var _result263 IClientRPCServiceDeleteTimeseriesResult +// - Req +func (p *IClientRPCServiceClient) InsertRecord(ctx context.Context, req *TSInsertRecordReq) (_r *common.TSStatus, _err error) { + var _args261 IClientRPCServiceInsertRecordArgs + _args261.Req = req + var _result263 IClientRPCServiceInsertRecordResult var _meta262 thrift.ResponseMeta - _meta262, _err = p.Client_().Call(ctx, "deleteTimeseries", &_args261, &_result263) + _meta262, _err = p.Client_().Call(ctx, "insertRecord", &_args261, &_result263) p.SetLastResponseMeta_(_meta262) if _err != nil { return @@ -17675,15 +18373,13 @@ } // Parameters: -// - SessionId -// - StorageGroup -func (p *IClientRPCServiceClient) DeleteStorageGroups(ctx context.Context, sessionId int64, storageGroup []string) (_r *common.TSStatus, _err error) { - var _args264 IClientRPCServiceDeleteStorageGroupsArgs - _args264.SessionId = sessionId - _args264.StorageGroup = storageGroup - var _result266 IClientRPCServiceDeleteStorageGroupsResult +// - Req +func (p *IClientRPCServiceClient) InsertStringRecord(ctx context.Context, req *TSInsertStringRecordReq) (_r *common.TSStatus, _err error) { + var _args264 IClientRPCServiceInsertStringRecordArgs + _args264.Req = req + var _result266 IClientRPCServiceInsertStringRecordResult var _meta265 thrift.ResponseMeta - _meta265, _err = p.Client_().Call(ctx, "deleteStorageGroups", &_args264, &_result266) + _meta265, _err = p.Client_().Call(ctx, "insertStringRecord", &_args264, &_result266) p.SetLastResponseMeta_(_meta265) if _err != nil { return @@ -17693,12 +18389,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) InsertRecord(ctx context.Context, req *TSInsertRecordReq) (_r *common.TSStatus, _err error) { - var _args267 IClientRPCServiceInsertRecordArgs +func (p *IClientRPCServiceClient) InsertTablet(ctx context.Context, req *TSInsertTabletReq) (_r *common.TSStatus, _err error) { + var _args267 IClientRPCServiceInsertTabletArgs _args267.Req = req - var _result269 IClientRPCServiceInsertRecordResult + var _result269 IClientRPCServiceInsertTabletResult var _meta268 thrift.ResponseMeta - _meta268, _err = p.Client_().Call(ctx, "insertRecord", &_args267, &_result269) + _meta268, _err = p.Client_().Call(ctx, "insertTablet", &_args267, &_result269) p.SetLastResponseMeta_(_meta268) if _err != nil { return @@ -17708,12 +18404,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) InsertStringRecord(ctx context.Context, req *TSInsertStringRecordReq) (_r *common.TSStatus, _err error) { - var _args270 IClientRPCServiceInsertStringRecordArgs +func (p *IClientRPCServiceClient) InsertTablets(ctx context.Context, req *TSInsertTabletsReq) (_r *common.TSStatus, _err error) { + var _args270 IClientRPCServiceInsertTabletsArgs _args270.Req = req - var _result272 IClientRPCServiceInsertStringRecordResult + var _result272 IClientRPCServiceInsertTabletsResult var _meta271 thrift.ResponseMeta - _meta271, _err = p.Client_().Call(ctx, "insertStringRecord", &_args270, &_result272) + _meta271, _err = p.Client_().Call(ctx, "insertTablets", &_args270, &_result272) p.SetLastResponseMeta_(_meta271) if _err != nil { return @@ -17723,12 +18419,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) InsertTablet(ctx context.Context, req *TSInsertTabletReq) (_r *common.TSStatus, _err error) { - var _args273 IClientRPCServiceInsertTabletArgs +func (p *IClientRPCServiceClient) InsertRecords(ctx context.Context, req *TSInsertRecordsReq) (_r *common.TSStatus, _err error) { + var _args273 IClientRPCServiceInsertRecordsArgs _args273.Req = req - var _result275 IClientRPCServiceInsertTabletResult + var _result275 IClientRPCServiceInsertRecordsResult var _meta274 thrift.ResponseMeta - _meta274, _err = p.Client_().Call(ctx, "insertTablet", &_args273, &_result275) + _meta274, _err = p.Client_().Call(ctx, "insertRecords", &_args273, &_result275) p.SetLastResponseMeta_(_meta274) if _err != nil { return @@ -17738,12 +18434,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) InsertTablets(ctx context.Context, req *TSInsertTabletsReq) (_r *common.TSStatus, _err error) { - var _args276 IClientRPCServiceInsertTabletsArgs +func (p *IClientRPCServiceClient) InsertRecordsOfOneDevice(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error) { + var _args276 IClientRPCServiceInsertRecordsOfOneDeviceArgs _args276.Req = req - var _result278 IClientRPCServiceInsertTabletsResult + var _result278 IClientRPCServiceInsertRecordsOfOneDeviceResult var _meta277 thrift.ResponseMeta - _meta277, _err = p.Client_().Call(ctx, "insertTablets", &_args276, &_result278) + _meta277, _err = p.Client_().Call(ctx, "insertRecordsOfOneDevice", &_args276, &_result278) p.SetLastResponseMeta_(_meta277) if _err != nil { return @@ -17753,12 +18449,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) InsertRecords(ctx context.Context, req *TSInsertRecordsReq) (_r *common.TSStatus, _err error) { - var _args279 IClientRPCServiceInsertRecordsArgs +func (p *IClientRPCServiceClient) InsertStringRecordsOfOneDevice(ctx context.Context, req *TSInsertStringRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error) { + var _args279 IClientRPCServiceInsertStringRecordsOfOneDeviceArgs _args279.Req = req - var _result281 IClientRPCServiceInsertRecordsResult + var _result281 IClientRPCServiceInsertStringRecordsOfOneDeviceResult var _meta280 thrift.ResponseMeta - _meta280, _err = p.Client_().Call(ctx, "insertRecords", &_args279, &_result281) + _meta280, _err = p.Client_().Call(ctx, "insertStringRecordsOfOneDevice", &_args279, &_result281) p.SetLastResponseMeta_(_meta280) if _err != nil { return @@ -17768,12 +18464,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) FastInsertRecords(ctx context.Context, req *TSFastInsertRecordsReq) (_r *common.TSStatus, _err error) { - var _args282 IClientRPCServiceFastInsertRecordsArgs +func (p *IClientRPCServiceClient) InsertStringRecords(ctx context.Context, req *TSInsertStringRecordsReq) (_r *common.TSStatus, _err error) { + var _args282 IClientRPCServiceInsertStringRecordsArgs _args282.Req = req - var _result284 IClientRPCServiceFastInsertRecordsResult + var _result284 IClientRPCServiceInsertStringRecordsResult var _meta283 thrift.ResponseMeta - _meta283, _err = p.Client_().Call(ctx, "fastInsertRecords", &_args282, &_result284) + _meta283, _err = p.Client_().Call(ctx, "insertStringRecords", &_args282, &_result284) p.SetLastResponseMeta_(_meta283) if _err != nil { return @@ -17783,12 +18479,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) InsertRecordsOfOneDevice(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error) { - var _args285 IClientRPCServiceInsertRecordsOfOneDeviceArgs +func (p *IClientRPCServiceClient) TestInsertTablet(ctx context.Context, req *TSInsertTabletReq) (_r *common.TSStatus, _err error) { + var _args285 IClientRPCServiceTestInsertTabletArgs _args285.Req = req - var _result287 IClientRPCServiceInsertRecordsOfOneDeviceResult + var _result287 IClientRPCServiceTestInsertTabletResult var _meta286 thrift.ResponseMeta - _meta286, _err = p.Client_().Call(ctx, "insertRecordsOfOneDevice", &_args285, &_result287) + _meta286, _err = p.Client_().Call(ctx, "testInsertTablet", &_args285, &_result287) p.SetLastResponseMeta_(_meta286) if _err != nil { return @@ -17798,12 +18494,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) InsertStringRecordsOfOneDevice(ctx context.Context, req *TSInsertStringRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error) { - var _args288 IClientRPCServiceInsertStringRecordsOfOneDeviceArgs +func (p *IClientRPCServiceClient) TestInsertTablets(ctx context.Context, req *TSInsertTabletsReq) (_r *common.TSStatus, _err error) { + var _args288 IClientRPCServiceTestInsertTabletsArgs _args288.Req = req - var _result290 IClientRPCServiceInsertStringRecordsOfOneDeviceResult + var _result290 IClientRPCServiceTestInsertTabletsResult var _meta289 thrift.ResponseMeta - _meta289, _err = p.Client_().Call(ctx, "insertStringRecordsOfOneDevice", &_args288, &_result290) + _meta289, _err = p.Client_().Call(ctx, "testInsertTablets", &_args288, &_result290) p.SetLastResponseMeta_(_meta289) if _err != nil { return @@ -17813,12 +18509,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) InsertStringRecords(ctx context.Context, req *TSInsertStringRecordsReq) (_r *common.TSStatus, _err error) { - var _args291 IClientRPCServiceInsertStringRecordsArgs +func (p *IClientRPCServiceClient) TestInsertRecord(ctx context.Context, req *TSInsertRecordReq) (_r *common.TSStatus, _err error) { + var _args291 IClientRPCServiceTestInsertRecordArgs _args291.Req = req - var _result293 IClientRPCServiceInsertStringRecordsResult + var _result293 IClientRPCServiceTestInsertRecordResult var _meta292 thrift.ResponseMeta - _meta292, _err = p.Client_().Call(ctx, "insertStringRecords", &_args291, &_result293) + _meta292, _err = p.Client_().Call(ctx, "testInsertRecord", &_args291, &_result293) p.SetLastResponseMeta_(_meta292) if _err != nil { return @@ -17828,12 +18524,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) TestInsertTablet(ctx context.Context, req *TSInsertTabletReq) (_r *common.TSStatus, _err error) { - var _args294 IClientRPCServiceTestInsertTabletArgs +func (p *IClientRPCServiceClient) TestInsertStringRecord(ctx context.Context, req *TSInsertStringRecordReq) (_r *common.TSStatus, _err error) { + var _args294 IClientRPCServiceTestInsertStringRecordArgs _args294.Req = req - var _result296 IClientRPCServiceTestInsertTabletResult + var _result296 IClientRPCServiceTestInsertStringRecordResult var _meta295 thrift.ResponseMeta - _meta295, _err = p.Client_().Call(ctx, "testInsertTablet", &_args294, &_result296) + _meta295, _err = p.Client_().Call(ctx, "testInsertStringRecord", &_args294, &_result296) p.SetLastResponseMeta_(_meta295) if _err != nil { return @@ -17843,12 +18539,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) TestInsertTablets(ctx context.Context, req *TSInsertTabletsReq) (_r *common.TSStatus, _err error) { - var _args297 IClientRPCServiceTestInsertTabletsArgs +func (p *IClientRPCServiceClient) TestInsertRecords(ctx context.Context, req *TSInsertRecordsReq) (_r *common.TSStatus, _err error) { + var _args297 IClientRPCServiceTestInsertRecordsArgs _args297.Req = req - var _result299 IClientRPCServiceTestInsertTabletsResult + var _result299 IClientRPCServiceTestInsertRecordsResult var _meta298 thrift.ResponseMeta - _meta298, _err = p.Client_().Call(ctx, "testInsertTablets", &_args297, &_result299) + _meta298, _err = p.Client_().Call(ctx, "testInsertRecords", &_args297, &_result299) p.SetLastResponseMeta_(_meta298) if _err != nil { return @@ -17858,12 +18554,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) TestInsertRecord(ctx context.Context, req *TSInsertRecordReq) (_r *common.TSStatus, _err error) { - var _args300 IClientRPCServiceTestInsertRecordArgs +func (p *IClientRPCServiceClient) TestInsertRecordsOfOneDevice(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error) { + var _args300 IClientRPCServiceTestInsertRecordsOfOneDeviceArgs _args300.Req = req - var _result302 IClientRPCServiceTestInsertRecordResult + var _result302 IClientRPCServiceTestInsertRecordsOfOneDeviceResult var _meta301 thrift.ResponseMeta - _meta301, _err = p.Client_().Call(ctx, "testInsertRecord", &_args300, &_result302) + _meta301, _err = p.Client_().Call(ctx, "testInsertRecordsOfOneDevice", &_args300, &_result302) p.SetLastResponseMeta_(_meta301) if _err != nil { return @@ -17873,12 +18569,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) TestInsertStringRecord(ctx context.Context, req *TSInsertStringRecordReq) (_r *common.TSStatus, _err error) { - var _args303 IClientRPCServiceTestInsertStringRecordArgs +func (p *IClientRPCServiceClient) TestInsertStringRecords(ctx context.Context, req *TSInsertStringRecordsReq) (_r *common.TSStatus, _err error) { + var _args303 IClientRPCServiceTestInsertStringRecordsArgs _args303.Req = req - var _result305 IClientRPCServiceTestInsertStringRecordResult + var _result305 IClientRPCServiceTestInsertStringRecordsResult var _meta304 thrift.ResponseMeta - _meta304, _err = p.Client_().Call(ctx, "testInsertStringRecord", &_args303, &_result305) + _meta304, _err = p.Client_().Call(ctx, "testInsertStringRecords", &_args303, &_result305) p.SetLastResponseMeta_(_meta304) if _err != nil { return @@ -17888,12 +18584,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) TestInsertRecords(ctx context.Context, req *TSInsertRecordsReq) (_r *common.TSStatus, _err error) { - var _args306 IClientRPCServiceTestInsertRecordsArgs +func (p *IClientRPCServiceClient) DeleteData(ctx context.Context, req *TSDeleteDataReq) (_r *common.TSStatus, _err error) { + var _args306 IClientRPCServiceDeleteDataArgs _args306.Req = req - var _result308 IClientRPCServiceTestInsertRecordsResult + var _result308 IClientRPCServiceDeleteDataResult var _meta307 thrift.ResponseMeta - _meta307, _err = p.Client_().Call(ctx, "testInsertRecords", &_args306, &_result308) + _meta307, _err = p.Client_().Call(ctx, "deleteData", &_args306, &_result308) p.SetLastResponseMeta_(_meta307) if _err != nil { return @@ -17903,12 +18599,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) TestInsertRecordsOfOneDevice(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error) { - var _args309 IClientRPCServiceTestInsertRecordsOfOneDeviceArgs +func (p *IClientRPCServiceClient) ExecuteRawDataQuery(ctx context.Context, req *TSRawDataQueryReq) (_r *TSExecuteStatementResp, _err error) { + var _args309 IClientRPCServiceExecuteRawDataQueryArgs _args309.Req = req - var _result311 IClientRPCServiceTestInsertRecordsOfOneDeviceResult + var _result311 IClientRPCServiceExecuteRawDataQueryResult var _meta310 thrift.ResponseMeta - _meta310, _err = p.Client_().Call(ctx, "testInsertRecordsOfOneDevice", &_args309, &_result311) + _meta310, _err = p.Client_().Call(ctx, "executeRawDataQuery", &_args309, &_result311) p.SetLastResponseMeta_(_meta310) if _err != nil { return @@ -17918,12 +18614,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) TestInsertStringRecords(ctx context.Context, req *TSInsertStringRecordsReq) (_r *common.TSStatus, _err error) { - var _args312 IClientRPCServiceTestInsertStringRecordsArgs +func (p *IClientRPCServiceClient) ExecuteLastDataQuery(ctx context.Context, req *TSLastDataQueryReq) (_r *TSExecuteStatementResp, _err error) { + var _args312 IClientRPCServiceExecuteLastDataQueryArgs _args312.Req = req - var _result314 IClientRPCServiceTestInsertStringRecordsResult + var _result314 IClientRPCServiceExecuteLastDataQueryResult var _meta313 thrift.ResponseMeta - _meta313, _err = p.Client_().Call(ctx, "testInsertStringRecords", &_args312, &_result314) + _meta313, _err = p.Client_().Call(ctx, "executeLastDataQuery", &_args312, &_result314) p.SetLastResponseMeta_(_meta313) if _err != nil { return @@ -17933,12 +18629,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) DeleteData(ctx context.Context, req *TSDeleteDataReq) (_r *common.TSStatus, _err error) { - var _args315 IClientRPCServiceDeleteDataArgs +func (p *IClientRPCServiceClient) ExecuteAggregationQuery(ctx context.Context, req *TSAggregationQueryReq) (_r *TSExecuteStatementResp, _err error) { + var _args315 IClientRPCServiceExecuteAggregationQueryArgs _args315.Req = req - var _result317 IClientRPCServiceDeleteDataResult + var _result317 IClientRPCServiceExecuteAggregationQueryResult var _meta316 thrift.ResponseMeta - _meta316, _err = p.Client_().Call(ctx, "deleteData", &_args315, &_result317) + _meta316, _err = p.Client_().Call(ctx, "executeAggregationQuery", &_args315, &_result317) p.SetLastResponseMeta_(_meta316) if _err != nil { return @@ -17948,12 +18644,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) ExecuteRawDataQuery(ctx context.Context, req *TSRawDataQueryReq) (_r *TSExecuteStatementResp, _err error) { - var _args318 IClientRPCServiceExecuteRawDataQueryArgs +func (p *IClientRPCServiceClient) ExecuteGroupByQueryIntervalQuery(ctx context.Context, req *TSGroupByQueryIntervalReq) (_r *TSExecuteStatementResp, _err error) { + var _args318 IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs _args318.Req = req - var _result320 IClientRPCServiceExecuteRawDataQueryResult + var _result320 IClientRPCServiceExecuteGroupByQueryIntervalQueryResult var _meta319 thrift.ResponseMeta - _meta319, _err = p.Client_().Call(ctx, "executeRawDataQuery", &_args318, &_result320) + _meta319, _err = p.Client_().Call(ctx, "executeGroupByQueryIntervalQuery", &_args318, &_result320) p.SetLastResponseMeta_(_meta319) if _err != nil { return @@ -17962,13 +18658,13 @@ } // Parameters: -// - Req -func (p *IClientRPCServiceClient) ExecuteLastDataQuery(ctx context.Context, req *TSLastDataQueryReq) (_r *TSExecuteStatementResp, _err error) { - var _args321 IClientRPCServiceExecuteLastDataQueryArgs - _args321.Req = req - var _result323 IClientRPCServiceExecuteLastDataQueryResult +// - SessionId +func (p *IClientRPCServiceClient) RequestStatementId(ctx context.Context, sessionId int64) (_r int64, _err error) { + var _args321 IClientRPCServiceRequestStatementIdArgs + _args321.SessionId = sessionId + var _result323 IClientRPCServiceRequestStatementIdResult var _meta322 thrift.ResponseMeta - _meta322, _err = p.Client_().Call(ctx, "executeLastDataQuery", &_args321, &_result323) + _meta322, _err = p.Client_().Call(ctx, "requestStatementId", &_args321, &_result323) p.SetLastResponseMeta_(_meta322) if _err != nil { return @@ -17978,12 +18674,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) ExecuteAggregationQuery(ctx context.Context, req *TSAggregationQueryReq) (_r *TSExecuteStatementResp, _err error) { - var _args324 IClientRPCServiceExecuteAggregationQueryArgs +func (p *IClientRPCServiceClient) CreateSchemaTemplate(ctx context.Context, req *TSCreateSchemaTemplateReq) (_r *common.TSStatus, _err error) { + var _args324 IClientRPCServiceCreateSchemaTemplateArgs _args324.Req = req - var _result326 IClientRPCServiceExecuteAggregationQueryResult + var _result326 IClientRPCServiceCreateSchemaTemplateResult var _meta325 thrift.ResponseMeta - _meta325, _err = p.Client_().Call(ctx, "executeAggregationQuery", &_args324, &_result326) + _meta325, _err = p.Client_().Call(ctx, "createSchemaTemplate", &_args324, &_result326) p.SetLastResponseMeta_(_meta325) if _err != nil { return @@ -17992,13 +18688,13 @@ } // Parameters: -// - SessionId -func (p *IClientRPCServiceClient) RequestStatementId(ctx context.Context, sessionId int64) (_r int64, _err error) { - var _args327 IClientRPCServiceRequestStatementIdArgs - _args327.SessionId = sessionId - var _result329 IClientRPCServiceRequestStatementIdResult +// - Req +func (p *IClientRPCServiceClient) AppendSchemaTemplate(ctx context.Context, req *TSAppendSchemaTemplateReq) (_r *common.TSStatus, _err error) { + var _args327 IClientRPCServiceAppendSchemaTemplateArgs + _args327.Req = req + var _result329 IClientRPCServiceAppendSchemaTemplateResult var _meta328 thrift.ResponseMeta - _meta328, _err = p.Client_().Call(ctx, "requestStatementId", &_args327, &_result329) + _meta328, _err = p.Client_().Call(ctx, "appendSchemaTemplate", &_args327, &_result329) p.SetLastResponseMeta_(_meta328) if _err != nil { return @@ -18008,12 +18704,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) CreateSchemaTemplate(ctx context.Context, req *TSCreateSchemaTemplateReq) (_r *common.TSStatus, _err error) { - var _args330 IClientRPCServiceCreateSchemaTemplateArgs +func (p *IClientRPCServiceClient) PruneSchemaTemplate(ctx context.Context, req *TSPruneSchemaTemplateReq) (_r *common.TSStatus, _err error) { + var _args330 IClientRPCServicePruneSchemaTemplateArgs _args330.Req = req - var _result332 IClientRPCServiceCreateSchemaTemplateResult + var _result332 IClientRPCServicePruneSchemaTemplateResult var _meta331 thrift.ResponseMeta - _meta331, _err = p.Client_().Call(ctx, "createSchemaTemplate", &_args330, &_result332) + _meta331, _err = p.Client_().Call(ctx, "pruneSchemaTemplate", &_args330, &_result332) p.SetLastResponseMeta_(_meta331) if _err != nil { return @@ -18023,12 +18719,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) AppendSchemaTemplate(ctx context.Context, req *TSAppendSchemaTemplateReq) (_r *common.TSStatus, _err error) { - var _args333 IClientRPCServiceAppendSchemaTemplateArgs +func (p *IClientRPCServiceClient) QuerySchemaTemplate(ctx context.Context, req *TSQueryTemplateReq) (_r *TSQueryTemplateResp, _err error) { + var _args333 IClientRPCServiceQuerySchemaTemplateArgs _args333.Req = req - var _result335 IClientRPCServiceAppendSchemaTemplateResult + var _result335 IClientRPCServiceQuerySchemaTemplateResult var _meta334 thrift.ResponseMeta - _meta334, _err = p.Client_().Call(ctx, "appendSchemaTemplate", &_args333, &_result335) + _meta334, _err = p.Client_().Call(ctx, "querySchemaTemplate", &_args333, &_result335) p.SetLastResponseMeta_(_meta334) if _err != nil { return @@ -18038,12 +18734,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) PruneSchemaTemplate(ctx context.Context, req *TSPruneSchemaTemplateReq) (_r *common.TSStatus, _err error) { - var _args336 IClientRPCServicePruneSchemaTemplateArgs +func (p *IClientRPCServiceClient) SetSchemaTemplate(ctx context.Context, req *TSSetSchemaTemplateReq) (_r *common.TSStatus, _err error) { + var _args336 IClientRPCServiceSetSchemaTemplateArgs _args336.Req = req - var _result338 IClientRPCServicePruneSchemaTemplateResult + var _result338 IClientRPCServiceSetSchemaTemplateResult var _meta337 thrift.ResponseMeta - _meta337, _err = p.Client_().Call(ctx, "pruneSchemaTemplate", &_args336, &_result338) + _meta337, _err = p.Client_().Call(ctx, "setSchemaTemplate", &_args336, &_result338) p.SetLastResponseMeta_(_meta337) if _err != nil { return @@ -18053,12 +18749,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) QuerySchemaTemplate(ctx context.Context, req *TSQueryTemplateReq) (_r *TSQueryTemplateResp, _err error) { - var _args339 IClientRPCServiceQuerySchemaTemplateArgs +func (p *IClientRPCServiceClient) UnsetSchemaTemplate(ctx context.Context, req *TSUnsetSchemaTemplateReq) (_r *common.TSStatus, _err error) { + var _args339 IClientRPCServiceUnsetSchemaTemplateArgs _args339.Req = req - var _result341 IClientRPCServiceQuerySchemaTemplateResult + var _result341 IClientRPCServiceUnsetSchemaTemplateResult var _meta340 thrift.ResponseMeta - _meta340, _err = p.Client_().Call(ctx, "querySchemaTemplate", &_args339, &_result341) + _meta340, _err = p.Client_().Call(ctx, "unsetSchemaTemplate", &_args339, &_result341) p.SetLastResponseMeta_(_meta340) if _err != nil { return @@ -18068,12 +18764,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) SetSchemaTemplate(ctx context.Context, req *TSSetSchemaTemplateReq) (_r *common.TSStatus, _err error) { - var _args342 IClientRPCServiceSetSchemaTemplateArgs +func (p *IClientRPCServiceClient) DropSchemaTemplate(ctx context.Context, req *TSDropSchemaTemplateReq) (_r *common.TSStatus, _err error) { + var _args342 IClientRPCServiceDropSchemaTemplateArgs _args342.Req = req - var _result344 IClientRPCServiceSetSchemaTemplateResult + var _result344 IClientRPCServiceDropSchemaTemplateResult var _meta343 thrift.ResponseMeta - _meta343, _err = p.Client_().Call(ctx, "setSchemaTemplate", &_args342, &_result344) + _meta343, _err = p.Client_().Call(ctx, "dropSchemaTemplate", &_args342, &_result344) p.SetLastResponseMeta_(_meta343) if _err != nil { return @@ -18083,12 +18779,12 @@ // Parameters: // - Req -func (p *IClientRPCServiceClient) UnsetSchemaTemplate(ctx context.Context, req *TSUnsetSchemaTemplateReq) (_r *common.TSStatus, _err error) { - var _args345 IClientRPCServiceUnsetSchemaTemplateArgs +func (p *IClientRPCServiceClient) CreateTimeseriesUsingSchemaTemplate(ctx context.Context, req *TCreateTimeseriesUsingSchemaTemplateReq) (_r *common.TSStatus, _err error) { + var _args345 IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs _args345.Req = req - var _result347 IClientRPCServiceUnsetSchemaTemplateResult + var _result347 IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult var _meta346 thrift.ResponseMeta - _meta346, _err = p.Client_().Call(ctx, "unsetSchemaTemplate", &_args345, &_result347) + _meta346, _err = p.Client_().Call(ctx, "createTimeseriesUsingSchemaTemplate", &_args345, &_result347) p.SetLastResponseMeta_(_meta346) if _err != nil { return @@ -18097,13 +18793,13 @@ } // Parameters: -// - Req -func (p *IClientRPCServiceClient) DropSchemaTemplate(ctx context.Context, req *TSDropSchemaTemplateReq) (_r *common.TSStatus, _err error) { - var _args348 IClientRPCServiceDropSchemaTemplateArgs - _args348.Req = req - var _result350 IClientRPCServiceDropSchemaTemplateResult +// - Info +func (p *IClientRPCServiceClient) Handshake(ctx context.Context, info *TSyncIdentityInfo) (_r *common.TSStatus, _err error) { + var _args348 IClientRPCServiceHandshakeArgs + _args348.Info = info + var _result350 IClientRPCServiceHandshakeResult var _meta349 thrift.ResponseMeta - _meta349, _err = p.Client_().Call(ctx, "dropSchemaTemplate", &_args348, &_result350) + _meta349, _err = p.Client_().Call(ctx, "handshake", &_args348, &_result350) p.SetLastResponseMeta_(_meta349) if _err != nil { return @@ -18112,13 +18808,13 @@ } // Parameters: -// - Req -func (p *IClientRPCServiceClient) CreateTimeseriesUsingSchemaTemplate(ctx context.Context, req *TCreateTimeseriesUsingSchemaTemplateReq) (_r *common.TSStatus, _err error) { - var _args351 IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs - _args351.Req = req - var _result353 IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult +// - Buff +func (p *IClientRPCServiceClient) SendPipeData(ctx context.Context, buff []byte) (_r *common.TSStatus, _err error) { + var _args351 IClientRPCServiceSendPipeDataArgs + _args351.Buff = buff + var _result353 IClientRPCServiceSendPipeDataResult var _meta352 thrift.ResponseMeta - _meta352, _err = p.Client_().Call(ctx, "createTimeseriesUsingSchemaTemplate", &_args351, &_result353) + _meta352, _err = p.Client_().Call(ctx, "sendPipeData", &_args351, &_result353) p.SetLastResponseMeta_(_meta352) if _err != nil { return @@ -18127,13 +18823,15 @@ } // Parameters: -// - Info -func (p *IClientRPCServiceClient) Handshake(ctx context.Context, info *TSyncIdentityInfo) (_r *common.TSStatus, _err error) { - var _args354 IClientRPCServiceHandshakeArgs - _args354.Info = info - var _result356 IClientRPCServiceHandshakeResult +// - MetaInfo +// - Buff +func (p *IClientRPCServiceClient) SendFile(ctx context.Context, metaInfo *TSyncTransportMetaInfo, buff []byte) (_r *common.TSStatus, _err error) { + var _args354 IClientRPCServiceSendFileArgs + _args354.MetaInfo = metaInfo + _args354.Buff = buff + var _result356 IClientRPCServiceSendFileResult var _meta355 thrift.ResponseMeta - _meta355, _err = p.Client_().Call(ctx, "handshake", &_args354, &_result356) + _meta355, _err = p.Client_().Call(ctx, "sendFile", &_args354, &_result356) p.SetLastResponseMeta_(_meta355) if _err != nil { return @@ -18142,13 +18840,13 @@ } // Parameters: -// - Buff -func (p *IClientRPCServiceClient) SendPipeData(ctx context.Context, buff []byte) (_r *common.TSStatus, _err error) { - var _args357 IClientRPCServiceSendPipeDataArgs - _args357.Buff = buff - var _result359 IClientRPCServiceSendPipeDataResult +// - Req +func (p *IClientRPCServiceClient) PipeTransfer(ctx context.Context, req *TPipeTransferReq) (_r *TPipeTransferResp, _err error) { + var _args357 IClientRPCServicePipeTransferArgs + _args357.Req = req + var _result359 IClientRPCServicePipeTransferResult var _meta358 thrift.ResponseMeta - _meta358, _err = p.Client_().Call(ctx, "sendPipeData", &_args357, &_result359) + _meta358, _err = p.Client_().Call(ctx, "pipeTransfer", &_args357, &_result359) p.SetLastResponseMeta_(_meta358) if _err != nil { return @@ -18156,16 +18854,11 @@ return _result359.GetSuccess(), nil } -// Parameters: -// - MetaInfo -// - Buff -func (p *IClientRPCServiceClient) SendFile(ctx context.Context, metaInfo *TSyncTransportMetaInfo, buff []byte) (_r *common.TSStatus, _err error) { - var _args360 IClientRPCServiceSendFileArgs - _args360.MetaInfo = metaInfo - _args360.Buff = buff - var _result362 IClientRPCServiceSendFileResult +func (p *IClientRPCServiceClient) GetBackupConfiguration(ctx context.Context) (_r *TSBackupConfigurationResp, _err error) { + var _args360 IClientRPCServiceGetBackupConfigurationArgs + var _result362 IClientRPCServiceGetBackupConfigurationResult var _meta361 thrift.ResponseMeta - _meta361, _err = p.Client_().Call(ctx, "sendFile", &_args360, &_result362) + _meta361, _err = p.Client_().Call(ctx, "getBackupConfiguration", &_args360, &_result362) p.SetLastResponseMeta_(_meta361) if _err != nil { return @@ -18173,11 +18866,11 @@ return _result362.GetSuccess(), nil } -func (p *IClientRPCServiceClient) GetBackupConfiguration(ctx context.Context) (_r *TSBackupConfigurationResp, _err error) { - var _args363 IClientRPCServiceGetBackupConfigurationArgs - var _result365 IClientRPCServiceGetBackupConfigurationResult +func (p *IClientRPCServiceClient) FetchAllConnectionsInfo(ctx context.Context) (_r *TSConnectionInfoResp, _err error) { + var _args363 IClientRPCServiceFetchAllConnectionsInfoArgs + var _result365 IClientRPCServiceFetchAllConnectionsInfoResult var _meta364 thrift.ResponseMeta - _meta364, _err = p.Client_().Call(ctx, "getBackupConfiguration", &_args363, &_result365) + _meta364, _err = p.Client_().Call(ctx, "fetchAllConnectionsInfo", &_args363, &_result365) p.SetLastResponseMeta_(_meta364) if _err != nil { return @@ -18185,18 +18878,6 @@ return _result365.GetSuccess(), nil } -func (p *IClientRPCServiceClient) FetchAllConnectionsInfo(ctx context.Context) (_r *TSConnectionInfoResp, _err error) { - var _args366 IClientRPCServiceFetchAllConnectionsInfoArgs - var _result368 IClientRPCServiceFetchAllConnectionsInfoResult - var _meta367 thrift.ResponseMeta - _meta367, _err = p.Client_().Call(ctx, "fetchAllConnectionsInfo", &_args366, &_result368) - p.SetLastResponseMeta_(_meta367) - if _err != nil { - return - } - return _result368.GetSuccess(), nil -} - type IClientRPCServiceProcessor struct { processorMap map[string]thrift.TProcessorFunction handler IClientRPCService @@ -18217,68 +18898,69 @@ func NewIClientRPCServiceProcessor(handler IClientRPCService) *IClientRPCServiceProcessor { - self369 := &IClientRPCServiceProcessor{handler:handler, processorMap:make(map[string]thrift.TProcessorFunction)} - self369.processorMap["executeQueryStatementV2"] = &iClientRPCServiceProcessorExecuteQueryStatementV2{handler:handler} - self369.processorMap["executeUpdateStatementV2"] = &iClientRPCServiceProcessorExecuteUpdateStatementV2{handler:handler} - self369.processorMap["executeStatementV2"] = &iClientRPCServiceProcessorExecuteStatementV2{handler:handler} - self369.processorMap["executeRawDataQueryV2"] = &iClientRPCServiceProcessorExecuteRawDataQueryV2{handler:handler} - self369.processorMap["executeLastDataQueryV2"] = &iClientRPCServiceProcessorExecuteLastDataQueryV2{handler:handler} - self369.processorMap["executeAggregationQueryV2"] = &iClientRPCServiceProcessorExecuteAggregationQueryV2{handler:handler} - self369.processorMap["fetchResultsV2"] = &iClientRPCServiceProcessorFetchResultsV2{handler:handler} - self369.processorMap["openSession"] = &iClientRPCServiceProcessorOpenSession{handler:handler} - self369.processorMap["closeSession"] = &iClientRPCServiceProcessorCloseSession{handler:handler} - self369.processorMap["executeStatement"] = &iClientRPCServiceProcessorExecuteStatement{handler:handler} - self369.processorMap["executeBatchStatement"] = &iClientRPCServiceProcessorExecuteBatchStatement{handler:handler} - self369.processorMap["executeQueryStatement"] = &iClientRPCServiceProcessorExecuteQueryStatement{handler:handler} - self369.processorMap["executeUpdateStatement"] = &iClientRPCServiceProcessorExecuteUpdateStatement{handler:handler} - self369.processorMap["fetchResults"] = &iClientRPCServiceProcessorFetchResults{handler:handler} - self369.processorMap["fetchMetadata"] = &iClientRPCServiceProcessorFetchMetadata{handler:handler} - self369.processorMap["cancelOperation"] = &iClientRPCServiceProcessorCancelOperation{handler:handler} - self369.processorMap["closeOperation"] = &iClientRPCServiceProcessorCloseOperation{handler:handler} - self369.processorMap["getTimeZone"] = &iClientRPCServiceProcessorGetTimeZone{handler:handler} - self369.processorMap["setTimeZone"] = &iClientRPCServiceProcessorSetTimeZone{handler:handler} - self369.processorMap["getProperties"] = &iClientRPCServiceProcessorGetProperties{handler:handler} - self369.processorMap["setStorageGroup"] = &iClientRPCServiceProcessorSetStorageGroup{handler:handler} - self369.processorMap["createTimeseries"] = &iClientRPCServiceProcessorCreateTimeseries{handler:handler} - self369.processorMap["createAlignedTimeseries"] = &iClientRPCServiceProcessorCreateAlignedTimeseries{handler:handler} - self369.processorMap["createMultiTimeseries"] = &iClientRPCServiceProcessorCreateMultiTimeseries{handler:handler} - self369.processorMap["deleteTimeseries"] = &iClientRPCServiceProcessorDeleteTimeseries{handler:handler} - self369.processorMap["deleteStorageGroups"] = &iClientRPCServiceProcessorDeleteStorageGroups{handler:handler} - self369.processorMap["insertRecord"] = &iClientRPCServiceProcessorInsertRecord{handler:handler} - self369.processorMap["insertStringRecord"] = &iClientRPCServiceProcessorInsertStringRecord{handler:handler} - self369.processorMap["insertTablet"] = &iClientRPCServiceProcessorInsertTablet{handler:handler} - self369.processorMap["insertTablets"] = &iClientRPCServiceProcessorInsertTablets{handler:handler} - self369.processorMap["insertRecords"] = &iClientRPCServiceProcessorInsertRecords{handler:handler} - self369.processorMap["fastInsertRecords"] = &iClientRPCServiceProcessorFastInsertRecords{handler:handler} - self369.processorMap["insertRecordsOfOneDevice"] = &iClientRPCServiceProcessorInsertRecordsOfOneDevice{handler:handler} - self369.processorMap["insertStringRecordsOfOneDevice"] = &iClientRPCServiceProcessorInsertStringRecordsOfOneDevice{handler:handler} - self369.processorMap["insertStringRecords"] = &iClientRPCServiceProcessorInsertStringRecords{handler:handler} - self369.processorMap["testInsertTablet"] = &iClientRPCServiceProcessorTestInsertTablet{handler:handler} - self369.processorMap["testInsertTablets"] = &iClientRPCServiceProcessorTestInsertTablets{handler:handler} - self369.processorMap["testInsertRecord"] = &iClientRPCServiceProcessorTestInsertRecord{handler:handler} - self369.processorMap["testInsertStringRecord"] = &iClientRPCServiceProcessorTestInsertStringRecord{handler:handler} - self369.processorMap["testInsertRecords"] = &iClientRPCServiceProcessorTestInsertRecords{handler:handler} - self369.processorMap["testInsertRecordsOfOneDevice"] = &iClientRPCServiceProcessorTestInsertRecordsOfOneDevice{handler:handler} - self369.processorMap["testInsertStringRecords"] = &iClientRPCServiceProcessorTestInsertStringRecords{handler:handler} - self369.processorMap["deleteData"] = &iClientRPCServiceProcessorDeleteData{handler:handler} - self369.processorMap["executeRawDataQuery"] = &iClientRPCServiceProcessorExecuteRawDataQuery{handler:handler} - self369.processorMap["executeLastDataQuery"] = &iClientRPCServiceProcessorExecuteLastDataQuery{handler:handler} - self369.processorMap["executeAggregationQuery"] = &iClientRPCServiceProcessorExecuteAggregationQuery{handler:handler} - self369.processorMap["requestStatementId"] = &iClientRPCServiceProcessorRequestStatementId{handler:handler} - self369.processorMap["createSchemaTemplate"] = &iClientRPCServiceProcessorCreateSchemaTemplate{handler:handler} - self369.processorMap["appendSchemaTemplate"] = &iClientRPCServiceProcessorAppendSchemaTemplate{handler:handler} - self369.processorMap["pruneSchemaTemplate"] = &iClientRPCServiceProcessorPruneSchemaTemplate{handler:handler} - self369.processorMap["querySchemaTemplate"] = &iClientRPCServiceProcessorQuerySchemaTemplate{handler:handler} - self369.processorMap["setSchemaTemplate"] = &iClientRPCServiceProcessorSetSchemaTemplate{handler:handler} - self369.processorMap["unsetSchemaTemplate"] = &iClientRPCServiceProcessorUnsetSchemaTemplate{handler:handler} - self369.processorMap["dropSchemaTemplate"] = &iClientRPCServiceProcessorDropSchemaTemplate{handler:handler} - self369.processorMap["createTimeseriesUsingSchemaTemplate"] = &iClientRPCServiceProcessorCreateTimeseriesUsingSchemaTemplate{handler:handler} - self369.processorMap["handshake"] = &iClientRPCServiceProcessorHandshake{handler:handler} - self369.processorMap["sendPipeData"] = &iClientRPCServiceProcessorSendPipeData{handler:handler} - self369.processorMap["sendFile"] = &iClientRPCServiceProcessorSendFile{handler:handler} - self369.processorMap["getBackupConfiguration"] = &iClientRPCServiceProcessorGetBackupConfiguration{handler:handler} - self369.processorMap["fetchAllConnectionsInfo"] = &iClientRPCServiceProcessorFetchAllConnectionsInfo{handler:handler} -return self369 + self366 := &IClientRPCServiceProcessor{handler:handler, processorMap:make(map[string]thrift.TProcessorFunction)} + self366.processorMap["executeQueryStatementV2"] = &iClientRPCServiceProcessorExecuteQueryStatementV2{handler:handler} + self366.processorMap["executeUpdateStatementV2"] = &iClientRPCServiceProcessorExecuteUpdateStatementV2{handler:handler} + self366.processorMap["executeStatementV2"] = &iClientRPCServiceProcessorExecuteStatementV2{handler:handler} + self366.processorMap["executeRawDataQueryV2"] = &iClientRPCServiceProcessorExecuteRawDataQueryV2{handler:handler} + self366.processorMap["executeLastDataQueryV2"] = &iClientRPCServiceProcessorExecuteLastDataQueryV2{handler:handler} + self366.processorMap["executeAggregationQueryV2"] = &iClientRPCServiceProcessorExecuteAggregationQueryV2{handler:handler} + self366.processorMap["fetchResultsV2"] = &iClientRPCServiceProcessorFetchResultsV2{handler:handler} + self366.processorMap["openSession"] = &iClientRPCServiceProcessorOpenSession{handler:handler} + self366.processorMap["closeSession"] = &iClientRPCServiceProcessorCloseSession{handler:handler} + self366.processorMap["executeStatement"] = &iClientRPCServiceProcessorExecuteStatement{handler:handler} + self366.processorMap["executeBatchStatement"] = &iClientRPCServiceProcessorExecuteBatchStatement{handler:handler} + self366.processorMap["executeQueryStatement"] = &iClientRPCServiceProcessorExecuteQueryStatement{handler:handler} + self366.processorMap["executeUpdateStatement"] = &iClientRPCServiceProcessorExecuteUpdateStatement{handler:handler} + self366.processorMap["fetchResults"] = &iClientRPCServiceProcessorFetchResults{handler:handler} + self366.processorMap["fetchMetadata"] = &iClientRPCServiceProcessorFetchMetadata{handler:handler} + self366.processorMap["cancelOperation"] = &iClientRPCServiceProcessorCancelOperation{handler:handler} + self366.processorMap["closeOperation"] = &iClientRPCServiceProcessorCloseOperation{handler:handler} + self366.processorMap["getTimeZone"] = &iClientRPCServiceProcessorGetTimeZone{handler:handler} + self366.processorMap["setTimeZone"] = &iClientRPCServiceProcessorSetTimeZone{handler:handler} + self366.processorMap["getProperties"] = &iClientRPCServiceProcessorGetProperties{handler:handler} + self366.processorMap["setStorageGroup"] = &iClientRPCServiceProcessorSetStorageGroup{handler:handler} + self366.processorMap["createTimeseries"] = &iClientRPCServiceProcessorCreateTimeseries{handler:handler} + self366.processorMap["createAlignedTimeseries"] = &iClientRPCServiceProcessorCreateAlignedTimeseries{handler:handler} + self366.processorMap["createMultiTimeseries"] = &iClientRPCServiceProcessorCreateMultiTimeseries{handler:handler} + self366.processorMap["deleteTimeseries"] = &iClientRPCServiceProcessorDeleteTimeseries{handler:handler} + self366.processorMap["deleteStorageGroups"] = &iClientRPCServiceProcessorDeleteStorageGroups{handler:handler} + self366.processorMap["insertRecord"] = &iClientRPCServiceProcessorInsertRecord{handler:handler} + self366.processorMap["insertStringRecord"] = &iClientRPCServiceProcessorInsertStringRecord{handler:handler} + self366.processorMap["insertTablet"] = &iClientRPCServiceProcessorInsertTablet{handler:handler} + self366.processorMap["insertTablets"] = &iClientRPCServiceProcessorInsertTablets{handler:handler} + self366.processorMap["insertRecords"] = &iClientRPCServiceProcessorInsertRecords{handler:handler} + self366.processorMap["insertRecordsOfOneDevice"] = &iClientRPCServiceProcessorInsertRecordsOfOneDevice{handler:handler} + self366.processorMap["insertStringRecordsOfOneDevice"] = &iClientRPCServiceProcessorInsertStringRecordsOfOneDevice{handler:handler} + self366.processorMap["insertStringRecords"] = &iClientRPCServiceProcessorInsertStringRecords{handler:handler} + self366.processorMap["testInsertTablet"] = &iClientRPCServiceProcessorTestInsertTablet{handler:handler} + self366.processorMap["testInsertTablets"] = &iClientRPCServiceProcessorTestInsertTablets{handler:handler} + self366.processorMap["testInsertRecord"] = &iClientRPCServiceProcessorTestInsertRecord{handler:handler} + self366.processorMap["testInsertStringRecord"] = &iClientRPCServiceProcessorTestInsertStringRecord{handler:handler} + self366.processorMap["testInsertRecords"] = &iClientRPCServiceProcessorTestInsertRecords{handler:handler} + self366.processorMap["testInsertRecordsOfOneDevice"] = &iClientRPCServiceProcessorTestInsertRecordsOfOneDevice{handler:handler} + self366.processorMap["testInsertStringRecords"] = &iClientRPCServiceProcessorTestInsertStringRecords{handler:handler} + self366.processorMap["deleteData"] = &iClientRPCServiceProcessorDeleteData{handler:handler} + self366.processorMap["executeRawDataQuery"] = &iClientRPCServiceProcessorExecuteRawDataQuery{handler:handler} + self366.processorMap["executeLastDataQuery"] = &iClientRPCServiceProcessorExecuteLastDataQuery{handler:handler} + self366.processorMap["executeAggregationQuery"] = &iClientRPCServiceProcessorExecuteAggregationQuery{handler:handler} + self366.processorMap["executeGroupByQueryIntervalQuery"] = &iClientRPCServiceProcessorExecuteGroupByQueryIntervalQuery{handler:handler} + self366.processorMap["requestStatementId"] = &iClientRPCServiceProcessorRequestStatementId{handler:handler} + self366.processorMap["createSchemaTemplate"] = &iClientRPCServiceProcessorCreateSchemaTemplate{handler:handler} + self366.processorMap["appendSchemaTemplate"] = &iClientRPCServiceProcessorAppendSchemaTemplate{handler:handler} + self366.processorMap["pruneSchemaTemplate"] = &iClientRPCServiceProcessorPruneSchemaTemplate{handler:handler} + self366.processorMap["querySchemaTemplate"] = &iClientRPCServiceProcessorQuerySchemaTemplate{handler:handler} + self366.processorMap["setSchemaTemplate"] = &iClientRPCServiceProcessorSetSchemaTemplate{handler:handler} + self366.processorMap["unsetSchemaTemplate"] = &iClientRPCServiceProcessorUnsetSchemaTemplate{handler:handler} + self366.processorMap["dropSchemaTemplate"] = &iClientRPCServiceProcessorDropSchemaTemplate{handler:handler} + self366.processorMap["createTimeseriesUsingSchemaTemplate"] = &iClientRPCServiceProcessorCreateTimeseriesUsingSchemaTemplate{handler:handler} + self366.processorMap["handshake"] = &iClientRPCServiceProcessorHandshake{handler:handler} + self366.processorMap["sendPipeData"] = &iClientRPCServiceProcessorSendPipeData{handler:handler} + self366.processorMap["sendFile"] = &iClientRPCServiceProcessorSendFile{handler:handler} + self366.processorMap["pipeTransfer"] = &iClientRPCServiceProcessorPipeTransfer{handler:handler} + self366.processorMap["getBackupConfiguration"] = &iClientRPCServiceProcessorGetBackupConfiguration{handler:handler} + self366.processorMap["fetchAllConnectionsInfo"] = &iClientRPCServiceProcessorFetchAllConnectionsInfo{handler:handler} +return self366 } func (p *IClientRPCServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) { @@ -18289,12 +18971,12 @@ } iprot.Skip(ctx, thrift.STRUCT) iprot.ReadMessageEnd(ctx) - x370 := thrift.NewTApplicationException(thrift.UNKNOWN_METHOD, "Unknown function " + name) + x367 := thrift.NewTApplicationException(thrift.UNKNOWN_METHOD, "Unknown function " + name) oprot.WriteMessageBegin(ctx, name, thrift.EXCEPTION, seqId) - x370.Write(ctx, oprot) + x367.Write(ctx, oprot) oprot.WriteMessageEnd(ctx) oprot.Flush(ctx) - return false, x370 + return false, x367 } @@ -20747,85 +21429,6 @@ return true, err } -type iClientRPCServiceProcessorFastInsertRecords struct { - handler IClientRPCService -} - -func (p *iClientRPCServiceProcessorFastInsertRecords) Process(ctx context.Context, seqId int32, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) { - args := IClientRPCServiceFastInsertRecordsArgs{} - var err2 error - if err2 = args.Read(ctx, iprot); err2 != nil { - iprot.ReadMessageEnd(ctx) - x := thrift.NewTApplicationException(thrift.PROTOCOL_ERROR, err2.Error()) - oprot.WriteMessageBegin(ctx, "fastInsertRecords", thrift.EXCEPTION, seqId) - x.Write(ctx, oprot) - oprot.WriteMessageEnd(ctx) - oprot.Flush(ctx) - return false, thrift.WrapTException(err2) - } - iprot.ReadMessageEnd(ctx) - - tickerCancel := func() {} - // Start a goroutine to do server side connectivity check. - if thrift.ServerConnectivityCheckInterval > 0 { - var cancel context.CancelFunc - ctx, cancel = context.WithCancel(ctx) - defer cancel() - var tickerCtx context.Context - tickerCtx, tickerCancel = context.WithCancel(context.Background()) - defer tickerCancel() - go func(ctx context.Context, cancel context.CancelFunc) { - ticker := time.NewTicker(thrift.ServerConnectivityCheckInterval) - defer ticker.Stop() - for { - select { - case <-ctx.Done(): - return - case <-ticker.C: - if !iprot.Transport().IsOpen() { - cancel() - return - } - } - } - }(tickerCtx, cancel) - } - - result := IClientRPCServiceFastInsertRecordsResult{} - var retval *common.TSStatus - if retval, err2 = p.handler.FastInsertRecords(ctx, args.Req); err2 != nil { - tickerCancel() - if err2 == thrift.ErrAbandonRequest { - return false, thrift.WrapTException(err2) - } - x := thrift.NewTApplicationException(thrift.INTERNAL_ERROR, "Internal error processing fastInsertRecords: " + err2.Error()) - oprot.WriteMessageBegin(ctx, "fastInsertRecords", thrift.EXCEPTION, seqId) - x.Write(ctx, oprot) - oprot.WriteMessageEnd(ctx) - oprot.Flush(ctx) - return true, thrift.WrapTException(err2) - } else { - result.Success = retval - } - tickerCancel() - if err2 = oprot.WriteMessageBegin(ctx, "fastInsertRecords", thrift.REPLY, seqId); err2 != nil { - err = thrift.WrapTException(err2) - } - if err2 = result.Write(ctx, oprot); err == nil && err2 != nil { - err = thrift.WrapTException(err2) - } - if err2 = oprot.WriteMessageEnd(ctx); err == nil && err2 != nil { - err = thrift.WrapTException(err2) - } - if err2 = oprot.Flush(ctx); err == nil && err2 != nil { - err = thrift.WrapTException(err2) - } - if err != nil { - return - } - return true, err -} - type iClientRPCServiceProcessorInsertRecordsOfOneDevice struct { handler IClientRPCService } @@ -21932,6 +22535,85 @@ return true, err } +type iClientRPCServiceProcessorExecuteGroupByQueryIntervalQuery struct { + handler IClientRPCService +} + +func (p *iClientRPCServiceProcessorExecuteGroupByQueryIntervalQuery) Process(ctx context.Context, seqId int32, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) { + args := IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs{} + var err2 error + if err2 = args.Read(ctx, iprot); err2 != nil { + iprot.ReadMessageEnd(ctx) + x := thrift.NewTApplicationException(thrift.PROTOCOL_ERROR, err2.Error()) + oprot.WriteMessageBegin(ctx, "executeGroupByQueryIntervalQuery", thrift.EXCEPTION, seqId) + x.Write(ctx, oprot) + oprot.WriteMessageEnd(ctx) + oprot.Flush(ctx) + return false, thrift.WrapTException(err2) + } + iprot.ReadMessageEnd(ctx) + + tickerCancel := func() {} + // Start a goroutine to do server side connectivity check. + if thrift.ServerConnectivityCheckInterval > 0 { + var cancel context.CancelFunc + ctx, cancel = context.WithCancel(ctx) + defer cancel() + var tickerCtx context.Context + tickerCtx, tickerCancel = context.WithCancel(context.Background()) + defer tickerCancel() + go func(ctx context.Context, cancel context.CancelFunc) { + ticker := time.NewTicker(thrift.ServerConnectivityCheckInterval) + defer ticker.Stop() + for { + select { + case <-ctx.Done(): + return + case <-ticker.C: + if !iprot.Transport().IsOpen() { + cancel() + return + } + } + } + }(tickerCtx, cancel) + } + + result := IClientRPCServiceExecuteGroupByQueryIntervalQueryResult{} + var retval *TSExecuteStatementResp + if retval, err2 = p.handler.ExecuteGroupByQueryIntervalQuery(ctx, args.Req); err2 != nil { + tickerCancel() + if err2 == thrift.ErrAbandonRequest { + return false, thrift.WrapTException(err2) + } + x := thrift.NewTApplicationException(thrift.INTERNAL_ERROR, "Internal error processing executeGroupByQueryIntervalQuery: " + err2.Error()) + oprot.WriteMessageBegin(ctx, "executeGroupByQueryIntervalQuery", thrift.EXCEPTION, seqId) + x.Write(ctx, oprot) + oprot.WriteMessageEnd(ctx) + oprot.Flush(ctx) + return true, thrift.WrapTException(err2) + } else { + result.Success = retval + } + tickerCancel() + if err2 = oprot.WriteMessageBegin(ctx, "executeGroupByQueryIntervalQuery", thrift.REPLY, seqId); err2 != nil { + err = thrift.WrapTException(err2) + } + if err2 = result.Write(ctx, oprot); err == nil && err2 != nil { + err = thrift.WrapTException(err2) + } + if err2 = oprot.WriteMessageEnd(ctx); err == nil && err2 != nil { + err = thrift.WrapTException(err2) + } + if err2 = oprot.Flush(ctx); err == nil && err2 != nil { + err = thrift.WrapTException(err2) + } + if err != nil { + return + } + return true, err +} + type iClientRPCServiceProcessorRequestStatementId struct { handler IClientRPCService } @@ -22880,6 +23562,85 @@ return true, err } +type iClientRPCServiceProcessorPipeTransfer struct { + handler IClientRPCService +} + +func (p *iClientRPCServiceProcessorPipeTransfer) Process(ctx context.Context, seqId int32, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) { + args := IClientRPCServicePipeTransferArgs{} + var err2 error + if err2 = args.Read(ctx, iprot); err2 != nil { + iprot.ReadMessageEnd(ctx) + x := thrift.NewTApplicationException(thrift.PROTOCOL_ERROR, err2.Error()) + oprot.WriteMessageBegin(ctx, "pipeTransfer", thrift.EXCEPTION, seqId) + x.Write(ctx, oprot) + oprot.WriteMessageEnd(ctx) + oprot.Flush(ctx) + return false, thrift.WrapTException(err2) + } + iprot.ReadMessageEnd(ctx) + + tickerCancel := func() {} + // Start a goroutine to do server side connectivity check. + if thrift.ServerConnectivityCheckInterval > 0 { + var cancel context.CancelFunc + ctx, cancel = context.WithCancel(ctx) + defer cancel() + var tickerCtx context.Context + tickerCtx, tickerCancel = context.WithCancel(context.Background()) + defer tickerCancel() + go func(ctx context.Context, cancel context.CancelFunc) { + ticker := time.NewTicker(thrift.ServerConnectivityCheckInterval) + defer ticker.Stop() + for { + select { + case <-ctx.Done(): + return + case <-ticker.C: + if !iprot.Transport().IsOpen() { + cancel() + return + } + } + } + }(tickerCtx, cancel) + } + + result := IClientRPCServicePipeTransferResult{} + var retval *TPipeTransferResp + if retval, err2 = p.handler.PipeTransfer(ctx, args.Req); err2 != nil { + tickerCancel() + if err2 == thrift.ErrAbandonRequest { + return false, thrift.WrapTException(err2) + } + x := thrift.NewTApplicationException(thrift.INTERNAL_ERROR, "Internal error processing pipeTransfer: " + err2.Error()) + oprot.WriteMessageBegin(ctx, "pipeTransfer", thrift.EXCEPTION, seqId) + x.Write(ctx, oprot) + oprot.WriteMessageEnd(ctx) + oprot.Flush(ctx) + return true, thrift.WrapTException(err2) + } else { + result.Success = retval + } + tickerCancel() + if err2 = oprot.WriteMessageBegin(ctx, "pipeTransfer", thrift.REPLY, seqId); err2 != nil { + err = thrift.WrapTException(err2) + } + if err2 = result.Write(ctx, oprot); err == nil && err2 != nil { + err = thrift.WrapTException(err2) + } + if err2 = oprot.WriteMessageEnd(ctx); err == nil && err2 != nil { + err = thrift.WrapTException(err2) + } + if err2 = oprot.Flush(ctx); err == nil && err2 != nil { + err = thrift.WrapTException(err2) + } + if err != nil { + return + } + return true, err +} + type iClientRPCServiceProcessorGetBackupConfiguration struct { handler IClientRPCService } @@ -27857,13 +28618,13 @@ tSlice := make([]string, 0, size) p.Path = tSlice for i := 0; i < size; i ++ { -var _elem371 string +var _elem368 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem371 = v + _elem368 = v } - p.Path = append(p.Path, _elem371) + p.Path = append(p.Path, _elem368) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -28105,13 +28866,13 @@ tSlice := make([]string, 0, size) p.StorageGroup = tSlice for i := 0; i < size; i ++ { -var _elem372 string +var _elem369 string if v, err := iprot.ReadString(ctx); err != nil { return thrift.PrependError("error reading field 0: ", err) } else { - _elem372 = v + _elem369 = v } - p.StorageGroup = append(p.StorageGroup, _elem372) + p.StorageGroup = append(p.StorageGroup, _elem369) } if err := iprot.ReadListEnd(ctx); err != nil { return thrift.PrependError("error reading list end: ", err) @@ -29260,204 +30021,6 @@ // Attributes: // - Req -type IClientRPCServiceFastInsertRecordsArgs struct { - Req *TSFastInsertRecordsReq `thrift:"req,1" db:"req" json:"req"` -} - -func NewIClientRPCServiceFastInsertRecordsArgs() *IClientRPCServiceFastInsertRecordsArgs { - return &IClientRPCServiceFastInsertRecordsArgs{} -} - -var IClientRPCServiceFastInsertRecordsArgs_Req_DEFAULT *TSFastInsertRecordsReq -func (p *IClientRPCServiceFastInsertRecordsArgs) GetReq() *TSFastInsertRecordsReq { - if !p.IsSetReq() { - return IClientRPCServiceFastInsertRecordsArgs_Req_DEFAULT - } -return p.Req -} -func (p *IClientRPCServiceFastInsertRecordsArgs) IsSetReq() bool { - return p.Req != nil -} - -func (p *IClientRPCServiceFastInsertRecordsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { - if _, err := iprot.ReadStructBegin(ctx); err != nil { - return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) - } - - - for { - _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) - if err != nil { - return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) - } - if fieldTypeId == thrift.STOP { break; } - switch fieldId { - case 1: - if fieldTypeId == thrift.STRUCT { - if err := p.ReadField1(ctx, iprot); err != nil { - return err - } - } else { - if err := iprot.Skip(ctx, fieldTypeId); err != nil { - return err - } - } - default: - if err := iprot.Skip(ctx, fieldTypeId); err != nil { - return err - } - } - if err := iprot.ReadFieldEnd(ctx); err != nil { - return err - } - } - if err := iprot.ReadStructEnd(ctx); err != nil { - return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) - } - return nil -} - -func (p *IClientRPCServiceFastInsertRecordsArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { - p.Req = &TSFastInsertRecordsReq{} - if err := p.Req.Read(ctx, iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Req), err) - } - return nil -} - -func (p *IClientRPCServiceFastInsertRecordsArgs) Write(ctx context.Context, oprot thrift.TProtocol) error { - if err := oprot.WriteStructBegin(ctx, "fastInsertRecords_args"); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } - if p != nil { - if err := p.writeField1(ctx, oprot); err != nil { return err } - } - if err := oprot.WriteFieldStop(ctx); err != nil { - return thrift.PrependError("write field stop error: ", err) } - if err := oprot.WriteStructEnd(ctx); err != nil { - return thrift.PrependError("write struct stop error: ", err) } - return nil -} - -func (p *IClientRPCServiceFastInsertRecordsArgs) writeField1(ctx context.Context, oprot thrift.TProtocol) (err error) { - if err := oprot.WriteFieldBegin(ctx, "req", thrift.STRUCT, 1); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:req: ", p), err) } - if err := p.Req.Write(ctx, oprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Req), err) - } - if err := oprot.WriteFieldEnd(ctx); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field end error 1:req: ", p), err) } - return err -} - -func (p *IClientRPCServiceFastInsertRecordsArgs) String() string { - if p == nil { - return "<nil>" - } - return fmt.Sprintf("IClientRPCServiceFastInsertRecordsArgs(%+v)", *p) -} - -// Attributes: -// - Success -type IClientRPCServiceFastInsertRecordsResult struct { - Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"` -} - -func NewIClientRPCServiceFastInsertRecordsResult() *IClientRPCServiceFastInsertRecordsResult { - return &IClientRPCServiceFastInsertRecordsResult{} -} - -var IClientRPCServiceFastInsertRecordsResult_Success_DEFAULT *common.TSStatus -func (p *IClientRPCServiceFastInsertRecordsResult) GetSuccess() *common.TSStatus { - if !p.IsSetSuccess() { - return IClientRPCServiceFastInsertRecordsResult_Success_DEFAULT - } -return p.Success -} -func (p *IClientRPCServiceFastInsertRecordsResult) IsSetSuccess() bool { - return p.Success != nil -} - -func (p *IClientRPCServiceFastInsertRecordsResult) Read(ctx context.Context, iprot thrift.TProtocol) error { - if _, err := iprot.ReadStructBegin(ctx); err != nil { - return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) - } - - - for { - _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) - if err != nil { - return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) - } - if fieldTypeId == thrift.STOP { break; } - switch fieldId { - case 0: - if fieldTypeId == thrift.STRUCT { - if err := p.ReadField0(ctx, iprot); err != nil { - return err - } - } else { - if err := iprot.Skip(ctx, fieldTypeId); err != nil { - return err - } - } - default: - if err := iprot.Skip(ctx, fieldTypeId); err != nil { - return err - } - } - if err := iprot.ReadFieldEnd(ctx); err != nil { - return err - } - } - if err := iprot.ReadStructEnd(ctx); err != nil { - return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) - } - return nil -} - -func (p *IClientRPCServiceFastInsertRecordsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error { - p.Success = &common.TSStatus{} - if err := p.Success.Read(ctx, iprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Success), err) - } - return nil -} - -func (p *IClientRPCServiceFastInsertRecordsResult) Write(ctx context.Context, oprot thrift.TProtocol) error { - if err := oprot.WriteStructBegin(ctx, "fastInsertRecords_result"); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } - if p != nil { - if err := p.writeField0(ctx, oprot); err != nil { return err } - } - if err := oprot.WriteFieldStop(ctx); err != nil { - return thrift.PrependError("write field stop error: ", err) } - if err := oprot.WriteStructEnd(ctx); err != nil { - return thrift.PrependError("write struct stop error: ", err) } - return nil -} - -func (p *IClientRPCServiceFastInsertRecordsResult) writeField0(ctx context.Context, oprot thrift.TProtocol) (err error) { - if p.IsSetSuccess() { - if err := oprot.WriteFieldBegin(ctx, "success", thrift.STRUCT, 0); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field begin error 0:success: ", p), err) } - if err := p.Success.Write(ctx, oprot); err != nil { - return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Success), err) - } - if err := oprot.WriteFieldEnd(ctx); err != nil { - return thrift.PrependError(fmt.Sprintf("%T write field end error 0:success: ", p), err) } - } - return err -} - -func (p *IClientRPCServiceFastInsertRecordsResult) String() string { - if p == nil { - return "<nil>" - } - return fmt.Sprintf("IClientRPCServiceFastInsertRecordsResult(%+v)", *p) -} - -// Attributes: -// - Req type IClientRPCServiceInsertRecordsOfOneDeviceArgs struct { Req *TSInsertRecordsOfOneDeviceReq `thrift:"req,1" db:"req" json:"req"` } @@ -32229,6 +32792,204 @@ } // Attributes: +// - Req +type IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs struct { + Req *TSGroupByQueryIntervalReq `thrift:"req,1" db:"req" json:"req"` +} + +func NewIClientRPCServiceExecuteGroupByQueryIntervalQueryArgs() *IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs { + return &IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs{} +} + +var IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs_Req_DEFAULT *TSGroupByQueryIntervalReq +func (p *IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs) GetReq() *TSGroupByQueryIntervalReq { + if !p.IsSetReq() { + return IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs_Req_DEFAULT + } +return p.Req +} +func (p *IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs) IsSetReq() bool { + return p.Req != nil +} + +func (p *IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { + if _, err := iprot.ReadStructBegin(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) + } + + + for { + _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) + if err != nil { + return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) + } + if fieldTypeId == thrift.STOP { break; } + switch fieldId { + case 1: + if fieldTypeId == thrift.STRUCT { + if err := p.ReadField1(ctx, iprot); err != nil { + return err + } + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + default: + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + if err := iprot.ReadFieldEnd(ctx); err != nil { + return err + } + } + if err := iprot.ReadStructEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) + } + return nil +} + +func (p *IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error { + p.Req = &TSGroupByQueryIntervalReq{} + if err := p.Req.Read(ctx, iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Req), err) + } + return nil +} + +func (p *IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs) Write(ctx context.Context, oprot thrift.TProtocol) error { + if err := oprot.WriteStructBegin(ctx, "executeGroupByQueryIntervalQuery_args"); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } + if p != nil { + if err := p.writeField1(ctx, oprot); err != nil { return err } + } + if err := oprot.WriteFieldStop(ctx); err != nil { + return thrift.PrependError("write field stop error: ", err) } + if err := oprot.WriteStructEnd(ctx); err != nil { + return thrift.PrependError("write struct stop error: ", err) } + return nil +} + +func (p *IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs) writeField1(ctx context.Context, oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin(ctx, "req", thrift.STRUCT, 1); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 1:req: ", p), err) } + if err := p.Req.Write(ctx, oprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Req), err) + } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 1:req: ", p), err) } + return err +} + +func (p *IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs) String() string { + if p == nil { + return "<nil>" + } + return fmt.Sprintf("IClientRPCServiceExecuteGroupByQueryIntervalQueryArgs(%+v)", *p) +} + +// Attributes: +// - Success +type IClientRPCServiceExecuteGroupByQueryIntervalQueryResult struct { + Success *TSExecuteStatementResp `thrift:"success,0" db:"success" json:"success,omitempty"` +} + +func NewIClientRPCServiceExecuteGroupByQueryIntervalQueryResult() *IClientRPCServiceExecuteGroupByQueryIntervalQueryResult { + return &IClientRPCServiceExecuteGroupByQueryIntervalQueryResult{} +} + +var IClientRPCServiceExecuteGroupByQueryIntervalQueryResult_Success_DEFAULT *TSExecuteStatementResp +func (p *IClientRPCServiceExecuteGroupByQueryIntervalQueryResult) GetSuccess() *TSExecuteStatementResp { + if !p.IsSetSuccess() { + return IClientRPCServiceExecuteGroupByQueryIntervalQueryResult_Success_DEFAULT + } +return p.Success +} +func (p *IClientRPCServiceExecuteGroupByQueryIntervalQueryResult) IsSetSuccess() bool { + return p.Success != nil +} + +func (p *IClientRPCServiceExecuteGroupByQueryIntervalQueryResult) Read(ctx context.Context, iprot thrift.TProtocol) error { + if _, err := iprot.ReadStructBegin(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) + } + + + for { + _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) + if err != nil { + return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) + } + if fieldTypeId == thrift.STOP { break; } + switch fieldId { + case 0: + if fieldTypeId == thrift.STRUCT { + if err := p.ReadField0(ctx, iprot); err != nil { + return err + } + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + default: + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + if err := iprot.ReadFieldEnd(ctx); err != nil { + return err + } + } + if err := iprot.ReadStructEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) + } + return nil +} + +func (p *IClientRPCServiceExecuteGroupByQueryIntervalQueryResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error { + p.Success = &TSExecuteStatementResp{} + if err := p.Success.Read(ctx, iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Success), err) + } + return nil +} + +func (p *IClientRPCServiceExecuteGroupByQueryIntervalQueryResult) Write(ctx context.Context, oprot thrift.TProtocol) error { + if err := oprot.WriteStructBegin(ctx, "executeGroupByQueryIntervalQuery_result"); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } + if p != nil { + if err := p.writeField0(ctx, oprot); err != nil { return err } + } + if err := oprot.WriteFieldStop(ctx); err != nil { + return thrift.PrependError("write field stop error: ", err) } + if err := oprot.WriteStructEnd(ctx); err != nil { + return thrift.PrependError("write struct stop error: ", err) } + return nil +} + +func (p *IClientRPCServiceExecuteGroupByQueryIntervalQueryResult) writeField0(ctx context.Context, oprot thrift.TProtocol) (err error) { + if p.IsSetSuccess() { + if err := oprot.WriteFieldBegin(ctx, "success", thrift.STRUCT, 0); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 0:success: ", p), err) } + if err := p.Success.Write(ctx, oprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Success), err) + } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 0:success: ", p), err) } + } + return err +} + +func (p *IClientRPCServiceExecuteGroupByQueryIntervalQueryResult) String() string { + if p == nil { + return "<nil>" + } + return fmt.Sprintf("IClientRPCServiceExecuteGroupByQueryIntervalQueryResult(%+v)", *p) +} + +// Attributes: // - SessionId type IClientRPCServiceRequestStatementIdArgs struct { SessionId int64 `thrift:"sessionId,1" db:"sessionId" json:"sessionId"` @@ -34626,6 +35387,204 @@ return fmt.Sprintf("IClientRPCServiceSendFileResult(%+v)", *p) } +// Attributes: +// - Req +type IClientRPCServicePipeTransferArgs struct { + Req *TPipeTransferReq +} + +func NewIClientRPCServicePipeTransferArgs() *IClientRPCServicePipeTransferArgs { + return &IClientRPCServicePipeTransferArgs{} +} + +var IClientRPCServicePipeTransferArgs_Req_DEFAULT *TPipeTransferReq +func (p *IClientRPCServicePipeTransferArgs) GetReq() *TPipeTransferReq { + if !p.IsSetReq() { + return IClientRPCServicePipeTransferArgs_Req_DEFAULT + } +return p.Req +} +func (p *IClientRPCServicePipeTransferArgs) IsSetReq() bool { + return p.Req != nil +} + +func (p *IClientRPCServicePipeTransferArgs) Read(ctx context.Context, iprot thrift.TProtocol) error { + if _, err := iprot.ReadStructBegin(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) + } + + + for { + _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) + if err != nil { + return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) + } + if fieldTypeId == thrift.STOP { break; } + switch fieldId { + case -1: + if fieldTypeId == thrift.STRUCT { + if err := p.ReadField_1(ctx, iprot); err != nil { + return err + } + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + default: + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + if err := iprot.ReadFieldEnd(ctx); err != nil { + return err + } + } + if err := iprot.ReadStructEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) + } + return nil +} + +func (p *IClientRPCServicePipeTransferArgs) ReadField_1(ctx context.Context, iprot thrift.TProtocol) error { + p.Req = &TPipeTransferReq{} + if err := p.Req.Read(ctx, iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Req), err) + } + return nil +} + +func (p *IClientRPCServicePipeTransferArgs) Write(ctx context.Context, oprot thrift.TProtocol) error { + if err := oprot.WriteStructBegin(ctx, "pipeTransfer_args"); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } + if p != nil { + if err := p.writeField_1(ctx, oprot); err != nil { return err } + } + if err := oprot.WriteFieldStop(ctx); err != nil { + return thrift.PrependError("write field stop error: ", err) } + if err := oprot.WriteStructEnd(ctx); err != nil { + return thrift.PrependError("write struct stop error: ", err) } + return nil +} + +func (p *IClientRPCServicePipeTransferArgs) writeField_1(ctx context.Context, oprot thrift.TProtocol) (err error) { + if err := oprot.WriteFieldBegin(ctx, "req", thrift.STRUCT, -1); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error -1:req: ", p), err) } + if err := p.Req.Write(ctx, oprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Req), err) + } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error -1:req: ", p), err) } + return err +} + +func (p *IClientRPCServicePipeTransferArgs) String() string { + if p == nil { + return "<nil>" + } + return fmt.Sprintf("IClientRPCServicePipeTransferArgs(%+v)", *p) +} + +// Attributes: +// - Success +type IClientRPCServicePipeTransferResult struct { + Success *TPipeTransferResp `thrift:"success,0" db:"success" json:"success,omitempty"` +} + +func NewIClientRPCServicePipeTransferResult() *IClientRPCServicePipeTransferResult { + return &IClientRPCServicePipeTransferResult{} +} + +var IClientRPCServicePipeTransferResult_Success_DEFAULT *TPipeTransferResp +func (p *IClientRPCServicePipeTransferResult) GetSuccess() *TPipeTransferResp { + if !p.IsSetSuccess() { + return IClientRPCServicePipeTransferResult_Success_DEFAULT + } +return p.Success +} +func (p *IClientRPCServicePipeTransferResult) IsSetSuccess() bool { + return p.Success != nil +} + +func (p *IClientRPCServicePipeTransferResult) Read(ctx context.Context, iprot thrift.TProtocol) error { + if _, err := iprot.ReadStructBegin(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read error: ", p), err) + } + + + for { + _, fieldTypeId, fieldId, err := iprot.ReadFieldBegin(ctx) + if err != nil { + return thrift.PrependError(fmt.Sprintf("%T field %d read error: ", p, fieldId), err) + } + if fieldTypeId == thrift.STOP { break; } + switch fieldId { + case 0: + if fieldTypeId == thrift.STRUCT { + if err := p.ReadField0(ctx, iprot); err != nil { + return err + } + } else { + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + default: + if err := iprot.Skip(ctx, fieldTypeId); err != nil { + return err + } + } + if err := iprot.ReadFieldEnd(ctx); err != nil { + return err + } + } + if err := iprot.ReadStructEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T read struct end error: ", p), err) + } + return nil +} + +func (p *IClientRPCServicePipeTransferResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error { + p.Success = &TPipeTransferResp{} + if err := p.Success.Read(ctx, iprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error reading struct: ", p.Success), err) + } + return nil +} + +func (p *IClientRPCServicePipeTransferResult) Write(ctx context.Context, oprot thrift.TProtocol) error { + if err := oprot.WriteStructBegin(ctx, "pipeTransfer_result"); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write struct begin error: ", p), err) } + if p != nil { + if err := p.writeField0(ctx, oprot); err != nil { return err } + } + if err := oprot.WriteFieldStop(ctx); err != nil { + return thrift.PrependError("write field stop error: ", err) } + if err := oprot.WriteStructEnd(ctx); err != nil { + return thrift.PrependError("write struct stop error: ", err) } + return nil +} + +func (p *IClientRPCServicePipeTransferResult) writeField0(ctx context.Context, oprot thrift.TProtocol) (err error) { + if p.IsSetSuccess() { + if err := oprot.WriteFieldBegin(ctx, "success", thrift.STRUCT, 0); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field begin error 0:success: ", p), err) } + if err := p.Success.Write(ctx, oprot); err != nil { + return thrift.PrependError(fmt.Sprintf("%T error writing struct: ", p.Success), err) + } + if err := oprot.WriteFieldEnd(ctx); err != nil { + return thrift.PrependError(fmt.Sprintf("%T write field end error 0:success: ", p), err) } + } + return err +} + +func (p *IClientRPCServicePipeTransferResult) String() string { + if p == nil { + return "<nil>" + } + return fmt.Sprintf("IClientRPCServicePipeTransferResult(%+v)", *p) +} + type IClientRPCServiceGetBackupConfigurationArgs struct { }