Versions in this module Expand all Collapse all v2 v2.0.8 Mar 12, 2026 Changes in this version + var GoUnusedProtection__ int + var IClientRPCServiceAppendSchemaTemplateResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceCancelOperationResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceCloseOperationResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceCloseSessionResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceCreateAlignedTimeseriesResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceCreateMultiTimeseriesResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceCreateSchemaTemplateResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceCreateTimeseriesResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceDeallocatePreparedStatementResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceDeleteDataResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceDeleteStorageGroupsResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceDeleteTimeseriesResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceDropSchemaTemplateResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceExecuteBatchStatementResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceHandshakeResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceInsertRecordResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceInsertRecordsOfOneDeviceResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceInsertRecordsResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceInsertStringRecordResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceInsertStringRecordsOfOneDeviceResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceInsertStringRecordsResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceInsertTabletResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceInsertTabletsResult_Success_DEFAULT *common.TSStatus + var IClientRPCServicePruneSchemaTemplateResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceRequestStatementIdResult_Success_DEFAULT int64 + var IClientRPCServiceSendFileResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceSendPipeDataResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceSetSchemaTemplateResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceSetStorageGroupResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceSetTimeZoneResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceShowConfigurationResult_Success_DEFAULT *common.TShowConfigurationResp + var IClientRPCServiceShowConfigurationTemplateResult_Success_DEFAULT *common.TShowConfigurationTemplateResp + var IClientRPCServiceTestConnectionEmptyRPCResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceTestInsertRecordResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceTestInsertRecordsOfOneDeviceResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceTestInsertRecordsResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceTestInsertStringRecordResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceTestInsertStringRecordsResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceTestInsertTabletResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceTestInsertTabletsResult_Success_DEFAULT *common.TSStatus + var IClientRPCServiceUnsetSchemaTemplateResult_Success_DEFAULT *common.TSStatus + var ServerProperties_BuildInfo_DEFAULT string + var ServerProperties_IsReadOnly_DEFAULT bool + var ServerProperties_Logo_DEFAULT string + var ServerProperties_ThriftMaxFrameSize_DEFAULT int32 + var TPipeSubscribeReq_Body_DEFAULT []byte + var TPipeSubscribeResp_Body_DEFAULT [][]byte + var TPipeSubscribeResp_Status_DEFAULT *common.TSStatus + var TPipeTransferResp_Body_DEFAULT []byte + var TPipeTransferResp_Status_DEFAULT *common.TSStatus + var TSAggregationQueryReq_EndTime_DEFAULT int64 + var TSAggregationQueryReq_FetchSize_DEFAULT int32 + var TSAggregationQueryReq_Interval_DEFAULT int64 + var TSAggregationQueryReq_LegalPathNodes_DEFAULT bool + var TSAggregationQueryReq_SlidingStep_DEFAULT int64 + var TSAggregationQueryReq_StartTime_DEFAULT int64 + var TSAggregationQueryReq_Timeout_DEFAULT int64 + var TSBackupConfigurationResp_EnableOperationSync_DEFAULT bool + var TSBackupConfigurationResp_SecondaryAddress_DEFAULT string + var TSBackupConfigurationResp_SecondaryPort_DEFAULT int32 + var TSBackupConfigurationResp_Status_DEFAULT *common.TSStatus + var TSCloseOperationReq_PreparedStatementName_DEFAULT string + var TSCloseOperationReq_QueryId_DEFAULT int64 + var TSCloseOperationReq_StatementId_DEFAULT int64 + var TSCreateAlignedTimeseriesReq_AttributesList_DEFAULT []map[string]string + var TSCreateAlignedTimeseriesReq_MeasurementAlias_DEFAULT []string + var TSCreateAlignedTimeseriesReq_TagsList_DEFAULT []map[string]string + var TSCreateMultiTimeseriesReq_AttributesList_DEFAULT []map[string]string + var TSCreateMultiTimeseriesReq_MeasurementAliasList_DEFAULT []string + var TSCreateMultiTimeseriesReq_PropsList_DEFAULT []map[string]string + var TSCreateMultiTimeseriesReq_TagsList_DEFAULT []map[string]string + var TSCreateTimeseriesReq_Attributes_DEFAULT map[string]string + var TSCreateTimeseriesReq_MeasurementAlias_DEFAULT string + var TSCreateTimeseriesReq_Props_DEFAULT map[string]string + var TSCreateTimeseriesReq_Tags_DEFAULT map[string]string + var TSExecutePreparedReq_FetchSize_DEFAULT int32 + var TSExecutePreparedReq_Timeout_DEFAULT int64 + var TSExecuteStatementReq_EnableRedirectQuery_DEFAULT bool + var TSExecuteStatementReq_FetchSize_DEFAULT int32 + var TSExecuteStatementReq_JdbcQuery_DEFAULT bool + var TSExecuteStatementReq_Timeout_DEFAULT int64 + var TSExecuteStatementResp_AliasColumns_DEFAULT []int8 + var TSExecuteStatementResp_ColumnIndex2TsBlockColumnIndexList_DEFAULT []int32 + var TSExecuteStatementResp_ColumnNameIndexMap_DEFAULT map[string]int32 + var TSExecuteStatementResp_Columns_DEFAULT []string + var TSExecuteStatementResp_DataTypeList_DEFAULT []string + var TSExecuteStatementResp_Database_DEFAULT string + var TSExecuteStatementResp_IgnoreTimeStamp_DEFAULT bool + var TSExecuteStatementResp_MoreData_DEFAULT bool + var TSExecuteStatementResp_OperationType_DEFAULT string + var TSExecuteStatementResp_QueryId_DEFAULT int64 + var TSExecuteStatementResp_QueryResult__DEFAULT [][]byte + var TSExecuteStatementResp_SgColumns_DEFAULT []string + var TSExecuteStatementResp_Status_DEFAULT *common.TSStatus + var TSExecuteStatementResp_TableModel_DEFAULT bool + var TSFastLastDataQueryForOneDeviceReq_EnableRedirectQuery_DEFAULT bool + var TSFastLastDataQueryForOneDeviceReq_FetchSize_DEFAULT int32 + var TSFastLastDataQueryForOneDeviceReq_JdbcQuery_DEFAULT bool + var TSFastLastDataQueryForOneDeviceReq_LegalPathNodes_DEFAULT bool + var TSFastLastDataQueryForOneDeviceReq_Timeout_DEFAULT int64 + var TSFastLastDataQueryForOnePrefixPathReq_EnableRedirectQuery_DEFAULT bool + var TSFastLastDataQueryForOnePrefixPathReq_FetchSize_DEFAULT int32 + var TSFastLastDataQueryForOnePrefixPathReq_JdbcQuery_DEFAULT bool + var TSFastLastDataQueryForOnePrefixPathReq_Timeout_DEFAULT int64 + var TSFetchMetadataReq_ColumnPath_DEFAULT string + var TSFetchMetadataResp_ColumnsList_DEFAULT []string + var TSFetchMetadataResp_DataType_DEFAULT string + var TSFetchMetadataResp_MetadataInJson_DEFAULT string + var TSFetchMetadataResp_Status_DEFAULT *common.TSStatus + var TSFetchResultsReq_StatementId_DEFAULT int64 + var TSFetchResultsReq_Timeout_DEFAULT int64 + var TSFetchResultsResp_MoreData_DEFAULT bool + var TSFetchResultsResp_QueryResult__DEFAULT [][]byte + var TSFetchResultsResp_Status_DEFAULT *common.TSStatus + var TSGetTimeZoneResp_Status_DEFAULT *common.TSStatus + var TSInsertRecordReq_ColumnCategoryies_DEFAULT []int8 + var TSInsertRecordReq_IsAligned_DEFAULT bool + var TSInsertRecordReq_IsWriteToTable_DEFAULT bool + var TSInsertRecordsOfOneDeviceReq_IsAligned_DEFAULT bool + var TSInsertRecordsReq_IsAligned_DEFAULT bool + var TSInsertStringRecordReq_IsAligned_DEFAULT bool + var TSInsertStringRecordReq_Timeout_DEFAULT int64 + var TSInsertStringRecordsOfOneDeviceReq_IsAligned_DEFAULT bool + var TSInsertStringRecordsReq_IsAligned_DEFAULT bool + var TSInsertTabletReq_ColumnCategories_DEFAULT []int8 + var TSInsertTabletReq_CompressType_DEFAULT int8 + var TSInsertTabletReq_EncodingTypes_DEFAULT []int8 + var TSInsertTabletReq_IsAligned_DEFAULT bool + var TSInsertTabletReq_IsCompressed_DEFAULT bool + var TSInsertTabletReq_WriteToTable_DEFAULT bool + var TSInsertTabletsReq_IsAligned_DEFAULT bool + var TSLastDataQueryReq_EnableRedirectQuery_DEFAULT bool + var TSLastDataQueryReq_FetchSize_DEFAULT int32 + var TSLastDataQueryReq_JdbcQuery_DEFAULT bool + var TSLastDataQueryReq_LegalPathNodes_DEFAULT bool + var TSLastDataQueryReq_Timeout_DEFAULT int64 + var TSOpenSessionReq_Configuration_DEFAULT map[string]string + var TSOpenSessionReq_Password_DEFAULT string + var TSOpenSessionResp_Configuration_DEFAULT map[string]string + var TSOpenSessionResp_SessionId_DEFAULT int64 + var TSOpenSessionResp_Status_DEFAULT *common.TSStatus + var TSPrepareResp_ParameterCount_DEFAULT int32 + var TSPrepareResp_Status_DEFAULT *common.TSStatus + var TSQueryTemplateReq_Measurement_DEFAULT string + var TSQueryTemplateResp_Count_DEFAULT int32 + var TSQueryTemplateResp_Measurements_DEFAULT []string + var TSQueryTemplateResp_Result__DEFAULT bool + var TSQueryTemplateResp_Status_DEFAULT *common.TSStatus + var TSRawDataQueryReq_EnableRedirectQuery_DEFAULT bool + var TSRawDataQueryReq_FetchSize_DEFAULT int32 + var TSRawDataQueryReq_JdbcQuery_DEFAULT bool + var TSRawDataQueryReq_LegalPathNodes_DEFAULT bool + var TSRawDataQueryReq_Timeout_DEFAULT int64 + var TSTracingInfo_OverlappedPageNum_DEFAULT int32 + var TSTracingInfo_SeqFileNum_DEFAULT int32 + var TSTracingInfo_SequenceChunkNum_DEFAULT int32 + var TSTracingInfo_SequenceChunkPointNum_DEFAULT int64 + var TSTracingInfo_SeriesPathNum_DEFAULT int32 + var TSTracingInfo_TotalPageNum_DEFAULT int32 + var TSTracingInfo_UnSeqFileNum_DEFAULT int32 + var TSTracingInfo_UnsequenceChunkNum_DEFAULT int32 + var TSTracingInfo_UnsequenceChunkPointNum_DEFAULT int64 + type IClientRPCService interface + AppendSchemaTemplate func(ctx context.Context, req *TSAppendSchemaTemplateReq) (_r *common.TSStatus, _err error) + CancelOperation func(ctx context.Context, req *TSCancelOperationReq) (_r *common.TSStatus, _err error) + CloseOperation func(ctx context.Context, req *TSCloseOperationReq) (_r *common.TSStatus, _err error) + CloseSession func(ctx context.Context, req *TSCloseSessionReq) (_r *common.TSStatus, _err error) + CreateAlignedTimeseries func(ctx context.Context, req *TSCreateAlignedTimeseriesReq) (_r *common.TSStatus, _err error) + CreateMultiTimeseries func(ctx context.Context, req *TSCreateMultiTimeseriesReq) (_r *common.TSStatus, _err error) + CreateSchemaTemplate func(ctx context.Context, req *TSCreateSchemaTemplateReq) (_r *common.TSStatus, _err error) + CreateTimeseries func(ctx context.Context, req *TSCreateTimeseriesReq) (_r *common.TSStatus, _err error) + CreateTimeseriesUsingSchemaTemplate func(ctx context.Context, req *TCreateTimeseriesUsingSchemaTemplateReq) (_r *common.TSStatus, _err error) + DeallocatePreparedStatement func(ctx context.Context, req *TSDeallocatePreparedReq) (_r *common.TSStatus, _err error) + DeleteData func(ctx context.Context, req *TSDeleteDataReq) (_r *common.TSStatus, _err error) + DeleteStorageGroups func(ctx context.Context, sessionId int64, storageGroup []string) (_r *common.TSStatus, _err error) + DeleteTimeseries func(ctx context.Context, sessionId int64, path []string) (_r *common.TSStatus, _err error) + DropSchemaTemplate func(ctx context.Context, req *TSDropSchemaTemplateReq) (_r *common.TSStatus, _err error) + ExecuteAggregationQuery func(ctx context.Context, req *TSAggregationQueryReq) (_r *TSExecuteStatementResp, _err error) + ExecuteAggregationQueryV2 func(ctx context.Context, req *TSAggregationQueryReq) (_r *TSExecuteStatementResp, _err error) + ExecuteBatchStatement func(ctx context.Context, req *TSExecuteBatchStatementReq) (_r *common.TSStatus, _err error) + ExecuteFastLastDataQueryForOneDeviceV2 func(ctx context.Context, req *TSFastLastDataQueryForOneDeviceReq) (_r *TSExecuteStatementResp, _err error) + ExecuteFastLastDataQueryForOnePrefixPath func(ctx context.Context, req *TSFastLastDataQueryForOnePrefixPathReq) (_r *TSExecuteStatementResp, _err error) + ExecuteLastDataQuery func(ctx context.Context, req *TSLastDataQueryReq) (_r *TSExecuteStatementResp, _err error) + ExecuteLastDataQueryV2 func(ctx context.Context, req *TSLastDataQueryReq) (_r *TSExecuteStatementResp, _err error) + ExecutePreparedStatement func(ctx context.Context, req *TSExecutePreparedReq) (_r *TSExecuteStatementResp, _err error) + ExecuteQueryStatement func(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) + ExecuteQueryStatementV2 func(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) + ExecuteRawDataQuery func(ctx context.Context, req *TSRawDataQueryReq) (_r *TSExecuteStatementResp, _err error) + ExecuteRawDataQueryV2 func(ctx context.Context, req *TSRawDataQueryReq) (_r *TSExecuteStatementResp, _err error) + ExecuteStatement func(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) + ExecuteStatementV2 func(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) + ExecuteUpdateStatement func(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) + ExecuteUpdateStatementV2 func(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) + FetchAllConnectionsInfo func(ctx context.Context) (_r *TSConnectionInfoResp, _err error) + FetchMetadata func(ctx context.Context, req *TSFetchMetadataReq) (_r *TSFetchMetadataResp, _err error) + FetchResults func(ctx context.Context, req *TSFetchResultsReq) (_r *TSFetchResultsResp, _err error) + FetchResultsV2 func(ctx context.Context, req *TSFetchResultsReq) (_r *TSFetchResultsResp, _err error) + GetBackupConfiguration func(ctx context.Context) (_r *TSBackupConfigurationResp, _err error) + GetProperties func(ctx context.Context) (_r *ServerProperties, _err error) + GetTimeZone func(ctx context.Context, sessionId int64) (_r *TSGetTimeZoneResp, _err error) + Handshake func(ctx context.Context, info *TSyncIdentityInfo) (_r *common.TSStatus, _err error) + InsertRecord func(ctx context.Context, req *TSInsertRecordReq) (_r *common.TSStatus, _err error) + InsertRecords func(ctx context.Context, req *TSInsertRecordsReq) (_r *common.TSStatus, _err error) + InsertRecordsOfOneDevice func(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error) + InsertStringRecord func(ctx context.Context, req *TSInsertStringRecordReq) (_r *common.TSStatus, _err error) + InsertStringRecords func(ctx context.Context, req *TSInsertStringRecordsReq) (_r *common.TSStatus, _err error) + InsertStringRecordsOfOneDevice func(ctx context.Context, req *TSInsertStringRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error) + InsertTablet func(ctx context.Context, req *TSInsertTabletReq) (_r *common.TSStatus, _err error) + InsertTablets func(ctx context.Context, req *TSInsertTabletsReq) (_r *common.TSStatus, _err error) + OpenSession func(ctx context.Context, req *TSOpenSessionReq) (_r *TSOpenSessionResp, _err error) + PipeSubscribe func(ctx context.Context, req *TPipeSubscribeReq) (_r *TPipeSubscribeResp, _err error) + PipeTransfer func(ctx context.Context, req *TPipeTransferReq) (_r *TPipeTransferResp, _err error) + PrepareStatement func(ctx context.Context, req *TSPrepareReq) (_r *TSPrepareResp, _err error) + PruneSchemaTemplate func(ctx context.Context, req *TSPruneSchemaTemplateReq) (_r *common.TSStatus, _err error) + QuerySchemaTemplate func(ctx context.Context, req *TSQueryTemplateReq) (_r *TSQueryTemplateResp, _err error) + RequestStatementId func(ctx context.Context, sessionId int64) (_r int64, _err error) + SendFile func(ctx context.Context, metaInfo *TSyncTransportMetaInfo, buff []byte) (_r *common.TSStatus, _err error) + SendPipeData func(ctx context.Context, buff []byte) (_r *common.TSStatus, _err error) + SetSchemaTemplate func(ctx context.Context, req *TSSetSchemaTemplateReq) (_r *common.TSStatus, _err error) + SetStorageGroup func(ctx context.Context, sessionId int64, storageGroup string) (_r *common.TSStatus, _err error) + SetTimeZone func(ctx context.Context, req *TSSetTimeZoneReq) (_r *common.TSStatus, _err error) + ShowConfiguration func(ctx context.Context, nodeId int32) (_r *common.TShowConfigurationResp, _err error) + ShowConfigurationTemplate func(ctx context.Context) (_r *common.TShowConfigurationTemplateResp, _err error) + TestConnectionEmptyRPC func(ctx context.Context) (_r *common.TSStatus, _err error) + TestInsertRecord func(ctx context.Context, req *TSInsertRecordReq) (_r *common.TSStatus, _err error) + TestInsertRecords func(ctx context.Context, req *TSInsertRecordsReq) (_r *common.TSStatus, _err error) + TestInsertRecordsOfOneDevice func(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error) + TestInsertStringRecord func(ctx context.Context, req *TSInsertStringRecordReq) (_r *common.TSStatus, _err error) + TestInsertStringRecords func(ctx context.Context, req *TSInsertStringRecordsReq) (_r *common.TSStatus, _err error) + TestInsertTablet func(ctx context.Context, req *TSInsertTabletReq) (_r *common.TSStatus, _err error) + TestInsertTablets func(ctx context.Context, req *TSInsertTabletsReq) (_r *common.TSStatus, _err error) + UnsetSchemaTemplate func(ctx context.Context, req *TSUnsetSchemaTemplateReq) (_r *common.TSStatus, _err error) + type IClientRPCServiceAppendSchemaTemplateArgs struct + Req *TSAppendSchemaTemplateReq + func NewIClientRPCServiceAppendSchemaTemplateArgs() *IClientRPCServiceAppendSchemaTemplateArgs + func (p *IClientRPCServiceAppendSchemaTemplateArgs) GetReq() *TSAppendSchemaTemplateReq + func (p *IClientRPCServiceAppendSchemaTemplateArgs) IsSetReq() bool + func (p *IClientRPCServiceAppendSchemaTemplateArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceAppendSchemaTemplateArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceAppendSchemaTemplateArgs) String() string + func (p *IClientRPCServiceAppendSchemaTemplateArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceAppendSchemaTemplateResult struct + Success *common.TSStatus + func NewIClientRPCServiceAppendSchemaTemplateResult() *IClientRPCServiceAppendSchemaTemplateResult + func (p *IClientRPCServiceAppendSchemaTemplateResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceAppendSchemaTemplateResult) IsSetSuccess() bool + func (p *IClientRPCServiceAppendSchemaTemplateResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceAppendSchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceAppendSchemaTemplateResult) String() string + func (p *IClientRPCServiceAppendSchemaTemplateResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCancelOperationArgs struct + Req *TSCancelOperationReq + func NewIClientRPCServiceCancelOperationArgs() *IClientRPCServiceCancelOperationArgs + func (p *IClientRPCServiceCancelOperationArgs) GetReq() *TSCancelOperationReq + func (p *IClientRPCServiceCancelOperationArgs) IsSetReq() bool + func (p *IClientRPCServiceCancelOperationArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCancelOperationArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCancelOperationArgs) String() string + func (p *IClientRPCServiceCancelOperationArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCancelOperationResult struct + Success *common.TSStatus + func NewIClientRPCServiceCancelOperationResult() *IClientRPCServiceCancelOperationResult + func (p *IClientRPCServiceCancelOperationResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceCancelOperationResult) IsSetSuccess() bool + func (p *IClientRPCServiceCancelOperationResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCancelOperationResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCancelOperationResult) String() string + func (p *IClientRPCServiceCancelOperationResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceClient struct + func NewIClientRPCServiceClient(c thrift.TClient) *IClientRPCServiceClient + func NewIClientRPCServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *IClientRPCServiceClient + func NewIClientRPCServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *IClientRPCServiceClient + func (p *IClientRPCServiceClient) AppendSchemaTemplate(ctx context.Context, req *TSAppendSchemaTemplateReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) CancelOperation(ctx context.Context, req *TSCancelOperationReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) Client_() thrift.TClient + func (p *IClientRPCServiceClient) CloseOperation(ctx context.Context, req *TSCloseOperationReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) CloseSession(ctx context.Context, req *TSCloseSessionReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) CreateAlignedTimeseries(ctx context.Context, req *TSCreateAlignedTimeseriesReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) CreateMultiTimeseries(ctx context.Context, req *TSCreateMultiTimeseriesReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) CreateSchemaTemplate(ctx context.Context, req *TSCreateSchemaTemplateReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) CreateTimeseries(ctx context.Context, req *TSCreateTimeseriesReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) CreateTimeseriesUsingSchemaTemplate(ctx context.Context, req *TCreateTimeseriesUsingSchemaTemplateReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) DeallocatePreparedStatement(ctx context.Context, req *TSDeallocatePreparedReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) DeleteData(ctx context.Context, req *TSDeleteDataReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) DeleteStorageGroups(ctx context.Context, sessionId int64, storageGroup []string) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) DeleteTimeseries(ctx context.Context, sessionId int64, path []string) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) DropSchemaTemplate(ctx context.Context, req *TSDropSchemaTemplateReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) ExecuteAggregationQuery(ctx context.Context, req *TSAggregationQueryReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) ExecuteAggregationQueryV2(ctx context.Context, req *TSAggregationQueryReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) ExecuteBatchStatement(ctx context.Context, req *TSExecuteBatchStatementReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) ExecuteFastLastDataQueryForOneDeviceV2(ctx context.Context, req *TSFastLastDataQueryForOneDeviceReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) ExecuteFastLastDataQueryForOnePrefixPath(ctx context.Context, req *TSFastLastDataQueryForOnePrefixPathReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) ExecuteLastDataQuery(ctx context.Context, req *TSLastDataQueryReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) ExecuteLastDataQueryV2(ctx context.Context, req *TSLastDataQueryReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) ExecutePreparedStatement(ctx context.Context, req *TSExecutePreparedReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) ExecuteQueryStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) ExecuteQueryStatementV2(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) ExecuteRawDataQuery(ctx context.Context, req *TSRawDataQueryReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) ExecuteRawDataQueryV2(ctx context.Context, req *TSRawDataQueryReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) ExecuteStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) ExecuteStatementV2(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) ExecuteUpdateStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) ExecuteUpdateStatementV2(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error) + func (p *IClientRPCServiceClient) FetchAllConnectionsInfo(ctx context.Context) (_r *TSConnectionInfoResp, _err error) + func (p *IClientRPCServiceClient) FetchMetadata(ctx context.Context, req *TSFetchMetadataReq) (_r *TSFetchMetadataResp, _err error) + func (p *IClientRPCServiceClient) FetchResults(ctx context.Context, req *TSFetchResultsReq) (_r *TSFetchResultsResp, _err error) + func (p *IClientRPCServiceClient) FetchResultsV2(ctx context.Context, req *TSFetchResultsReq) (_r *TSFetchResultsResp, _err error) + func (p *IClientRPCServiceClient) GetBackupConfiguration(ctx context.Context) (_r *TSBackupConfigurationResp, _err error) + func (p *IClientRPCServiceClient) GetProperties(ctx context.Context) (_r *ServerProperties, _err error) + func (p *IClientRPCServiceClient) GetTimeZone(ctx context.Context, sessionId int64) (_r *TSGetTimeZoneResp, _err error) + func (p *IClientRPCServiceClient) Handshake(ctx context.Context, info *TSyncIdentityInfo) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) InsertRecord(ctx context.Context, req *TSInsertRecordReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) InsertRecords(ctx context.Context, req *TSInsertRecordsReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) InsertRecordsOfOneDevice(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) InsertStringRecord(ctx context.Context, req *TSInsertStringRecordReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) InsertStringRecords(ctx context.Context, req *TSInsertStringRecordsReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) InsertStringRecordsOfOneDevice(ctx context.Context, req *TSInsertStringRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) InsertTablet(ctx context.Context, req *TSInsertTabletReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) InsertTablets(ctx context.Context, req *TSInsertTabletsReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) LastResponseMeta_() thrift.ResponseMeta + func (p *IClientRPCServiceClient) OpenSession(ctx context.Context, req *TSOpenSessionReq) (_r *TSOpenSessionResp, _err error) + func (p *IClientRPCServiceClient) PipeSubscribe(ctx context.Context, req *TPipeSubscribeReq) (_r *TPipeSubscribeResp, _err error) + func (p *IClientRPCServiceClient) PipeTransfer(ctx context.Context, req *TPipeTransferReq) (_r *TPipeTransferResp, _err error) + func (p *IClientRPCServiceClient) PrepareStatement(ctx context.Context, req *TSPrepareReq) (_r *TSPrepareResp, _err error) + func (p *IClientRPCServiceClient) PruneSchemaTemplate(ctx context.Context, req *TSPruneSchemaTemplateReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) QuerySchemaTemplate(ctx context.Context, req *TSQueryTemplateReq) (_r *TSQueryTemplateResp, _err error) + func (p *IClientRPCServiceClient) RequestStatementId(ctx context.Context, sessionId int64) (_r int64, _err error) + func (p *IClientRPCServiceClient) SendFile(ctx context.Context, metaInfo *TSyncTransportMetaInfo, buff []byte) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) SendPipeData(ctx context.Context, buff []byte) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) SetLastResponseMeta_(meta thrift.ResponseMeta) + func (p *IClientRPCServiceClient) SetSchemaTemplate(ctx context.Context, req *TSSetSchemaTemplateReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) SetStorageGroup(ctx context.Context, sessionId int64, storageGroup string) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) SetTimeZone(ctx context.Context, req *TSSetTimeZoneReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) ShowConfiguration(ctx context.Context, nodeId int32) (_r *common.TShowConfigurationResp, _err error) + func (p *IClientRPCServiceClient) ShowConfigurationTemplate(ctx context.Context) (_r *common.TShowConfigurationTemplateResp, _err error) + func (p *IClientRPCServiceClient) TestConnectionEmptyRPC(ctx context.Context) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) TestInsertRecord(ctx context.Context, req *TSInsertRecordReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) TestInsertRecords(ctx context.Context, req *TSInsertRecordsReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) TestInsertRecordsOfOneDevice(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) TestInsertStringRecord(ctx context.Context, req *TSInsertStringRecordReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) TestInsertStringRecords(ctx context.Context, req *TSInsertStringRecordsReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) TestInsertTablet(ctx context.Context, req *TSInsertTabletReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) TestInsertTablets(ctx context.Context, req *TSInsertTabletsReq) (_r *common.TSStatus, _err error) + func (p *IClientRPCServiceClient) UnsetSchemaTemplate(ctx context.Context, req *TSUnsetSchemaTemplateReq) (_r *common.TSStatus, _err error) + type IClientRPCServiceCloseOperationArgs struct + Req *TSCloseOperationReq + func NewIClientRPCServiceCloseOperationArgs() *IClientRPCServiceCloseOperationArgs + func (p *IClientRPCServiceCloseOperationArgs) GetReq() *TSCloseOperationReq + func (p *IClientRPCServiceCloseOperationArgs) IsSetReq() bool + func (p *IClientRPCServiceCloseOperationArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCloseOperationArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCloseOperationArgs) String() string + func (p *IClientRPCServiceCloseOperationArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCloseOperationResult struct + Success *common.TSStatus + func NewIClientRPCServiceCloseOperationResult() *IClientRPCServiceCloseOperationResult + func (p *IClientRPCServiceCloseOperationResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceCloseOperationResult) IsSetSuccess() bool + func (p *IClientRPCServiceCloseOperationResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCloseOperationResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCloseOperationResult) String() string + func (p *IClientRPCServiceCloseOperationResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCloseSessionArgs struct + Req *TSCloseSessionReq + func NewIClientRPCServiceCloseSessionArgs() *IClientRPCServiceCloseSessionArgs + func (p *IClientRPCServiceCloseSessionArgs) GetReq() *TSCloseSessionReq + func (p *IClientRPCServiceCloseSessionArgs) IsSetReq() bool + func (p *IClientRPCServiceCloseSessionArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCloseSessionArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCloseSessionArgs) String() string + func (p *IClientRPCServiceCloseSessionArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCloseSessionResult struct + Success *common.TSStatus + func NewIClientRPCServiceCloseSessionResult() *IClientRPCServiceCloseSessionResult + func (p *IClientRPCServiceCloseSessionResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceCloseSessionResult) IsSetSuccess() bool + func (p *IClientRPCServiceCloseSessionResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCloseSessionResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCloseSessionResult) String() string + func (p *IClientRPCServiceCloseSessionResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCreateAlignedTimeseriesArgs struct + Req *TSCreateAlignedTimeseriesReq + func NewIClientRPCServiceCreateAlignedTimeseriesArgs() *IClientRPCServiceCreateAlignedTimeseriesArgs + func (p *IClientRPCServiceCreateAlignedTimeseriesArgs) GetReq() *TSCreateAlignedTimeseriesReq + func (p *IClientRPCServiceCreateAlignedTimeseriesArgs) IsSetReq() bool + func (p *IClientRPCServiceCreateAlignedTimeseriesArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateAlignedTimeseriesArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateAlignedTimeseriesArgs) String() string + func (p *IClientRPCServiceCreateAlignedTimeseriesArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCreateAlignedTimeseriesResult struct + Success *common.TSStatus + func NewIClientRPCServiceCreateAlignedTimeseriesResult() *IClientRPCServiceCreateAlignedTimeseriesResult + func (p *IClientRPCServiceCreateAlignedTimeseriesResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceCreateAlignedTimeseriesResult) IsSetSuccess() bool + func (p *IClientRPCServiceCreateAlignedTimeseriesResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateAlignedTimeseriesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateAlignedTimeseriesResult) String() string + func (p *IClientRPCServiceCreateAlignedTimeseriesResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCreateMultiTimeseriesArgs struct + Req *TSCreateMultiTimeseriesReq + func NewIClientRPCServiceCreateMultiTimeseriesArgs() *IClientRPCServiceCreateMultiTimeseriesArgs + func (p *IClientRPCServiceCreateMultiTimeseriesArgs) GetReq() *TSCreateMultiTimeseriesReq + func (p *IClientRPCServiceCreateMultiTimeseriesArgs) IsSetReq() bool + func (p *IClientRPCServiceCreateMultiTimeseriesArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateMultiTimeseriesArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateMultiTimeseriesArgs) String() string + func (p *IClientRPCServiceCreateMultiTimeseriesArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCreateMultiTimeseriesResult struct + Success *common.TSStatus + func NewIClientRPCServiceCreateMultiTimeseriesResult() *IClientRPCServiceCreateMultiTimeseriesResult + func (p *IClientRPCServiceCreateMultiTimeseriesResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceCreateMultiTimeseriesResult) IsSetSuccess() bool + func (p *IClientRPCServiceCreateMultiTimeseriesResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateMultiTimeseriesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateMultiTimeseriesResult) String() string + func (p *IClientRPCServiceCreateMultiTimeseriesResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCreateSchemaTemplateArgs struct + Req *TSCreateSchemaTemplateReq + func NewIClientRPCServiceCreateSchemaTemplateArgs() *IClientRPCServiceCreateSchemaTemplateArgs + func (p *IClientRPCServiceCreateSchemaTemplateArgs) GetReq() *TSCreateSchemaTemplateReq + func (p *IClientRPCServiceCreateSchemaTemplateArgs) IsSetReq() bool + func (p *IClientRPCServiceCreateSchemaTemplateArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateSchemaTemplateArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateSchemaTemplateArgs) String() string + func (p *IClientRPCServiceCreateSchemaTemplateArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCreateSchemaTemplateResult struct + Success *common.TSStatus + func NewIClientRPCServiceCreateSchemaTemplateResult() *IClientRPCServiceCreateSchemaTemplateResult + func (p *IClientRPCServiceCreateSchemaTemplateResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceCreateSchemaTemplateResult) IsSetSuccess() bool + func (p *IClientRPCServiceCreateSchemaTemplateResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateSchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateSchemaTemplateResult) String() string + func (p *IClientRPCServiceCreateSchemaTemplateResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCreateTimeseriesArgs struct + Req *TSCreateTimeseriesReq + func NewIClientRPCServiceCreateTimeseriesArgs() *IClientRPCServiceCreateTimeseriesArgs + func (p *IClientRPCServiceCreateTimeseriesArgs) GetReq() *TSCreateTimeseriesReq + func (p *IClientRPCServiceCreateTimeseriesArgs) IsSetReq() bool + func (p *IClientRPCServiceCreateTimeseriesArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateTimeseriesArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateTimeseriesArgs) String() string + func (p *IClientRPCServiceCreateTimeseriesArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCreateTimeseriesResult struct + Success *common.TSStatus + func NewIClientRPCServiceCreateTimeseriesResult() *IClientRPCServiceCreateTimeseriesResult + func (p *IClientRPCServiceCreateTimeseriesResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceCreateTimeseriesResult) IsSetSuccess() bool + func (p *IClientRPCServiceCreateTimeseriesResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateTimeseriesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateTimeseriesResult) String() string + func (p *IClientRPCServiceCreateTimeseriesResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs struct + Req *TCreateTimeseriesUsingSchemaTemplateReq + func NewIClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs() *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs + func (p *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs) GetReq() *TCreateTimeseriesUsingSchemaTemplateReq + func (p *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs) IsSetReq() bool + func (p *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs) String() string + func (p *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult struct + Success *common.TSStatus + func NewIClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult() *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult + func (p *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult) IsSetSuccess() bool + func (p *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult) String() string + func (p *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceDeallocatePreparedStatementArgs struct + Req *TSDeallocatePreparedReq + func NewIClientRPCServiceDeallocatePreparedStatementArgs() *IClientRPCServiceDeallocatePreparedStatementArgs + func (p *IClientRPCServiceDeallocatePreparedStatementArgs) GetReq() *TSDeallocatePreparedReq + func (p *IClientRPCServiceDeallocatePreparedStatementArgs) IsSetReq() bool + func (p *IClientRPCServiceDeallocatePreparedStatementArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeallocatePreparedStatementArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeallocatePreparedStatementArgs) String() string + func (p *IClientRPCServiceDeallocatePreparedStatementArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceDeallocatePreparedStatementResult struct + Success *common.TSStatus + func NewIClientRPCServiceDeallocatePreparedStatementResult() *IClientRPCServiceDeallocatePreparedStatementResult + func (p *IClientRPCServiceDeallocatePreparedStatementResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceDeallocatePreparedStatementResult) IsSetSuccess() bool + func (p *IClientRPCServiceDeallocatePreparedStatementResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeallocatePreparedStatementResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeallocatePreparedStatementResult) String() string + func (p *IClientRPCServiceDeallocatePreparedStatementResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceDeleteDataArgs struct + Req *TSDeleteDataReq + func NewIClientRPCServiceDeleteDataArgs() *IClientRPCServiceDeleteDataArgs + func (p *IClientRPCServiceDeleteDataArgs) GetReq() *TSDeleteDataReq + func (p *IClientRPCServiceDeleteDataArgs) IsSetReq() bool + func (p *IClientRPCServiceDeleteDataArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeleteDataArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeleteDataArgs) String() string + func (p *IClientRPCServiceDeleteDataArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceDeleteDataResult struct + Success *common.TSStatus + func NewIClientRPCServiceDeleteDataResult() *IClientRPCServiceDeleteDataResult + func (p *IClientRPCServiceDeleteDataResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceDeleteDataResult) IsSetSuccess() bool + func (p *IClientRPCServiceDeleteDataResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeleteDataResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeleteDataResult) String() string + func (p *IClientRPCServiceDeleteDataResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceDeleteStorageGroupsArgs struct + SessionId int64 + StorageGroup []string + func NewIClientRPCServiceDeleteStorageGroupsArgs() *IClientRPCServiceDeleteStorageGroupsArgs + func (p *IClientRPCServiceDeleteStorageGroupsArgs) GetSessionId() int64 + func (p *IClientRPCServiceDeleteStorageGroupsArgs) GetStorageGroup() []string + func (p *IClientRPCServiceDeleteStorageGroupsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeleteStorageGroupsArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeleteStorageGroupsArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeleteStorageGroupsArgs) String() string + func (p *IClientRPCServiceDeleteStorageGroupsArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceDeleteStorageGroupsResult struct + Success *common.TSStatus + func NewIClientRPCServiceDeleteStorageGroupsResult() *IClientRPCServiceDeleteStorageGroupsResult + func (p *IClientRPCServiceDeleteStorageGroupsResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceDeleteStorageGroupsResult) IsSetSuccess() bool + func (p *IClientRPCServiceDeleteStorageGroupsResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeleteStorageGroupsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeleteStorageGroupsResult) String() string + func (p *IClientRPCServiceDeleteStorageGroupsResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceDeleteTimeseriesArgs struct + Path []string + SessionId int64 + func NewIClientRPCServiceDeleteTimeseriesArgs() *IClientRPCServiceDeleteTimeseriesArgs + func (p *IClientRPCServiceDeleteTimeseriesArgs) GetPath() []string + func (p *IClientRPCServiceDeleteTimeseriesArgs) GetSessionId() int64 + func (p *IClientRPCServiceDeleteTimeseriesArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeleteTimeseriesArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeleteTimeseriesArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeleteTimeseriesArgs) String() string + func (p *IClientRPCServiceDeleteTimeseriesArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceDeleteTimeseriesResult struct + Success *common.TSStatus + func NewIClientRPCServiceDeleteTimeseriesResult() *IClientRPCServiceDeleteTimeseriesResult + func (p *IClientRPCServiceDeleteTimeseriesResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceDeleteTimeseriesResult) IsSetSuccess() bool + func (p *IClientRPCServiceDeleteTimeseriesResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeleteTimeseriesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDeleteTimeseriesResult) String() string + func (p *IClientRPCServiceDeleteTimeseriesResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceDropSchemaTemplateArgs struct + Req *TSDropSchemaTemplateReq + func NewIClientRPCServiceDropSchemaTemplateArgs() *IClientRPCServiceDropSchemaTemplateArgs + func (p *IClientRPCServiceDropSchemaTemplateArgs) GetReq() *TSDropSchemaTemplateReq + func (p *IClientRPCServiceDropSchemaTemplateArgs) IsSetReq() bool + func (p *IClientRPCServiceDropSchemaTemplateArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDropSchemaTemplateArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDropSchemaTemplateArgs) String() string + func (p *IClientRPCServiceDropSchemaTemplateArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceDropSchemaTemplateResult struct + Success *common.TSStatus + func NewIClientRPCServiceDropSchemaTemplateResult() *IClientRPCServiceDropSchemaTemplateResult + func (p *IClientRPCServiceDropSchemaTemplateResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceDropSchemaTemplateResult) IsSetSuccess() bool + func (p *IClientRPCServiceDropSchemaTemplateResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDropSchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceDropSchemaTemplateResult) String() string + func (p *IClientRPCServiceDropSchemaTemplateResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteAggregationQueryArgs struct + Req *TSAggregationQueryReq + func NewIClientRPCServiceExecuteAggregationQueryArgs() *IClientRPCServiceExecuteAggregationQueryArgs + func (p *IClientRPCServiceExecuteAggregationQueryArgs) GetReq() *TSAggregationQueryReq + func (p *IClientRPCServiceExecuteAggregationQueryArgs) IsSetReq() bool + func (p *IClientRPCServiceExecuteAggregationQueryArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteAggregationQueryArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteAggregationQueryArgs) String() string + func (p *IClientRPCServiceExecuteAggregationQueryArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteAggregationQueryResult struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecuteAggregationQueryResult() *IClientRPCServiceExecuteAggregationQueryResult + func (p *IClientRPCServiceExecuteAggregationQueryResult) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecuteAggregationQueryResult) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteAggregationQueryResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteAggregationQueryResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteAggregationQueryResult) String() string + func (p *IClientRPCServiceExecuteAggregationQueryResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteAggregationQueryV2Args struct + Req *TSAggregationQueryReq + func NewIClientRPCServiceExecuteAggregationQueryV2Args() *IClientRPCServiceExecuteAggregationQueryV2Args + func (p *IClientRPCServiceExecuteAggregationQueryV2Args) GetReq() *TSAggregationQueryReq + func (p *IClientRPCServiceExecuteAggregationQueryV2Args) IsSetReq() bool + func (p *IClientRPCServiceExecuteAggregationQueryV2Args) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteAggregationQueryV2Args) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteAggregationQueryV2Args) String() string + func (p *IClientRPCServiceExecuteAggregationQueryV2Args) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteAggregationQueryV2Result struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecuteAggregationQueryV2Result() *IClientRPCServiceExecuteAggregationQueryV2Result + func (p *IClientRPCServiceExecuteAggregationQueryV2Result) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecuteAggregationQueryV2Result) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteAggregationQueryV2Result) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteAggregationQueryV2Result) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteAggregationQueryV2Result) String() string + func (p *IClientRPCServiceExecuteAggregationQueryV2Result) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteBatchStatementArgs struct + Req *TSExecuteBatchStatementReq + func NewIClientRPCServiceExecuteBatchStatementArgs() *IClientRPCServiceExecuteBatchStatementArgs + func (p *IClientRPCServiceExecuteBatchStatementArgs) GetReq() *TSExecuteBatchStatementReq + func (p *IClientRPCServiceExecuteBatchStatementArgs) IsSetReq() bool + func (p *IClientRPCServiceExecuteBatchStatementArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteBatchStatementArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteBatchStatementArgs) String() string + func (p *IClientRPCServiceExecuteBatchStatementArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteBatchStatementResult struct + Success *common.TSStatus + func NewIClientRPCServiceExecuteBatchStatementResult() *IClientRPCServiceExecuteBatchStatementResult + func (p *IClientRPCServiceExecuteBatchStatementResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceExecuteBatchStatementResult) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteBatchStatementResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteBatchStatementResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteBatchStatementResult) String() string + func (p *IClientRPCServiceExecuteBatchStatementResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Args struct + Req *TSFastLastDataQueryForOneDeviceReq + func NewIClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Args() *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Args + func (p *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Args) GetReq() *TSFastLastDataQueryForOneDeviceReq + func (p *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Args) IsSetReq() bool + func (p *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Args) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Args) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Args) String() string + func (p *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Args) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Result struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Result() *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Result + func (p *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Result) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Result) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Result) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Result) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Result) String() string + func (p *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Result) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathArgs struct + Req *TSFastLastDataQueryForOnePrefixPathReq + func NewIClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathArgs() *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathArgs + func (p *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathArgs) GetReq() *TSFastLastDataQueryForOnePrefixPathReq + func (p *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathArgs) IsSetReq() bool + func (p *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathArgs) String() string + func (p *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathResult struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathResult() *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathResult + func (p *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathResult) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathResult) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathResult) String() string + func (p *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteLastDataQueryArgs struct + Req *TSLastDataQueryReq + func NewIClientRPCServiceExecuteLastDataQueryArgs() *IClientRPCServiceExecuteLastDataQueryArgs + func (p *IClientRPCServiceExecuteLastDataQueryArgs) GetReq() *TSLastDataQueryReq + func (p *IClientRPCServiceExecuteLastDataQueryArgs) IsSetReq() bool + func (p *IClientRPCServiceExecuteLastDataQueryArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteLastDataQueryArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteLastDataQueryArgs) String() string + func (p *IClientRPCServiceExecuteLastDataQueryArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteLastDataQueryResult struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecuteLastDataQueryResult() *IClientRPCServiceExecuteLastDataQueryResult + func (p *IClientRPCServiceExecuteLastDataQueryResult) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecuteLastDataQueryResult) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteLastDataQueryResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteLastDataQueryResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteLastDataQueryResult) String() string + func (p *IClientRPCServiceExecuteLastDataQueryResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteLastDataQueryV2Args struct + Req *TSLastDataQueryReq + func NewIClientRPCServiceExecuteLastDataQueryV2Args() *IClientRPCServiceExecuteLastDataQueryV2Args + func (p *IClientRPCServiceExecuteLastDataQueryV2Args) GetReq() *TSLastDataQueryReq + func (p *IClientRPCServiceExecuteLastDataQueryV2Args) IsSetReq() bool + func (p *IClientRPCServiceExecuteLastDataQueryV2Args) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteLastDataQueryV2Args) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteLastDataQueryV2Args) String() string + func (p *IClientRPCServiceExecuteLastDataQueryV2Args) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteLastDataQueryV2Result struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecuteLastDataQueryV2Result() *IClientRPCServiceExecuteLastDataQueryV2Result + func (p *IClientRPCServiceExecuteLastDataQueryV2Result) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecuteLastDataQueryV2Result) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteLastDataQueryV2Result) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteLastDataQueryV2Result) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteLastDataQueryV2Result) String() string + func (p *IClientRPCServiceExecuteLastDataQueryV2Result) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecutePreparedStatementArgs struct + Req *TSExecutePreparedReq + func NewIClientRPCServiceExecutePreparedStatementArgs() *IClientRPCServiceExecutePreparedStatementArgs + func (p *IClientRPCServiceExecutePreparedStatementArgs) GetReq() *TSExecutePreparedReq + func (p *IClientRPCServiceExecutePreparedStatementArgs) IsSetReq() bool + func (p *IClientRPCServiceExecutePreparedStatementArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecutePreparedStatementArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecutePreparedStatementArgs) String() string + func (p *IClientRPCServiceExecutePreparedStatementArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecutePreparedStatementResult struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecutePreparedStatementResult() *IClientRPCServiceExecutePreparedStatementResult + func (p *IClientRPCServiceExecutePreparedStatementResult) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecutePreparedStatementResult) IsSetSuccess() bool + func (p *IClientRPCServiceExecutePreparedStatementResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecutePreparedStatementResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecutePreparedStatementResult) String() string + func (p *IClientRPCServiceExecutePreparedStatementResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteQueryStatementArgs struct + Req *TSExecuteStatementReq + func NewIClientRPCServiceExecuteQueryStatementArgs() *IClientRPCServiceExecuteQueryStatementArgs + func (p *IClientRPCServiceExecuteQueryStatementArgs) GetReq() *TSExecuteStatementReq + func (p *IClientRPCServiceExecuteQueryStatementArgs) IsSetReq() bool + func (p *IClientRPCServiceExecuteQueryStatementArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteQueryStatementArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteQueryStatementArgs) String() string + func (p *IClientRPCServiceExecuteQueryStatementArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteQueryStatementResult struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecuteQueryStatementResult() *IClientRPCServiceExecuteQueryStatementResult + func (p *IClientRPCServiceExecuteQueryStatementResult) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecuteQueryStatementResult) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteQueryStatementResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteQueryStatementResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteQueryStatementResult) String() string + func (p *IClientRPCServiceExecuteQueryStatementResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteQueryStatementV2Args struct + Req *TSExecuteStatementReq + func NewIClientRPCServiceExecuteQueryStatementV2Args() *IClientRPCServiceExecuteQueryStatementV2Args + func (p *IClientRPCServiceExecuteQueryStatementV2Args) GetReq() *TSExecuteStatementReq + func (p *IClientRPCServiceExecuteQueryStatementV2Args) IsSetReq() bool + func (p *IClientRPCServiceExecuteQueryStatementV2Args) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteQueryStatementV2Args) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteQueryStatementV2Args) String() string + func (p *IClientRPCServiceExecuteQueryStatementV2Args) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteQueryStatementV2Result struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecuteQueryStatementV2Result() *IClientRPCServiceExecuteQueryStatementV2Result + func (p *IClientRPCServiceExecuteQueryStatementV2Result) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecuteQueryStatementV2Result) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteQueryStatementV2Result) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteQueryStatementV2Result) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteQueryStatementV2Result) String() string + func (p *IClientRPCServiceExecuteQueryStatementV2Result) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteRawDataQueryArgs struct + Req *TSRawDataQueryReq + func NewIClientRPCServiceExecuteRawDataQueryArgs() *IClientRPCServiceExecuteRawDataQueryArgs + func (p *IClientRPCServiceExecuteRawDataQueryArgs) GetReq() *TSRawDataQueryReq + func (p *IClientRPCServiceExecuteRawDataQueryArgs) IsSetReq() bool + func (p *IClientRPCServiceExecuteRawDataQueryArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteRawDataQueryArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteRawDataQueryArgs) String() string + func (p *IClientRPCServiceExecuteRawDataQueryArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteRawDataQueryResult struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecuteRawDataQueryResult() *IClientRPCServiceExecuteRawDataQueryResult + func (p *IClientRPCServiceExecuteRawDataQueryResult) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecuteRawDataQueryResult) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteRawDataQueryResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteRawDataQueryResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteRawDataQueryResult) String() string + func (p *IClientRPCServiceExecuteRawDataQueryResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteRawDataQueryV2Args struct + Req *TSRawDataQueryReq + func NewIClientRPCServiceExecuteRawDataQueryV2Args() *IClientRPCServiceExecuteRawDataQueryV2Args + func (p *IClientRPCServiceExecuteRawDataQueryV2Args) GetReq() *TSRawDataQueryReq + func (p *IClientRPCServiceExecuteRawDataQueryV2Args) IsSetReq() bool + func (p *IClientRPCServiceExecuteRawDataQueryV2Args) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteRawDataQueryV2Args) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteRawDataQueryV2Args) String() string + func (p *IClientRPCServiceExecuteRawDataQueryV2Args) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteRawDataQueryV2Result struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecuteRawDataQueryV2Result() *IClientRPCServiceExecuteRawDataQueryV2Result + func (p *IClientRPCServiceExecuteRawDataQueryV2Result) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecuteRawDataQueryV2Result) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteRawDataQueryV2Result) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteRawDataQueryV2Result) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteRawDataQueryV2Result) String() string + func (p *IClientRPCServiceExecuteRawDataQueryV2Result) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteStatementArgs struct + Req *TSExecuteStatementReq + func NewIClientRPCServiceExecuteStatementArgs() *IClientRPCServiceExecuteStatementArgs + func (p *IClientRPCServiceExecuteStatementArgs) GetReq() *TSExecuteStatementReq + func (p *IClientRPCServiceExecuteStatementArgs) IsSetReq() bool + func (p *IClientRPCServiceExecuteStatementArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteStatementArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteStatementArgs) String() string + func (p *IClientRPCServiceExecuteStatementArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteStatementResult struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecuteStatementResult() *IClientRPCServiceExecuteStatementResult + func (p *IClientRPCServiceExecuteStatementResult) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecuteStatementResult) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteStatementResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteStatementResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteStatementResult) String() string + func (p *IClientRPCServiceExecuteStatementResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteStatementV2Args struct + Req *TSExecuteStatementReq + func NewIClientRPCServiceExecuteStatementV2Args() *IClientRPCServiceExecuteStatementV2Args + func (p *IClientRPCServiceExecuteStatementV2Args) GetReq() *TSExecuteStatementReq + func (p *IClientRPCServiceExecuteStatementV2Args) IsSetReq() bool + func (p *IClientRPCServiceExecuteStatementV2Args) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteStatementV2Args) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteStatementV2Args) String() string + func (p *IClientRPCServiceExecuteStatementV2Args) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteStatementV2Result struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecuteStatementV2Result() *IClientRPCServiceExecuteStatementV2Result + func (p *IClientRPCServiceExecuteStatementV2Result) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecuteStatementV2Result) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteStatementV2Result) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteStatementV2Result) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteStatementV2Result) String() string + func (p *IClientRPCServiceExecuteStatementV2Result) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteUpdateStatementArgs struct + Req *TSExecuteStatementReq + func NewIClientRPCServiceExecuteUpdateStatementArgs() *IClientRPCServiceExecuteUpdateStatementArgs + func (p *IClientRPCServiceExecuteUpdateStatementArgs) GetReq() *TSExecuteStatementReq + func (p *IClientRPCServiceExecuteUpdateStatementArgs) IsSetReq() bool + func (p *IClientRPCServiceExecuteUpdateStatementArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteUpdateStatementArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteUpdateStatementArgs) String() string + func (p *IClientRPCServiceExecuteUpdateStatementArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteUpdateStatementResult struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecuteUpdateStatementResult() *IClientRPCServiceExecuteUpdateStatementResult + func (p *IClientRPCServiceExecuteUpdateStatementResult) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecuteUpdateStatementResult) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteUpdateStatementResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteUpdateStatementResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteUpdateStatementResult) String() string + func (p *IClientRPCServiceExecuteUpdateStatementResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteUpdateStatementV2Args struct + Req *TSExecuteStatementReq + func NewIClientRPCServiceExecuteUpdateStatementV2Args() *IClientRPCServiceExecuteUpdateStatementV2Args + func (p *IClientRPCServiceExecuteUpdateStatementV2Args) GetReq() *TSExecuteStatementReq + func (p *IClientRPCServiceExecuteUpdateStatementV2Args) IsSetReq() bool + func (p *IClientRPCServiceExecuteUpdateStatementV2Args) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteUpdateStatementV2Args) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteUpdateStatementV2Args) String() string + func (p *IClientRPCServiceExecuteUpdateStatementV2Args) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceExecuteUpdateStatementV2Result struct + Success *TSExecuteStatementResp + func NewIClientRPCServiceExecuteUpdateStatementV2Result() *IClientRPCServiceExecuteUpdateStatementV2Result + func (p *IClientRPCServiceExecuteUpdateStatementV2Result) GetSuccess() *TSExecuteStatementResp + func (p *IClientRPCServiceExecuteUpdateStatementV2Result) IsSetSuccess() bool + func (p *IClientRPCServiceExecuteUpdateStatementV2Result) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteUpdateStatementV2Result) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceExecuteUpdateStatementV2Result) String() string + func (p *IClientRPCServiceExecuteUpdateStatementV2Result) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceFetchAllConnectionsInfoArgs struct + func NewIClientRPCServiceFetchAllConnectionsInfoArgs() *IClientRPCServiceFetchAllConnectionsInfoArgs + func (p *IClientRPCServiceFetchAllConnectionsInfoArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchAllConnectionsInfoArgs) String() string + func (p *IClientRPCServiceFetchAllConnectionsInfoArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceFetchAllConnectionsInfoResult struct + Success *TSConnectionInfoResp + func NewIClientRPCServiceFetchAllConnectionsInfoResult() *IClientRPCServiceFetchAllConnectionsInfoResult + func (p *IClientRPCServiceFetchAllConnectionsInfoResult) GetSuccess() *TSConnectionInfoResp + func (p *IClientRPCServiceFetchAllConnectionsInfoResult) IsSetSuccess() bool + func (p *IClientRPCServiceFetchAllConnectionsInfoResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchAllConnectionsInfoResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchAllConnectionsInfoResult) String() string + func (p *IClientRPCServiceFetchAllConnectionsInfoResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceFetchMetadataArgs struct + Req *TSFetchMetadataReq + func NewIClientRPCServiceFetchMetadataArgs() *IClientRPCServiceFetchMetadataArgs + func (p *IClientRPCServiceFetchMetadataArgs) GetReq() *TSFetchMetadataReq + func (p *IClientRPCServiceFetchMetadataArgs) IsSetReq() bool + func (p *IClientRPCServiceFetchMetadataArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchMetadataArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchMetadataArgs) String() string + func (p *IClientRPCServiceFetchMetadataArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceFetchMetadataResult struct + Success *TSFetchMetadataResp + func NewIClientRPCServiceFetchMetadataResult() *IClientRPCServiceFetchMetadataResult + func (p *IClientRPCServiceFetchMetadataResult) GetSuccess() *TSFetchMetadataResp + func (p *IClientRPCServiceFetchMetadataResult) IsSetSuccess() bool + func (p *IClientRPCServiceFetchMetadataResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchMetadataResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchMetadataResult) String() string + func (p *IClientRPCServiceFetchMetadataResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceFetchResultsArgs struct + Req *TSFetchResultsReq + func NewIClientRPCServiceFetchResultsArgs() *IClientRPCServiceFetchResultsArgs + func (p *IClientRPCServiceFetchResultsArgs) GetReq() *TSFetchResultsReq + func (p *IClientRPCServiceFetchResultsArgs) IsSetReq() bool + func (p *IClientRPCServiceFetchResultsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchResultsArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchResultsArgs) String() string + func (p *IClientRPCServiceFetchResultsArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceFetchResultsResult struct + Success *TSFetchResultsResp + func NewIClientRPCServiceFetchResultsResult() *IClientRPCServiceFetchResultsResult + func (p *IClientRPCServiceFetchResultsResult) GetSuccess() *TSFetchResultsResp + func (p *IClientRPCServiceFetchResultsResult) IsSetSuccess() bool + func (p *IClientRPCServiceFetchResultsResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchResultsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchResultsResult) String() string + func (p *IClientRPCServiceFetchResultsResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceFetchResultsV2Args struct + Req *TSFetchResultsReq + func NewIClientRPCServiceFetchResultsV2Args() *IClientRPCServiceFetchResultsV2Args + func (p *IClientRPCServiceFetchResultsV2Args) GetReq() *TSFetchResultsReq + func (p *IClientRPCServiceFetchResultsV2Args) IsSetReq() bool + func (p *IClientRPCServiceFetchResultsV2Args) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchResultsV2Args) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchResultsV2Args) String() string + func (p *IClientRPCServiceFetchResultsV2Args) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceFetchResultsV2Result struct + Success *TSFetchResultsResp + func NewIClientRPCServiceFetchResultsV2Result() *IClientRPCServiceFetchResultsV2Result + func (p *IClientRPCServiceFetchResultsV2Result) GetSuccess() *TSFetchResultsResp + func (p *IClientRPCServiceFetchResultsV2Result) IsSetSuccess() bool + func (p *IClientRPCServiceFetchResultsV2Result) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchResultsV2Result) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceFetchResultsV2Result) String() string + func (p *IClientRPCServiceFetchResultsV2Result) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceGetBackupConfigurationArgs struct + func NewIClientRPCServiceGetBackupConfigurationArgs() *IClientRPCServiceGetBackupConfigurationArgs + func (p *IClientRPCServiceGetBackupConfigurationArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceGetBackupConfigurationArgs) String() string + func (p *IClientRPCServiceGetBackupConfigurationArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceGetBackupConfigurationResult struct + Success *TSBackupConfigurationResp + func NewIClientRPCServiceGetBackupConfigurationResult() *IClientRPCServiceGetBackupConfigurationResult + func (p *IClientRPCServiceGetBackupConfigurationResult) GetSuccess() *TSBackupConfigurationResp + func (p *IClientRPCServiceGetBackupConfigurationResult) IsSetSuccess() bool + func (p *IClientRPCServiceGetBackupConfigurationResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceGetBackupConfigurationResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceGetBackupConfigurationResult) String() string + func (p *IClientRPCServiceGetBackupConfigurationResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceGetPropertiesArgs struct + func NewIClientRPCServiceGetPropertiesArgs() *IClientRPCServiceGetPropertiesArgs + func (p *IClientRPCServiceGetPropertiesArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceGetPropertiesArgs) String() string + func (p *IClientRPCServiceGetPropertiesArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceGetPropertiesResult struct + Success *ServerProperties + func NewIClientRPCServiceGetPropertiesResult() *IClientRPCServiceGetPropertiesResult + func (p *IClientRPCServiceGetPropertiesResult) GetSuccess() *ServerProperties + func (p *IClientRPCServiceGetPropertiesResult) IsSetSuccess() bool + func (p *IClientRPCServiceGetPropertiesResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceGetPropertiesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceGetPropertiesResult) String() string + func (p *IClientRPCServiceGetPropertiesResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceGetTimeZoneArgs struct + SessionId int64 + func NewIClientRPCServiceGetTimeZoneArgs() *IClientRPCServiceGetTimeZoneArgs + func (p *IClientRPCServiceGetTimeZoneArgs) GetSessionId() int64 + func (p *IClientRPCServiceGetTimeZoneArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceGetTimeZoneArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceGetTimeZoneArgs) String() string + func (p *IClientRPCServiceGetTimeZoneArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceGetTimeZoneResult struct + Success *TSGetTimeZoneResp + func NewIClientRPCServiceGetTimeZoneResult() *IClientRPCServiceGetTimeZoneResult + func (p *IClientRPCServiceGetTimeZoneResult) GetSuccess() *TSGetTimeZoneResp + func (p *IClientRPCServiceGetTimeZoneResult) IsSetSuccess() bool + func (p *IClientRPCServiceGetTimeZoneResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceGetTimeZoneResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceGetTimeZoneResult) String() string + func (p *IClientRPCServiceGetTimeZoneResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceHandshakeArgs struct + Info *TSyncIdentityInfo + func NewIClientRPCServiceHandshakeArgs() *IClientRPCServiceHandshakeArgs + func (p *IClientRPCServiceHandshakeArgs) GetInfo() *TSyncIdentityInfo + func (p *IClientRPCServiceHandshakeArgs) IsSetInfo() bool + func (p *IClientRPCServiceHandshakeArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceHandshakeArgs) ReadField_1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceHandshakeArgs) String() string + func (p *IClientRPCServiceHandshakeArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceHandshakeResult struct + Success *common.TSStatus + func NewIClientRPCServiceHandshakeResult() *IClientRPCServiceHandshakeResult + func (p *IClientRPCServiceHandshakeResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceHandshakeResult) IsSetSuccess() bool + func (p *IClientRPCServiceHandshakeResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceHandshakeResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceHandshakeResult) String() string + func (p *IClientRPCServiceHandshakeResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertRecordArgs struct + Req *TSInsertRecordReq + func NewIClientRPCServiceInsertRecordArgs() *IClientRPCServiceInsertRecordArgs + func (p *IClientRPCServiceInsertRecordArgs) GetReq() *TSInsertRecordReq + func (p *IClientRPCServiceInsertRecordArgs) IsSetReq() bool + func (p *IClientRPCServiceInsertRecordArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertRecordArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertRecordArgs) String() string + func (p *IClientRPCServiceInsertRecordArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertRecordResult struct + Success *common.TSStatus + func NewIClientRPCServiceInsertRecordResult() *IClientRPCServiceInsertRecordResult + func (p *IClientRPCServiceInsertRecordResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceInsertRecordResult) IsSetSuccess() bool + func (p *IClientRPCServiceInsertRecordResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertRecordResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertRecordResult) String() string + func (p *IClientRPCServiceInsertRecordResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertRecordsArgs struct + Req *TSInsertRecordsReq + func NewIClientRPCServiceInsertRecordsArgs() *IClientRPCServiceInsertRecordsArgs + func (p *IClientRPCServiceInsertRecordsArgs) GetReq() *TSInsertRecordsReq + func (p *IClientRPCServiceInsertRecordsArgs) IsSetReq() bool + func (p *IClientRPCServiceInsertRecordsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertRecordsArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertRecordsArgs) String() string + func (p *IClientRPCServiceInsertRecordsArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertRecordsOfOneDeviceArgs struct + Req *TSInsertRecordsOfOneDeviceReq + func NewIClientRPCServiceInsertRecordsOfOneDeviceArgs() *IClientRPCServiceInsertRecordsOfOneDeviceArgs + func (p *IClientRPCServiceInsertRecordsOfOneDeviceArgs) GetReq() *TSInsertRecordsOfOneDeviceReq + func (p *IClientRPCServiceInsertRecordsOfOneDeviceArgs) IsSetReq() bool + func (p *IClientRPCServiceInsertRecordsOfOneDeviceArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertRecordsOfOneDeviceArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertRecordsOfOneDeviceArgs) String() string + func (p *IClientRPCServiceInsertRecordsOfOneDeviceArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertRecordsOfOneDeviceResult struct + Success *common.TSStatus + func NewIClientRPCServiceInsertRecordsOfOneDeviceResult() *IClientRPCServiceInsertRecordsOfOneDeviceResult + func (p *IClientRPCServiceInsertRecordsOfOneDeviceResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceInsertRecordsOfOneDeviceResult) IsSetSuccess() bool + func (p *IClientRPCServiceInsertRecordsOfOneDeviceResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertRecordsOfOneDeviceResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertRecordsOfOneDeviceResult) String() string + func (p *IClientRPCServiceInsertRecordsOfOneDeviceResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertRecordsResult struct + Success *common.TSStatus + func NewIClientRPCServiceInsertRecordsResult() *IClientRPCServiceInsertRecordsResult + func (p *IClientRPCServiceInsertRecordsResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceInsertRecordsResult) IsSetSuccess() bool + func (p *IClientRPCServiceInsertRecordsResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertRecordsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertRecordsResult) String() string + func (p *IClientRPCServiceInsertRecordsResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertStringRecordArgs struct + Req *TSInsertStringRecordReq + func NewIClientRPCServiceInsertStringRecordArgs() *IClientRPCServiceInsertStringRecordArgs + func (p *IClientRPCServiceInsertStringRecordArgs) GetReq() *TSInsertStringRecordReq + func (p *IClientRPCServiceInsertStringRecordArgs) IsSetReq() bool + func (p *IClientRPCServiceInsertStringRecordArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertStringRecordArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertStringRecordArgs) String() string + func (p *IClientRPCServiceInsertStringRecordArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertStringRecordResult struct + Success *common.TSStatus + func NewIClientRPCServiceInsertStringRecordResult() *IClientRPCServiceInsertStringRecordResult + func (p *IClientRPCServiceInsertStringRecordResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceInsertStringRecordResult) IsSetSuccess() bool + func (p *IClientRPCServiceInsertStringRecordResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertStringRecordResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertStringRecordResult) String() string + func (p *IClientRPCServiceInsertStringRecordResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertStringRecordsArgs struct + Req *TSInsertStringRecordsReq + func NewIClientRPCServiceInsertStringRecordsArgs() *IClientRPCServiceInsertStringRecordsArgs + func (p *IClientRPCServiceInsertStringRecordsArgs) GetReq() *TSInsertStringRecordsReq + func (p *IClientRPCServiceInsertStringRecordsArgs) IsSetReq() bool + func (p *IClientRPCServiceInsertStringRecordsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertStringRecordsArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertStringRecordsArgs) String() string + func (p *IClientRPCServiceInsertStringRecordsArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertStringRecordsOfOneDeviceArgs struct + Req *TSInsertStringRecordsOfOneDeviceReq + func NewIClientRPCServiceInsertStringRecordsOfOneDeviceArgs() *IClientRPCServiceInsertStringRecordsOfOneDeviceArgs + func (p *IClientRPCServiceInsertStringRecordsOfOneDeviceArgs) GetReq() *TSInsertStringRecordsOfOneDeviceReq + func (p *IClientRPCServiceInsertStringRecordsOfOneDeviceArgs) IsSetReq() bool + func (p *IClientRPCServiceInsertStringRecordsOfOneDeviceArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertStringRecordsOfOneDeviceArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertStringRecordsOfOneDeviceArgs) String() string + func (p *IClientRPCServiceInsertStringRecordsOfOneDeviceArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertStringRecordsOfOneDeviceResult struct + Success *common.TSStatus + func NewIClientRPCServiceInsertStringRecordsOfOneDeviceResult() *IClientRPCServiceInsertStringRecordsOfOneDeviceResult + func (p *IClientRPCServiceInsertStringRecordsOfOneDeviceResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceInsertStringRecordsOfOneDeviceResult) IsSetSuccess() bool + func (p *IClientRPCServiceInsertStringRecordsOfOneDeviceResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertStringRecordsOfOneDeviceResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertStringRecordsOfOneDeviceResult) String() string + func (p *IClientRPCServiceInsertStringRecordsOfOneDeviceResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertStringRecordsResult struct + Success *common.TSStatus + func NewIClientRPCServiceInsertStringRecordsResult() *IClientRPCServiceInsertStringRecordsResult + func (p *IClientRPCServiceInsertStringRecordsResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceInsertStringRecordsResult) IsSetSuccess() bool + func (p *IClientRPCServiceInsertStringRecordsResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertStringRecordsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertStringRecordsResult) String() string + func (p *IClientRPCServiceInsertStringRecordsResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertTabletArgs struct + Req *TSInsertTabletReq + func NewIClientRPCServiceInsertTabletArgs() *IClientRPCServiceInsertTabletArgs + func (p *IClientRPCServiceInsertTabletArgs) GetReq() *TSInsertTabletReq + func (p *IClientRPCServiceInsertTabletArgs) IsSetReq() bool + func (p *IClientRPCServiceInsertTabletArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertTabletArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertTabletArgs) String() string + func (p *IClientRPCServiceInsertTabletArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertTabletResult struct + Success *common.TSStatus + func NewIClientRPCServiceInsertTabletResult() *IClientRPCServiceInsertTabletResult + func (p *IClientRPCServiceInsertTabletResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceInsertTabletResult) IsSetSuccess() bool + func (p *IClientRPCServiceInsertTabletResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertTabletResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertTabletResult) String() string + func (p *IClientRPCServiceInsertTabletResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertTabletsArgs struct + Req *TSInsertTabletsReq + func NewIClientRPCServiceInsertTabletsArgs() *IClientRPCServiceInsertTabletsArgs + func (p *IClientRPCServiceInsertTabletsArgs) GetReq() *TSInsertTabletsReq + func (p *IClientRPCServiceInsertTabletsArgs) IsSetReq() bool + func (p *IClientRPCServiceInsertTabletsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertTabletsArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertTabletsArgs) String() string + func (p *IClientRPCServiceInsertTabletsArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceInsertTabletsResult struct + Success *common.TSStatus + func NewIClientRPCServiceInsertTabletsResult() *IClientRPCServiceInsertTabletsResult + func (p *IClientRPCServiceInsertTabletsResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceInsertTabletsResult) IsSetSuccess() bool + func (p *IClientRPCServiceInsertTabletsResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertTabletsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceInsertTabletsResult) String() string + func (p *IClientRPCServiceInsertTabletsResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceOpenSessionArgs struct + Req *TSOpenSessionReq + func NewIClientRPCServiceOpenSessionArgs() *IClientRPCServiceOpenSessionArgs + func (p *IClientRPCServiceOpenSessionArgs) GetReq() *TSOpenSessionReq + func (p *IClientRPCServiceOpenSessionArgs) IsSetReq() bool + func (p *IClientRPCServiceOpenSessionArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceOpenSessionArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceOpenSessionArgs) String() string + func (p *IClientRPCServiceOpenSessionArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceOpenSessionResult struct + Success *TSOpenSessionResp + func NewIClientRPCServiceOpenSessionResult() *IClientRPCServiceOpenSessionResult + func (p *IClientRPCServiceOpenSessionResult) GetSuccess() *TSOpenSessionResp + func (p *IClientRPCServiceOpenSessionResult) IsSetSuccess() bool + func (p *IClientRPCServiceOpenSessionResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceOpenSessionResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceOpenSessionResult) String() string + func (p *IClientRPCServiceOpenSessionResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServicePipeSubscribeArgs struct + Req *TPipeSubscribeReq + func NewIClientRPCServicePipeSubscribeArgs() *IClientRPCServicePipeSubscribeArgs + func (p *IClientRPCServicePipeSubscribeArgs) GetReq() *TPipeSubscribeReq + func (p *IClientRPCServicePipeSubscribeArgs) IsSetReq() bool + func (p *IClientRPCServicePipeSubscribeArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePipeSubscribeArgs) ReadField_1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePipeSubscribeArgs) String() string + func (p *IClientRPCServicePipeSubscribeArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServicePipeSubscribeResult struct + Success *TPipeSubscribeResp + func NewIClientRPCServicePipeSubscribeResult() *IClientRPCServicePipeSubscribeResult + func (p *IClientRPCServicePipeSubscribeResult) GetSuccess() *TPipeSubscribeResp + func (p *IClientRPCServicePipeSubscribeResult) IsSetSuccess() bool + func (p *IClientRPCServicePipeSubscribeResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePipeSubscribeResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePipeSubscribeResult) String() string + func (p *IClientRPCServicePipeSubscribeResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServicePipeTransferArgs struct + Req *TPipeTransferReq + func NewIClientRPCServicePipeTransferArgs() *IClientRPCServicePipeTransferArgs + func (p *IClientRPCServicePipeTransferArgs) GetReq() *TPipeTransferReq + func (p *IClientRPCServicePipeTransferArgs) IsSetReq() bool + func (p *IClientRPCServicePipeTransferArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePipeTransferArgs) ReadField_1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePipeTransferArgs) String() string + func (p *IClientRPCServicePipeTransferArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServicePipeTransferResult struct + Success *TPipeTransferResp + func NewIClientRPCServicePipeTransferResult() *IClientRPCServicePipeTransferResult + func (p *IClientRPCServicePipeTransferResult) GetSuccess() *TPipeTransferResp + func (p *IClientRPCServicePipeTransferResult) IsSetSuccess() bool + func (p *IClientRPCServicePipeTransferResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePipeTransferResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePipeTransferResult) String() string + func (p *IClientRPCServicePipeTransferResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServicePrepareStatementArgs struct + Req *TSPrepareReq + func NewIClientRPCServicePrepareStatementArgs() *IClientRPCServicePrepareStatementArgs + func (p *IClientRPCServicePrepareStatementArgs) GetReq() *TSPrepareReq + func (p *IClientRPCServicePrepareStatementArgs) IsSetReq() bool + func (p *IClientRPCServicePrepareStatementArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePrepareStatementArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePrepareStatementArgs) String() string + func (p *IClientRPCServicePrepareStatementArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServicePrepareStatementResult struct + Success *TSPrepareResp + func NewIClientRPCServicePrepareStatementResult() *IClientRPCServicePrepareStatementResult + func (p *IClientRPCServicePrepareStatementResult) GetSuccess() *TSPrepareResp + func (p *IClientRPCServicePrepareStatementResult) IsSetSuccess() bool + func (p *IClientRPCServicePrepareStatementResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePrepareStatementResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePrepareStatementResult) String() string + func (p *IClientRPCServicePrepareStatementResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceProcessor struct + func NewIClientRPCServiceProcessor(handler IClientRPCService) *IClientRPCServiceProcessor + func (p *IClientRPCServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction) + func (p *IClientRPCServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool) + func (p *IClientRPCServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException) + func (p *IClientRPCServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction + type IClientRPCServicePruneSchemaTemplateArgs struct + Req *TSPruneSchemaTemplateReq + func NewIClientRPCServicePruneSchemaTemplateArgs() *IClientRPCServicePruneSchemaTemplateArgs + func (p *IClientRPCServicePruneSchemaTemplateArgs) GetReq() *TSPruneSchemaTemplateReq + func (p *IClientRPCServicePruneSchemaTemplateArgs) IsSetReq() bool + func (p *IClientRPCServicePruneSchemaTemplateArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePruneSchemaTemplateArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePruneSchemaTemplateArgs) String() string + func (p *IClientRPCServicePruneSchemaTemplateArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServicePruneSchemaTemplateResult struct + Success *common.TSStatus + func NewIClientRPCServicePruneSchemaTemplateResult() *IClientRPCServicePruneSchemaTemplateResult + func (p *IClientRPCServicePruneSchemaTemplateResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServicePruneSchemaTemplateResult) IsSetSuccess() bool + func (p *IClientRPCServicePruneSchemaTemplateResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePruneSchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServicePruneSchemaTemplateResult) String() string + func (p *IClientRPCServicePruneSchemaTemplateResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceQuerySchemaTemplateArgs struct + Req *TSQueryTemplateReq + func NewIClientRPCServiceQuerySchemaTemplateArgs() *IClientRPCServiceQuerySchemaTemplateArgs + func (p *IClientRPCServiceQuerySchemaTemplateArgs) GetReq() *TSQueryTemplateReq + func (p *IClientRPCServiceQuerySchemaTemplateArgs) IsSetReq() bool + func (p *IClientRPCServiceQuerySchemaTemplateArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceQuerySchemaTemplateArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceQuerySchemaTemplateArgs) String() string + func (p *IClientRPCServiceQuerySchemaTemplateArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceQuerySchemaTemplateResult struct + Success *TSQueryTemplateResp + func NewIClientRPCServiceQuerySchemaTemplateResult() *IClientRPCServiceQuerySchemaTemplateResult + func (p *IClientRPCServiceQuerySchemaTemplateResult) GetSuccess() *TSQueryTemplateResp + func (p *IClientRPCServiceQuerySchemaTemplateResult) IsSetSuccess() bool + func (p *IClientRPCServiceQuerySchemaTemplateResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceQuerySchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceQuerySchemaTemplateResult) String() string + func (p *IClientRPCServiceQuerySchemaTemplateResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceRequestStatementIdArgs struct + SessionId int64 + func NewIClientRPCServiceRequestStatementIdArgs() *IClientRPCServiceRequestStatementIdArgs + func (p *IClientRPCServiceRequestStatementIdArgs) GetSessionId() int64 + func (p *IClientRPCServiceRequestStatementIdArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceRequestStatementIdArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceRequestStatementIdArgs) String() string + func (p *IClientRPCServiceRequestStatementIdArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceRequestStatementIdResult struct + Success *int64 + func NewIClientRPCServiceRequestStatementIdResult() *IClientRPCServiceRequestStatementIdResult + func (p *IClientRPCServiceRequestStatementIdResult) GetSuccess() int64 + func (p *IClientRPCServiceRequestStatementIdResult) IsSetSuccess() bool + func (p *IClientRPCServiceRequestStatementIdResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceRequestStatementIdResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceRequestStatementIdResult) String() string + func (p *IClientRPCServiceRequestStatementIdResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceSendFileArgs struct + Buff []byte + MetaInfo *TSyncTransportMetaInfo + func NewIClientRPCServiceSendFileArgs() *IClientRPCServiceSendFileArgs + func (p *IClientRPCServiceSendFileArgs) GetBuff() []byte + func (p *IClientRPCServiceSendFileArgs) GetMetaInfo() *TSyncTransportMetaInfo + func (p *IClientRPCServiceSendFileArgs) IsSetMetaInfo() bool + func (p *IClientRPCServiceSendFileArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSendFileArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSendFileArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSendFileArgs) String() string + func (p *IClientRPCServiceSendFileArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceSendFileResult struct + Success *common.TSStatus + func NewIClientRPCServiceSendFileResult() *IClientRPCServiceSendFileResult + func (p *IClientRPCServiceSendFileResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceSendFileResult) IsSetSuccess() bool + func (p *IClientRPCServiceSendFileResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSendFileResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSendFileResult) String() string + func (p *IClientRPCServiceSendFileResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceSendPipeDataArgs struct + Buff []byte + func NewIClientRPCServiceSendPipeDataArgs() *IClientRPCServiceSendPipeDataArgs + func (p *IClientRPCServiceSendPipeDataArgs) GetBuff() []byte + func (p *IClientRPCServiceSendPipeDataArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSendPipeDataArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSendPipeDataArgs) String() string + func (p *IClientRPCServiceSendPipeDataArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceSendPipeDataResult struct + Success *common.TSStatus + func NewIClientRPCServiceSendPipeDataResult() *IClientRPCServiceSendPipeDataResult + func (p *IClientRPCServiceSendPipeDataResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceSendPipeDataResult) IsSetSuccess() bool + func (p *IClientRPCServiceSendPipeDataResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSendPipeDataResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSendPipeDataResult) String() string + func (p *IClientRPCServiceSendPipeDataResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceSetSchemaTemplateArgs struct + Req *TSSetSchemaTemplateReq + func NewIClientRPCServiceSetSchemaTemplateArgs() *IClientRPCServiceSetSchemaTemplateArgs + func (p *IClientRPCServiceSetSchemaTemplateArgs) GetReq() *TSSetSchemaTemplateReq + func (p *IClientRPCServiceSetSchemaTemplateArgs) IsSetReq() bool + func (p *IClientRPCServiceSetSchemaTemplateArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSetSchemaTemplateArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSetSchemaTemplateArgs) String() string + func (p *IClientRPCServiceSetSchemaTemplateArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceSetSchemaTemplateResult struct + Success *common.TSStatus + func NewIClientRPCServiceSetSchemaTemplateResult() *IClientRPCServiceSetSchemaTemplateResult + func (p *IClientRPCServiceSetSchemaTemplateResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceSetSchemaTemplateResult) IsSetSuccess() bool + func (p *IClientRPCServiceSetSchemaTemplateResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSetSchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSetSchemaTemplateResult) String() string + func (p *IClientRPCServiceSetSchemaTemplateResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceSetStorageGroupArgs struct + SessionId int64 + StorageGroup string + func NewIClientRPCServiceSetStorageGroupArgs() *IClientRPCServiceSetStorageGroupArgs + func (p *IClientRPCServiceSetStorageGroupArgs) GetSessionId() int64 + func (p *IClientRPCServiceSetStorageGroupArgs) GetStorageGroup() string + func (p *IClientRPCServiceSetStorageGroupArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSetStorageGroupArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSetStorageGroupArgs) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSetStorageGroupArgs) String() string + func (p *IClientRPCServiceSetStorageGroupArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceSetStorageGroupResult struct + Success *common.TSStatus + func NewIClientRPCServiceSetStorageGroupResult() *IClientRPCServiceSetStorageGroupResult + func (p *IClientRPCServiceSetStorageGroupResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceSetStorageGroupResult) IsSetSuccess() bool + func (p *IClientRPCServiceSetStorageGroupResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSetStorageGroupResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSetStorageGroupResult) String() string + func (p *IClientRPCServiceSetStorageGroupResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceSetTimeZoneArgs struct + Req *TSSetTimeZoneReq + func NewIClientRPCServiceSetTimeZoneArgs() *IClientRPCServiceSetTimeZoneArgs + func (p *IClientRPCServiceSetTimeZoneArgs) GetReq() *TSSetTimeZoneReq + func (p *IClientRPCServiceSetTimeZoneArgs) IsSetReq() bool + func (p *IClientRPCServiceSetTimeZoneArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSetTimeZoneArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSetTimeZoneArgs) String() string + func (p *IClientRPCServiceSetTimeZoneArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceSetTimeZoneResult struct + Success *common.TSStatus + func NewIClientRPCServiceSetTimeZoneResult() *IClientRPCServiceSetTimeZoneResult + func (p *IClientRPCServiceSetTimeZoneResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceSetTimeZoneResult) IsSetSuccess() bool + func (p *IClientRPCServiceSetTimeZoneResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSetTimeZoneResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceSetTimeZoneResult) String() string + func (p *IClientRPCServiceSetTimeZoneResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceShowConfigurationArgs struct + NodeId int32 + func NewIClientRPCServiceShowConfigurationArgs() *IClientRPCServiceShowConfigurationArgs + func (p *IClientRPCServiceShowConfigurationArgs) GetNodeId() int32 + func (p *IClientRPCServiceShowConfigurationArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceShowConfigurationArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceShowConfigurationArgs) String() string + func (p *IClientRPCServiceShowConfigurationArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceShowConfigurationResult struct + Success *common.TShowConfigurationResp + func NewIClientRPCServiceShowConfigurationResult() *IClientRPCServiceShowConfigurationResult + func (p *IClientRPCServiceShowConfigurationResult) GetSuccess() *common.TShowConfigurationResp + func (p *IClientRPCServiceShowConfigurationResult) IsSetSuccess() bool + func (p *IClientRPCServiceShowConfigurationResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceShowConfigurationResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceShowConfigurationResult) String() string + func (p *IClientRPCServiceShowConfigurationResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceShowConfigurationTemplateArgs struct + func NewIClientRPCServiceShowConfigurationTemplateArgs() *IClientRPCServiceShowConfigurationTemplateArgs + func (p *IClientRPCServiceShowConfigurationTemplateArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceShowConfigurationTemplateArgs) String() string + func (p *IClientRPCServiceShowConfigurationTemplateArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceShowConfigurationTemplateResult struct + Success *common.TShowConfigurationTemplateResp + func NewIClientRPCServiceShowConfigurationTemplateResult() *IClientRPCServiceShowConfigurationTemplateResult + func (p *IClientRPCServiceShowConfigurationTemplateResult) GetSuccess() *common.TShowConfigurationTemplateResp + func (p *IClientRPCServiceShowConfigurationTemplateResult) IsSetSuccess() bool + func (p *IClientRPCServiceShowConfigurationTemplateResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceShowConfigurationTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceShowConfigurationTemplateResult) String() string + func (p *IClientRPCServiceShowConfigurationTemplateResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestConnectionEmptyRPCArgs struct + func NewIClientRPCServiceTestConnectionEmptyRPCArgs() *IClientRPCServiceTestConnectionEmptyRPCArgs + func (p *IClientRPCServiceTestConnectionEmptyRPCArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestConnectionEmptyRPCArgs) String() string + func (p *IClientRPCServiceTestConnectionEmptyRPCArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestConnectionEmptyRPCResult struct + Success *common.TSStatus + func NewIClientRPCServiceTestConnectionEmptyRPCResult() *IClientRPCServiceTestConnectionEmptyRPCResult + func (p *IClientRPCServiceTestConnectionEmptyRPCResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceTestConnectionEmptyRPCResult) IsSetSuccess() bool + func (p *IClientRPCServiceTestConnectionEmptyRPCResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestConnectionEmptyRPCResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestConnectionEmptyRPCResult) String() string + func (p *IClientRPCServiceTestConnectionEmptyRPCResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestInsertRecordArgs struct + Req *TSInsertRecordReq + func NewIClientRPCServiceTestInsertRecordArgs() *IClientRPCServiceTestInsertRecordArgs + func (p *IClientRPCServiceTestInsertRecordArgs) GetReq() *TSInsertRecordReq + func (p *IClientRPCServiceTestInsertRecordArgs) IsSetReq() bool + func (p *IClientRPCServiceTestInsertRecordArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertRecordArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertRecordArgs) String() string + func (p *IClientRPCServiceTestInsertRecordArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestInsertRecordResult struct + Success *common.TSStatus + func NewIClientRPCServiceTestInsertRecordResult() *IClientRPCServiceTestInsertRecordResult + func (p *IClientRPCServiceTestInsertRecordResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceTestInsertRecordResult) IsSetSuccess() bool + func (p *IClientRPCServiceTestInsertRecordResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertRecordResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertRecordResult) String() string + func (p *IClientRPCServiceTestInsertRecordResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestInsertRecordsArgs struct + Req *TSInsertRecordsReq + func NewIClientRPCServiceTestInsertRecordsArgs() *IClientRPCServiceTestInsertRecordsArgs + func (p *IClientRPCServiceTestInsertRecordsArgs) GetReq() *TSInsertRecordsReq + func (p *IClientRPCServiceTestInsertRecordsArgs) IsSetReq() bool + func (p *IClientRPCServiceTestInsertRecordsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertRecordsArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertRecordsArgs) String() string + func (p *IClientRPCServiceTestInsertRecordsArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestInsertRecordsOfOneDeviceArgs struct + Req *TSInsertRecordsOfOneDeviceReq + func NewIClientRPCServiceTestInsertRecordsOfOneDeviceArgs() *IClientRPCServiceTestInsertRecordsOfOneDeviceArgs + func (p *IClientRPCServiceTestInsertRecordsOfOneDeviceArgs) GetReq() *TSInsertRecordsOfOneDeviceReq + func (p *IClientRPCServiceTestInsertRecordsOfOneDeviceArgs) IsSetReq() bool + func (p *IClientRPCServiceTestInsertRecordsOfOneDeviceArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertRecordsOfOneDeviceArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertRecordsOfOneDeviceArgs) String() string + func (p *IClientRPCServiceTestInsertRecordsOfOneDeviceArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestInsertRecordsOfOneDeviceResult struct + Success *common.TSStatus + func NewIClientRPCServiceTestInsertRecordsOfOneDeviceResult() *IClientRPCServiceTestInsertRecordsOfOneDeviceResult + func (p *IClientRPCServiceTestInsertRecordsOfOneDeviceResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceTestInsertRecordsOfOneDeviceResult) IsSetSuccess() bool + func (p *IClientRPCServiceTestInsertRecordsOfOneDeviceResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertRecordsOfOneDeviceResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertRecordsOfOneDeviceResult) String() string + func (p *IClientRPCServiceTestInsertRecordsOfOneDeviceResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestInsertRecordsResult struct + Success *common.TSStatus + func NewIClientRPCServiceTestInsertRecordsResult() *IClientRPCServiceTestInsertRecordsResult + func (p *IClientRPCServiceTestInsertRecordsResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceTestInsertRecordsResult) IsSetSuccess() bool + func (p *IClientRPCServiceTestInsertRecordsResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertRecordsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertRecordsResult) String() string + func (p *IClientRPCServiceTestInsertRecordsResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestInsertStringRecordArgs struct + Req *TSInsertStringRecordReq + func NewIClientRPCServiceTestInsertStringRecordArgs() *IClientRPCServiceTestInsertStringRecordArgs + func (p *IClientRPCServiceTestInsertStringRecordArgs) GetReq() *TSInsertStringRecordReq + func (p *IClientRPCServiceTestInsertStringRecordArgs) IsSetReq() bool + func (p *IClientRPCServiceTestInsertStringRecordArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertStringRecordArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertStringRecordArgs) String() string + func (p *IClientRPCServiceTestInsertStringRecordArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestInsertStringRecordResult struct + Success *common.TSStatus + func NewIClientRPCServiceTestInsertStringRecordResult() *IClientRPCServiceTestInsertStringRecordResult + func (p *IClientRPCServiceTestInsertStringRecordResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceTestInsertStringRecordResult) IsSetSuccess() bool + func (p *IClientRPCServiceTestInsertStringRecordResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertStringRecordResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertStringRecordResult) String() string + func (p *IClientRPCServiceTestInsertStringRecordResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestInsertStringRecordsArgs struct + Req *TSInsertStringRecordsReq + func NewIClientRPCServiceTestInsertStringRecordsArgs() *IClientRPCServiceTestInsertStringRecordsArgs + func (p *IClientRPCServiceTestInsertStringRecordsArgs) GetReq() *TSInsertStringRecordsReq + func (p *IClientRPCServiceTestInsertStringRecordsArgs) IsSetReq() bool + func (p *IClientRPCServiceTestInsertStringRecordsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertStringRecordsArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertStringRecordsArgs) String() string + func (p *IClientRPCServiceTestInsertStringRecordsArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestInsertStringRecordsResult struct + Success *common.TSStatus + func NewIClientRPCServiceTestInsertStringRecordsResult() *IClientRPCServiceTestInsertStringRecordsResult + func (p *IClientRPCServiceTestInsertStringRecordsResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceTestInsertStringRecordsResult) IsSetSuccess() bool + func (p *IClientRPCServiceTestInsertStringRecordsResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertStringRecordsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertStringRecordsResult) String() string + func (p *IClientRPCServiceTestInsertStringRecordsResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestInsertTabletArgs struct + Req *TSInsertTabletReq + func NewIClientRPCServiceTestInsertTabletArgs() *IClientRPCServiceTestInsertTabletArgs + func (p *IClientRPCServiceTestInsertTabletArgs) GetReq() *TSInsertTabletReq + func (p *IClientRPCServiceTestInsertTabletArgs) IsSetReq() bool + func (p *IClientRPCServiceTestInsertTabletArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertTabletArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertTabletArgs) String() string + func (p *IClientRPCServiceTestInsertTabletArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestInsertTabletResult struct + Success *common.TSStatus + func NewIClientRPCServiceTestInsertTabletResult() *IClientRPCServiceTestInsertTabletResult + func (p *IClientRPCServiceTestInsertTabletResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceTestInsertTabletResult) IsSetSuccess() bool + func (p *IClientRPCServiceTestInsertTabletResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertTabletResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertTabletResult) String() string + func (p *IClientRPCServiceTestInsertTabletResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestInsertTabletsArgs struct + Req *TSInsertTabletsReq + func NewIClientRPCServiceTestInsertTabletsArgs() *IClientRPCServiceTestInsertTabletsArgs + func (p *IClientRPCServiceTestInsertTabletsArgs) GetReq() *TSInsertTabletsReq + func (p *IClientRPCServiceTestInsertTabletsArgs) IsSetReq() bool + func (p *IClientRPCServiceTestInsertTabletsArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertTabletsArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertTabletsArgs) String() string + func (p *IClientRPCServiceTestInsertTabletsArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceTestInsertTabletsResult struct + Success *common.TSStatus + func NewIClientRPCServiceTestInsertTabletsResult() *IClientRPCServiceTestInsertTabletsResult + func (p *IClientRPCServiceTestInsertTabletsResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceTestInsertTabletsResult) IsSetSuccess() bool + func (p *IClientRPCServiceTestInsertTabletsResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertTabletsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceTestInsertTabletsResult) String() string + func (p *IClientRPCServiceTestInsertTabletsResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceUnsetSchemaTemplateArgs struct + Req *TSUnsetSchemaTemplateReq + func NewIClientRPCServiceUnsetSchemaTemplateArgs() *IClientRPCServiceUnsetSchemaTemplateArgs + func (p *IClientRPCServiceUnsetSchemaTemplateArgs) GetReq() *TSUnsetSchemaTemplateReq + func (p *IClientRPCServiceUnsetSchemaTemplateArgs) IsSetReq() bool + func (p *IClientRPCServiceUnsetSchemaTemplateArgs) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceUnsetSchemaTemplateArgs) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceUnsetSchemaTemplateArgs) String() string + func (p *IClientRPCServiceUnsetSchemaTemplateArgs) Write(ctx context.Context, oprot thrift.TProtocol) error + type IClientRPCServiceUnsetSchemaTemplateResult struct + Success *common.TSStatus + func NewIClientRPCServiceUnsetSchemaTemplateResult() *IClientRPCServiceUnsetSchemaTemplateResult + func (p *IClientRPCServiceUnsetSchemaTemplateResult) GetSuccess() *common.TSStatus + func (p *IClientRPCServiceUnsetSchemaTemplateResult) IsSetSuccess() bool + func (p *IClientRPCServiceUnsetSchemaTemplateResult) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceUnsetSchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error + func (p *IClientRPCServiceUnsetSchemaTemplateResult) String() string + func (p *IClientRPCServiceUnsetSchemaTemplateResult) Write(ctx context.Context, oprot thrift.TProtocol) error + type ServerProperties struct + BuildInfo *string + IsReadOnly *bool + Logo *string + MaxConcurrentClientNum int32 + SupportedTimeAggregationOperations []string + ThriftMaxFrameSize *int32 + TimestampPrecision string + Version string + var IClientRPCServiceGetPropertiesResult_Success_DEFAULT *ServerProperties + func NewServerProperties() *ServerProperties + func (p *ServerProperties) Equals(other *ServerProperties) bool + func (p *ServerProperties) GetBuildInfo() string + func (p *ServerProperties) GetIsReadOnly() bool + func (p *ServerProperties) GetLogo() string + func (p *ServerProperties) GetMaxConcurrentClientNum() int32 + func (p *ServerProperties) GetSupportedTimeAggregationOperations() []string + func (p *ServerProperties) GetThriftMaxFrameSize() int32 + func (p *ServerProperties) GetTimestampPrecision() string + func (p *ServerProperties) GetVersion() string + func (p *ServerProperties) IsSetBuildInfo() bool + func (p *ServerProperties) IsSetIsReadOnly() bool + func (p *ServerProperties) IsSetLogo() bool + func (p *ServerProperties) IsSetThriftMaxFrameSize() bool + func (p *ServerProperties) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *ServerProperties) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *ServerProperties) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *ServerProperties) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *ServerProperties) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *ServerProperties) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *ServerProperties) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *ServerProperties) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *ServerProperties) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *ServerProperties) String() string + func (p *ServerProperties) Write(ctx context.Context, oprot thrift.TProtocol) error + type TCreateTimeseriesUsingSchemaTemplateReq struct + DevicePathList []string + SessionId int64 + var IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs_Req_DEFAULT *TCreateTimeseriesUsingSchemaTemplateReq + func NewTCreateTimeseriesUsingSchemaTemplateReq() *TCreateTimeseriesUsingSchemaTemplateReq + func (p *TCreateTimeseriesUsingSchemaTemplateReq) Equals(other *TCreateTimeseriesUsingSchemaTemplateReq) bool + func (p *TCreateTimeseriesUsingSchemaTemplateReq) GetDevicePathList() []string + func (p *TCreateTimeseriesUsingSchemaTemplateReq) GetSessionId() int64 + func (p *TCreateTimeseriesUsingSchemaTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TCreateTimeseriesUsingSchemaTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TCreateTimeseriesUsingSchemaTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TCreateTimeseriesUsingSchemaTemplateReq) String() string + func (p *TCreateTimeseriesUsingSchemaTemplateReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TPipeSubscribeReq struct + Body []byte + Type int16 + Version int8 + var IClientRPCServicePipeSubscribeArgs_Req_DEFAULT *TPipeSubscribeReq + func NewTPipeSubscribeReq() *TPipeSubscribeReq + func (p *TPipeSubscribeReq) Equals(other *TPipeSubscribeReq) bool + func (p *TPipeSubscribeReq) GetBody() []byte + func (p *TPipeSubscribeReq) GetType() int16 + func (p *TPipeSubscribeReq) GetVersion() int8 + func (p *TPipeSubscribeReq) IsSetBody() bool + func (p *TPipeSubscribeReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeSubscribeReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeSubscribeReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeSubscribeReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeSubscribeReq) String() string + func (p *TPipeSubscribeReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TPipeSubscribeResp struct + Body [][]byte + Status *common.TSStatus + Type int16 + Version int8 + var IClientRPCServicePipeSubscribeResult_Success_DEFAULT *TPipeSubscribeResp + func NewTPipeSubscribeResp() *TPipeSubscribeResp + func (p *TPipeSubscribeResp) Equals(other *TPipeSubscribeResp) bool + func (p *TPipeSubscribeResp) GetBody() [][]byte + func (p *TPipeSubscribeResp) GetStatus() *common.TSStatus + func (p *TPipeSubscribeResp) GetType() int16 + func (p *TPipeSubscribeResp) GetVersion() int8 + func (p *TPipeSubscribeResp) IsSetBody() bool + func (p *TPipeSubscribeResp) IsSetStatus() bool + func (p *TPipeSubscribeResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeSubscribeResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeSubscribeResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeSubscribeResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeSubscribeResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeSubscribeResp) String() string + func (p *TPipeSubscribeResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TPipeTransferReq struct + Body []byte + Type int16 + Version int8 + var IClientRPCServicePipeTransferArgs_Req_DEFAULT *TPipeTransferReq + func NewTPipeTransferReq() *TPipeTransferReq + func (p *TPipeTransferReq) Equals(other *TPipeTransferReq) bool + func (p *TPipeTransferReq) GetBody() []byte + func (p *TPipeTransferReq) GetType() int16 + func (p *TPipeTransferReq) GetVersion() int8 + func (p *TPipeTransferReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeTransferReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeTransferReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeTransferReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeTransferReq) String() string + func (p *TPipeTransferReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TPipeTransferResp struct + Body []byte + Status *common.TSStatus + var IClientRPCServicePipeTransferResult_Success_DEFAULT *TPipeTransferResp + func NewTPipeTransferResp() *TPipeTransferResp + func (p *TPipeTransferResp) Equals(other *TPipeTransferResp) bool + func (p *TPipeTransferResp) GetBody() []byte + func (p *TPipeTransferResp) GetStatus() *common.TSStatus + func (p *TPipeTransferResp) IsSetBody() bool + func (p *TPipeTransferResp) IsSetStatus() bool + func (p *TPipeTransferResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeTransferResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeTransferResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TPipeTransferResp) String() string + func (p *TPipeTransferResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSAggregationQueryReq struct + Aggregations []common.TAggregationType + EndTime *int64 + FetchSize *int32 + Interval *int64 + LegalPathNodes *bool + Paths []string + SessionId int64 + SlidingStep *int64 + StartTime *int64 + StatementId int64 + Timeout *int64 + var IClientRPCServiceExecuteAggregationQueryArgs_Req_DEFAULT *TSAggregationQueryReq + var IClientRPCServiceExecuteAggregationQueryV2Args_Req_DEFAULT *TSAggregationQueryReq + func NewTSAggregationQueryReq() *TSAggregationQueryReq + func (p *TSAggregationQueryReq) Equals(other *TSAggregationQueryReq) bool + func (p *TSAggregationQueryReq) GetAggregations() []common.TAggregationType + func (p *TSAggregationQueryReq) GetEndTime() int64 + func (p *TSAggregationQueryReq) GetFetchSize() int32 + func (p *TSAggregationQueryReq) GetInterval() int64 + func (p *TSAggregationQueryReq) GetLegalPathNodes() bool + func (p *TSAggregationQueryReq) GetPaths() []string + func (p *TSAggregationQueryReq) GetSessionId() int64 + func (p *TSAggregationQueryReq) GetSlidingStep() int64 + func (p *TSAggregationQueryReq) GetStartTime() int64 + func (p *TSAggregationQueryReq) GetStatementId() int64 + func (p *TSAggregationQueryReq) GetTimeout() int64 + func (p *TSAggregationQueryReq) IsSetEndTime() bool + func (p *TSAggregationQueryReq) IsSetFetchSize() bool + func (p *TSAggregationQueryReq) IsSetInterval() bool + func (p *TSAggregationQueryReq) IsSetLegalPathNodes() bool + func (p *TSAggregationQueryReq) IsSetSlidingStep() bool + func (p *TSAggregationQueryReq) IsSetStartTime() bool + func (p *TSAggregationQueryReq) IsSetTimeout() bool + func (p *TSAggregationQueryReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAggregationQueryReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAggregationQueryReq) ReadField10(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAggregationQueryReq) ReadField11(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAggregationQueryReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAggregationQueryReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAggregationQueryReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAggregationQueryReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAggregationQueryReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAggregationQueryReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAggregationQueryReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAggregationQueryReq) ReadField9(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAggregationQueryReq) String() string + func (p *TSAggregationQueryReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSAppendSchemaTemplateReq struct + Compressors []int32 + DataTypes []int32 + Encodings []int32 + IsAligned bool + Measurements []string + Name string + SessionId int64 + var IClientRPCServiceAppendSchemaTemplateArgs_Req_DEFAULT *TSAppendSchemaTemplateReq + func NewTSAppendSchemaTemplateReq() *TSAppendSchemaTemplateReq + func (p *TSAppendSchemaTemplateReq) Equals(other *TSAppendSchemaTemplateReq) bool + func (p *TSAppendSchemaTemplateReq) GetCompressors() []int32 + func (p *TSAppendSchemaTemplateReq) GetDataTypes() []int32 + func (p *TSAppendSchemaTemplateReq) GetEncodings() []int32 + func (p *TSAppendSchemaTemplateReq) GetIsAligned() bool + func (p *TSAppendSchemaTemplateReq) GetMeasurements() []string + func (p *TSAppendSchemaTemplateReq) GetName() string + func (p *TSAppendSchemaTemplateReq) GetSessionId() int64 + func (p *TSAppendSchemaTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAppendSchemaTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAppendSchemaTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAppendSchemaTemplateReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAppendSchemaTemplateReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAppendSchemaTemplateReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAppendSchemaTemplateReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAppendSchemaTemplateReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSAppendSchemaTemplateReq) String() string + func (p *TSAppendSchemaTemplateReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSBackupConfigurationResp struct + EnableOperationSync *bool + SecondaryAddress *string + SecondaryPort *int32 + Status *common.TSStatus + var IClientRPCServiceGetBackupConfigurationResult_Success_DEFAULT *TSBackupConfigurationResp + func NewTSBackupConfigurationResp() *TSBackupConfigurationResp + func (p *TSBackupConfigurationResp) Equals(other *TSBackupConfigurationResp) bool + func (p *TSBackupConfigurationResp) GetEnableOperationSync() bool + func (p *TSBackupConfigurationResp) GetSecondaryAddress() string + func (p *TSBackupConfigurationResp) GetSecondaryPort() int32 + func (p *TSBackupConfigurationResp) GetStatus() *common.TSStatus + func (p *TSBackupConfigurationResp) IsSetEnableOperationSync() bool + func (p *TSBackupConfigurationResp) IsSetSecondaryAddress() bool + func (p *TSBackupConfigurationResp) IsSetSecondaryPort() bool + func (p *TSBackupConfigurationResp) IsSetStatus() bool + func (p *TSBackupConfigurationResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSBackupConfigurationResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSBackupConfigurationResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSBackupConfigurationResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSBackupConfigurationResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSBackupConfigurationResp) String() string + func (p *TSBackupConfigurationResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSCancelOperationReq struct + QueryId int64 + SessionId int64 + var IClientRPCServiceCancelOperationArgs_Req_DEFAULT *TSCancelOperationReq + func NewTSCancelOperationReq() *TSCancelOperationReq + func (p *TSCancelOperationReq) Equals(other *TSCancelOperationReq) bool + func (p *TSCancelOperationReq) GetQueryId() int64 + func (p *TSCancelOperationReq) GetSessionId() int64 + func (p *TSCancelOperationReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCancelOperationReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCancelOperationReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCancelOperationReq) String() string + func (p *TSCancelOperationReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSCloseOperationReq struct + PreparedStatementName *string + QueryId *int64 + SessionId int64 + StatementId *int64 + var IClientRPCServiceCloseOperationArgs_Req_DEFAULT *TSCloseOperationReq + func NewTSCloseOperationReq() *TSCloseOperationReq + func (p *TSCloseOperationReq) Equals(other *TSCloseOperationReq) bool + func (p *TSCloseOperationReq) GetPreparedStatementName() string + func (p *TSCloseOperationReq) GetQueryId() int64 + func (p *TSCloseOperationReq) GetSessionId() int64 + func (p *TSCloseOperationReq) GetStatementId() int64 + func (p *TSCloseOperationReq) IsSetPreparedStatementName() bool + func (p *TSCloseOperationReq) IsSetQueryId() bool + func (p *TSCloseOperationReq) IsSetStatementId() bool + func (p *TSCloseOperationReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCloseOperationReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCloseOperationReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCloseOperationReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCloseOperationReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCloseOperationReq) String() string + func (p *TSCloseOperationReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSCloseSessionReq struct + SessionId int64 + var IClientRPCServiceCloseSessionArgs_Req_DEFAULT *TSCloseSessionReq + func NewTSCloseSessionReq() *TSCloseSessionReq + func (p *TSCloseSessionReq) Equals(other *TSCloseSessionReq) bool + func (p *TSCloseSessionReq) GetSessionId() int64 + func (p *TSCloseSessionReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCloseSessionReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCloseSessionReq) String() string + func (p *TSCloseSessionReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSConnectionInfo struct + ConnectionId string + LogInTime int64 + Type TSConnectionType + UserName string + func NewTSConnectionInfo() *TSConnectionInfo + func (p *TSConnectionInfo) Equals(other *TSConnectionInfo) bool + func (p *TSConnectionInfo) GetConnectionId() string + func (p *TSConnectionInfo) GetLogInTime() int64 + func (p *TSConnectionInfo) GetType() TSConnectionType + func (p *TSConnectionInfo) GetUserName() string + func (p *TSConnectionInfo) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSConnectionInfo) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSConnectionInfo) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSConnectionInfo) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSConnectionInfo) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSConnectionInfo) String() string + func (p *TSConnectionInfo) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSConnectionInfoResp struct + ConnectionInfoList []*TSConnectionInfo + var IClientRPCServiceFetchAllConnectionsInfoResult_Success_DEFAULT *TSConnectionInfoResp + func NewTSConnectionInfoResp() *TSConnectionInfoResp + func (p *TSConnectionInfoResp) Equals(other *TSConnectionInfoResp) bool + func (p *TSConnectionInfoResp) GetConnectionInfoList() []*TSConnectionInfo + func (p *TSConnectionInfoResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSConnectionInfoResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSConnectionInfoResp) String() string + func (p *TSConnectionInfoResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSConnectionType int64 + const TSConnectionType_INTERNAL + const TSConnectionType_MQTT_BASED + const TSConnectionType_REST_BASED + const TSConnectionType_THRIFT_BASED + func TSConnectionTypeFromString(s string) (TSConnectionType, error) + func TSConnectionTypePtr(v TSConnectionType) *TSConnectionType + func (p *TSConnectionType) Scan(value interface{}) error + func (p *TSConnectionType) UnmarshalText(text []byte) error + func (p *TSConnectionType) Value() (driver.Value, error) + func (p TSConnectionType) MarshalText() ([]byte, error) + func (p TSConnectionType) String() string + type TSCreateAlignedTimeseriesReq struct + AttributesList []map[string]string + Compressors []int32 + DataTypes []int32 + Encodings []int32 + MeasurementAlias []string + Measurements []string + PrefixPath string + SessionId int64 + TagsList []map[string]string + var IClientRPCServiceCreateAlignedTimeseriesArgs_Req_DEFAULT *TSCreateAlignedTimeseriesReq + func NewTSCreateAlignedTimeseriesReq() *TSCreateAlignedTimeseriesReq + func (p *TSCreateAlignedTimeseriesReq) Equals(other *TSCreateAlignedTimeseriesReq) bool + func (p *TSCreateAlignedTimeseriesReq) GetAttributesList() []map[string]string + func (p *TSCreateAlignedTimeseriesReq) GetCompressors() []int32 + func (p *TSCreateAlignedTimeseriesReq) GetDataTypes() []int32 + func (p *TSCreateAlignedTimeseriesReq) GetEncodings() []int32 + func (p *TSCreateAlignedTimeseriesReq) GetMeasurementAlias() []string + func (p *TSCreateAlignedTimeseriesReq) GetMeasurements() []string + func (p *TSCreateAlignedTimeseriesReq) GetPrefixPath() string + func (p *TSCreateAlignedTimeseriesReq) GetSessionId() int64 + func (p *TSCreateAlignedTimeseriesReq) GetTagsList() []map[string]string + func (p *TSCreateAlignedTimeseriesReq) IsSetAttributesList() bool + func (p *TSCreateAlignedTimeseriesReq) IsSetMeasurementAlias() bool + func (p *TSCreateAlignedTimeseriesReq) IsSetTagsList() bool + func (p *TSCreateAlignedTimeseriesReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateAlignedTimeseriesReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateAlignedTimeseriesReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateAlignedTimeseriesReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateAlignedTimeseriesReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateAlignedTimeseriesReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateAlignedTimeseriesReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateAlignedTimeseriesReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateAlignedTimeseriesReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateAlignedTimeseriesReq) ReadField9(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateAlignedTimeseriesReq) String() string + func (p *TSCreateAlignedTimeseriesReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSCreateMultiTimeseriesReq struct + AttributesList []map[string]string + Compressors []int32 + DataTypes []int32 + Encodings []int32 + MeasurementAliasList []string + Paths []string + PropsList []map[string]string + SessionId int64 + TagsList []map[string]string + var IClientRPCServiceCreateMultiTimeseriesArgs_Req_DEFAULT *TSCreateMultiTimeseriesReq + func NewTSCreateMultiTimeseriesReq() *TSCreateMultiTimeseriesReq + func (p *TSCreateMultiTimeseriesReq) Equals(other *TSCreateMultiTimeseriesReq) bool + func (p *TSCreateMultiTimeseriesReq) GetAttributesList() []map[string]string + func (p *TSCreateMultiTimeseriesReq) GetCompressors() []int32 + func (p *TSCreateMultiTimeseriesReq) GetDataTypes() []int32 + func (p *TSCreateMultiTimeseriesReq) GetEncodings() []int32 + func (p *TSCreateMultiTimeseriesReq) GetMeasurementAliasList() []string + func (p *TSCreateMultiTimeseriesReq) GetPaths() []string + func (p *TSCreateMultiTimeseriesReq) GetPropsList() []map[string]string + func (p *TSCreateMultiTimeseriesReq) GetSessionId() int64 + func (p *TSCreateMultiTimeseriesReq) GetTagsList() []map[string]string + func (p *TSCreateMultiTimeseriesReq) IsSetAttributesList() bool + func (p *TSCreateMultiTimeseriesReq) IsSetMeasurementAliasList() bool + func (p *TSCreateMultiTimeseriesReq) IsSetPropsList() bool + func (p *TSCreateMultiTimeseriesReq) IsSetTagsList() bool + func (p *TSCreateMultiTimeseriesReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateMultiTimeseriesReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateMultiTimeseriesReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateMultiTimeseriesReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateMultiTimeseriesReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateMultiTimeseriesReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateMultiTimeseriesReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateMultiTimeseriesReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateMultiTimeseriesReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateMultiTimeseriesReq) ReadField9(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateMultiTimeseriesReq) String() string + func (p *TSCreateMultiTimeseriesReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSCreateSchemaTemplateReq struct + Name string + SerializedTemplate []byte + SessionId int64 + var IClientRPCServiceCreateSchemaTemplateArgs_Req_DEFAULT *TSCreateSchemaTemplateReq + func NewTSCreateSchemaTemplateReq() *TSCreateSchemaTemplateReq + func (p *TSCreateSchemaTemplateReq) Equals(other *TSCreateSchemaTemplateReq) bool + func (p *TSCreateSchemaTemplateReq) GetName() string + func (p *TSCreateSchemaTemplateReq) GetSerializedTemplate() []byte + func (p *TSCreateSchemaTemplateReq) GetSessionId() int64 + func (p *TSCreateSchemaTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateSchemaTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateSchemaTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateSchemaTemplateReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateSchemaTemplateReq) String() string + func (p *TSCreateSchemaTemplateReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSCreateTimeseriesReq struct + Attributes map[string]string + Compressor int32 + DataType int32 + Encoding int32 + MeasurementAlias *string + Path string + Props map[string]string + SessionId int64 + Tags map[string]string + var IClientRPCServiceCreateTimeseriesArgs_Req_DEFAULT *TSCreateTimeseriesReq + func NewTSCreateTimeseriesReq() *TSCreateTimeseriesReq + func (p *TSCreateTimeseriesReq) Equals(other *TSCreateTimeseriesReq) bool + func (p *TSCreateTimeseriesReq) GetAttributes() map[string]string + func (p *TSCreateTimeseriesReq) GetCompressor() int32 + func (p *TSCreateTimeseriesReq) GetDataType() int32 + func (p *TSCreateTimeseriesReq) GetEncoding() int32 + func (p *TSCreateTimeseriesReq) GetMeasurementAlias() string + func (p *TSCreateTimeseriesReq) GetPath() string + func (p *TSCreateTimeseriesReq) GetProps() map[string]string + func (p *TSCreateTimeseriesReq) GetSessionId() int64 + func (p *TSCreateTimeseriesReq) GetTags() map[string]string + func (p *TSCreateTimeseriesReq) IsSetAttributes() bool + func (p *TSCreateTimeseriesReq) IsSetMeasurementAlias() bool + func (p *TSCreateTimeseriesReq) IsSetProps() bool + func (p *TSCreateTimeseriesReq) IsSetTags() bool + func (p *TSCreateTimeseriesReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateTimeseriesReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateTimeseriesReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateTimeseriesReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateTimeseriesReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateTimeseriesReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateTimeseriesReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateTimeseriesReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateTimeseriesReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateTimeseriesReq) ReadField9(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSCreateTimeseriesReq) String() string + func (p *TSCreateTimeseriesReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSDeallocatePreparedReq struct + SessionId int64 + StatementName string + var IClientRPCServiceDeallocatePreparedStatementArgs_Req_DEFAULT *TSDeallocatePreparedReq + func NewTSDeallocatePreparedReq() *TSDeallocatePreparedReq + func (p *TSDeallocatePreparedReq) Equals(other *TSDeallocatePreparedReq) bool + func (p *TSDeallocatePreparedReq) GetSessionId() int64 + func (p *TSDeallocatePreparedReq) GetStatementName() string + func (p *TSDeallocatePreparedReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSDeallocatePreparedReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSDeallocatePreparedReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSDeallocatePreparedReq) String() string + func (p *TSDeallocatePreparedReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSDeleteDataReq struct + EndTime int64 + Paths []string + SessionId int64 + StartTime int64 + var IClientRPCServiceDeleteDataArgs_Req_DEFAULT *TSDeleteDataReq + func NewTSDeleteDataReq() *TSDeleteDataReq + func (p *TSDeleteDataReq) Equals(other *TSDeleteDataReq) bool + func (p *TSDeleteDataReq) GetEndTime() int64 + func (p *TSDeleteDataReq) GetPaths() []string + func (p *TSDeleteDataReq) GetSessionId() int64 + func (p *TSDeleteDataReq) GetStartTime() int64 + func (p *TSDeleteDataReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSDeleteDataReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSDeleteDataReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSDeleteDataReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSDeleteDataReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSDeleteDataReq) String() string + func (p *TSDeleteDataReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSDropSchemaTemplateReq struct + SessionId int64 + TemplateName string + var IClientRPCServiceDropSchemaTemplateArgs_Req_DEFAULT *TSDropSchemaTemplateReq + func NewTSDropSchemaTemplateReq() *TSDropSchemaTemplateReq + func (p *TSDropSchemaTemplateReq) Equals(other *TSDropSchemaTemplateReq) bool + func (p *TSDropSchemaTemplateReq) GetSessionId() int64 + func (p *TSDropSchemaTemplateReq) GetTemplateName() string + func (p *TSDropSchemaTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSDropSchemaTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSDropSchemaTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSDropSchemaTemplateReq) String() string + func (p *TSDropSchemaTemplateReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSExecuteBatchStatementReq struct + SessionId int64 + Statements []string + var IClientRPCServiceExecuteBatchStatementArgs_Req_DEFAULT *TSExecuteBatchStatementReq + func NewTSExecuteBatchStatementReq() *TSExecuteBatchStatementReq + func (p *TSExecuteBatchStatementReq) Equals(other *TSExecuteBatchStatementReq) bool + func (p *TSExecuteBatchStatementReq) GetSessionId() int64 + func (p *TSExecuteBatchStatementReq) GetStatements() []string + func (p *TSExecuteBatchStatementReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteBatchStatementReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteBatchStatementReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteBatchStatementReq) String() string + func (p *TSExecuteBatchStatementReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSExecutePreparedReq struct + FetchSize *int32 + Parameters []byte + SessionId int64 + StatementId int64 + StatementName string + Timeout *int64 + var IClientRPCServiceExecutePreparedStatementArgs_Req_DEFAULT *TSExecutePreparedReq + func NewTSExecutePreparedReq() *TSExecutePreparedReq + func (p *TSExecutePreparedReq) Equals(other *TSExecutePreparedReq) bool + func (p *TSExecutePreparedReq) GetFetchSize() int32 + func (p *TSExecutePreparedReq) GetParameters() []byte + func (p *TSExecutePreparedReq) GetSessionId() int64 + func (p *TSExecutePreparedReq) GetStatementId() int64 + func (p *TSExecutePreparedReq) GetStatementName() string + func (p *TSExecutePreparedReq) GetTimeout() int64 + func (p *TSExecutePreparedReq) IsSetFetchSize() bool + func (p *TSExecutePreparedReq) IsSetTimeout() bool + func (p *TSExecutePreparedReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecutePreparedReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecutePreparedReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecutePreparedReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecutePreparedReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecutePreparedReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecutePreparedReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecutePreparedReq) String() string + func (p *TSExecutePreparedReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSExecuteStatementReq struct + EnableRedirectQuery *bool + FetchSize *int32 + JdbcQuery *bool + SessionId int64 + Statement string + StatementId int64 + Timeout *int64 + var IClientRPCServiceExecuteQueryStatementArgs_Req_DEFAULT *TSExecuteStatementReq + var IClientRPCServiceExecuteQueryStatementV2Args_Req_DEFAULT *TSExecuteStatementReq + var IClientRPCServiceExecuteStatementArgs_Req_DEFAULT *TSExecuteStatementReq + var IClientRPCServiceExecuteStatementV2Args_Req_DEFAULT *TSExecuteStatementReq + var IClientRPCServiceExecuteUpdateStatementArgs_Req_DEFAULT *TSExecuteStatementReq + var IClientRPCServiceExecuteUpdateStatementV2Args_Req_DEFAULT *TSExecuteStatementReq + func NewTSExecuteStatementReq() *TSExecuteStatementReq + func (p *TSExecuteStatementReq) Equals(other *TSExecuteStatementReq) bool + func (p *TSExecuteStatementReq) GetEnableRedirectQuery() bool + func (p *TSExecuteStatementReq) GetFetchSize() int32 + func (p *TSExecuteStatementReq) GetJdbcQuery() bool + func (p *TSExecuteStatementReq) GetSessionId() int64 + func (p *TSExecuteStatementReq) GetStatement() string + func (p *TSExecuteStatementReq) GetStatementId() int64 + func (p *TSExecuteStatementReq) GetTimeout() int64 + func (p *TSExecuteStatementReq) IsSetEnableRedirectQuery() bool + func (p *TSExecuteStatementReq) IsSetFetchSize() bool + func (p *TSExecuteStatementReq) IsSetJdbcQuery() bool + func (p *TSExecuteStatementReq) IsSetTimeout() bool + func (p *TSExecuteStatementReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementReq) String() string + func (p *TSExecuteStatementReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSExecuteStatementResp struct + AliasColumns []int8 + ColumnIndex2TsBlockColumnIndexList []int32 + ColumnNameIndexMap map[string]int32 + Columns []string + DataTypeList []string + Database *string + IgnoreTimeStamp *bool + MoreData *bool + NonAlignQueryDataSet *TSQueryNonAlignDataSet + OperationType *string + QueryDataSet *TSQueryDataSet + QueryId *int64 + QueryResult_ [][]byte + SgColumns []string + Status *common.TSStatus + TableModel *bool + TracingInfo *TSTracingInfo + var IClientRPCServiceExecuteAggregationQueryResult_Success_DEFAULT *TSExecuteStatementResp + var IClientRPCServiceExecuteAggregationQueryV2Result_Success_DEFAULT *TSExecuteStatementResp + var IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Result_Success_DEFAULT *TSExecuteStatementResp + var IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathResult_Success_DEFAULT *TSExecuteStatementResp + var IClientRPCServiceExecuteLastDataQueryResult_Success_DEFAULT *TSExecuteStatementResp + var IClientRPCServiceExecuteLastDataQueryV2Result_Success_DEFAULT *TSExecuteStatementResp + var IClientRPCServiceExecutePreparedStatementResult_Success_DEFAULT *TSExecuteStatementResp + var IClientRPCServiceExecuteQueryStatementResult_Success_DEFAULT *TSExecuteStatementResp + var IClientRPCServiceExecuteQueryStatementV2Result_Success_DEFAULT *TSExecuteStatementResp + var IClientRPCServiceExecuteRawDataQueryResult_Success_DEFAULT *TSExecuteStatementResp + var IClientRPCServiceExecuteRawDataQueryV2Result_Success_DEFAULT *TSExecuteStatementResp + var IClientRPCServiceExecuteStatementResult_Success_DEFAULT *TSExecuteStatementResp + var IClientRPCServiceExecuteStatementV2Result_Success_DEFAULT *TSExecuteStatementResp + var IClientRPCServiceExecuteUpdateStatementResult_Success_DEFAULT *TSExecuteStatementResp + var IClientRPCServiceExecuteUpdateStatementV2Result_Success_DEFAULT *TSExecuteStatementResp + func NewTSExecuteStatementResp() *TSExecuteStatementResp + func (p *TSExecuteStatementResp) Equals(other *TSExecuteStatementResp) bool + func (p *TSExecuteStatementResp) GetAliasColumns() []int8 + func (p *TSExecuteStatementResp) GetColumnIndex2TsBlockColumnIndexList() []int32 + func (p *TSExecuteStatementResp) GetColumnNameIndexMap() map[string]int32 + func (p *TSExecuteStatementResp) GetColumns() []string + func (p *TSExecuteStatementResp) GetDataTypeList() []string + func (p *TSExecuteStatementResp) GetDatabase() string + func (p *TSExecuteStatementResp) GetIgnoreTimeStamp() bool + func (p *TSExecuteStatementResp) GetMoreData() bool + func (p *TSExecuteStatementResp) GetNonAlignQueryDataSet() *TSQueryNonAlignDataSet + func (p *TSExecuteStatementResp) GetOperationType() string + func (p *TSExecuteStatementResp) GetQueryDataSet() *TSQueryDataSet + func (p *TSExecuteStatementResp) GetQueryId() int64 + func (p *TSExecuteStatementResp) GetQueryResult_() [][]byte + func (p *TSExecuteStatementResp) GetSgColumns() []string + func (p *TSExecuteStatementResp) GetStatus() *common.TSStatus + func (p *TSExecuteStatementResp) GetTableModel() bool + func (p *TSExecuteStatementResp) GetTracingInfo() *TSTracingInfo + func (p *TSExecuteStatementResp) IsSetAliasColumns() bool + func (p *TSExecuteStatementResp) IsSetColumnIndex2TsBlockColumnIndexList() bool + func (p *TSExecuteStatementResp) IsSetColumnNameIndexMap() bool + func (p *TSExecuteStatementResp) IsSetColumns() bool + func (p *TSExecuteStatementResp) IsSetDataTypeList() bool + func (p *TSExecuteStatementResp) IsSetDatabase() bool + func (p *TSExecuteStatementResp) IsSetIgnoreTimeStamp() bool + func (p *TSExecuteStatementResp) IsSetMoreData() bool + func (p *TSExecuteStatementResp) IsSetNonAlignQueryDataSet() bool + func (p *TSExecuteStatementResp) IsSetOperationType() bool + func (p *TSExecuteStatementResp) IsSetQueryDataSet() bool + func (p *TSExecuteStatementResp) IsSetQueryId() bool + func (p *TSExecuteStatementResp) IsSetQueryResult_() bool + func (p *TSExecuteStatementResp) IsSetSgColumns() bool + func (p *TSExecuteStatementResp) IsSetStatus() bool + func (p *TSExecuteStatementResp) IsSetTableModel() bool + func (p *TSExecuteStatementResp) IsSetTracingInfo() bool + func (p *TSExecuteStatementResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField10(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField11(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField12(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField13(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField14(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField15(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField16(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField17(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) ReadField9(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSExecuteStatementResp) String() string + func (p *TSExecuteStatementResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSFastLastDataQueryForOneDeviceReq struct + Db string + DeviceId string + EnableRedirectQuery *bool + FetchSize *int32 + JdbcQuery *bool + LegalPathNodes *bool + Sensors []string + SessionId int64 + StatementId int64 + Timeout *int64 + var IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Args_Req_DEFAULT *TSFastLastDataQueryForOneDeviceReq + func NewTSFastLastDataQueryForOneDeviceReq() *TSFastLastDataQueryForOneDeviceReq + func (p *TSFastLastDataQueryForOneDeviceReq) Equals(other *TSFastLastDataQueryForOneDeviceReq) bool + func (p *TSFastLastDataQueryForOneDeviceReq) GetDb() string + func (p *TSFastLastDataQueryForOneDeviceReq) GetDeviceId() string + func (p *TSFastLastDataQueryForOneDeviceReq) GetEnableRedirectQuery() bool + func (p *TSFastLastDataQueryForOneDeviceReq) GetFetchSize() int32 + func (p *TSFastLastDataQueryForOneDeviceReq) GetJdbcQuery() bool + func (p *TSFastLastDataQueryForOneDeviceReq) GetLegalPathNodes() bool + func (p *TSFastLastDataQueryForOneDeviceReq) GetSensors() []string + func (p *TSFastLastDataQueryForOneDeviceReq) GetSessionId() int64 + func (p *TSFastLastDataQueryForOneDeviceReq) GetStatementId() int64 + func (p *TSFastLastDataQueryForOneDeviceReq) GetTimeout() int64 + func (p *TSFastLastDataQueryForOneDeviceReq) IsSetEnableRedirectQuery() bool + func (p *TSFastLastDataQueryForOneDeviceReq) IsSetFetchSize() bool + func (p *TSFastLastDataQueryForOneDeviceReq) IsSetJdbcQuery() bool + func (p *TSFastLastDataQueryForOneDeviceReq) IsSetLegalPathNodes() bool + func (p *TSFastLastDataQueryForOneDeviceReq) IsSetTimeout() bool + func (p *TSFastLastDataQueryForOneDeviceReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOneDeviceReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOneDeviceReq) ReadField10(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOneDeviceReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOneDeviceReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOneDeviceReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOneDeviceReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOneDeviceReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOneDeviceReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOneDeviceReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOneDeviceReq) ReadField9(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOneDeviceReq) String() string + func (p *TSFastLastDataQueryForOneDeviceReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSFastLastDataQueryForOnePrefixPathReq struct + EnableRedirectQuery *bool + FetchSize *int32 + JdbcQuery *bool + Prefixes []string + SessionId int64 + StatementId int64 + Timeout *int64 + var IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathArgs_Req_DEFAULT *TSFastLastDataQueryForOnePrefixPathReq + func NewTSFastLastDataQueryForOnePrefixPathReq() *TSFastLastDataQueryForOnePrefixPathReq + func (p *TSFastLastDataQueryForOnePrefixPathReq) Equals(other *TSFastLastDataQueryForOnePrefixPathReq) bool + func (p *TSFastLastDataQueryForOnePrefixPathReq) GetEnableRedirectQuery() bool + func (p *TSFastLastDataQueryForOnePrefixPathReq) GetFetchSize() int32 + func (p *TSFastLastDataQueryForOnePrefixPathReq) GetJdbcQuery() bool + func (p *TSFastLastDataQueryForOnePrefixPathReq) GetPrefixes() []string + func (p *TSFastLastDataQueryForOnePrefixPathReq) GetSessionId() int64 + func (p *TSFastLastDataQueryForOnePrefixPathReq) GetStatementId() int64 + func (p *TSFastLastDataQueryForOnePrefixPathReq) GetTimeout() int64 + func (p *TSFastLastDataQueryForOnePrefixPathReq) IsSetEnableRedirectQuery() bool + func (p *TSFastLastDataQueryForOnePrefixPathReq) IsSetFetchSize() bool + func (p *TSFastLastDataQueryForOnePrefixPathReq) IsSetJdbcQuery() bool + func (p *TSFastLastDataQueryForOnePrefixPathReq) IsSetTimeout() bool + func (p *TSFastLastDataQueryForOnePrefixPathReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOnePrefixPathReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOnePrefixPathReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOnePrefixPathReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOnePrefixPathReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOnePrefixPathReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOnePrefixPathReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOnePrefixPathReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFastLastDataQueryForOnePrefixPathReq) String() string + func (p *TSFastLastDataQueryForOnePrefixPathReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSFetchMetadataReq struct + ColumnPath *string + SessionId int64 + Type string + var IClientRPCServiceFetchMetadataArgs_Req_DEFAULT *TSFetchMetadataReq + func NewTSFetchMetadataReq() *TSFetchMetadataReq + func (p *TSFetchMetadataReq) Equals(other *TSFetchMetadataReq) bool + func (p *TSFetchMetadataReq) GetColumnPath() string + func (p *TSFetchMetadataReq) GetSessionId() int64 + func (p *TSFetchMetadataReq) GetType() string + func (p *TSFetchMetadataReq) IsSetColumnPath() bool + func (p *TSFetchMetadataReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchMetadataReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchMetadataReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchMetadataReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchMetadataReq) String() string + func (p *TSFetchMetadataReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSFetchMetadataResp struct + ColumnsList []string + DataType *string + MetadataInJson *string + Status *common.TSStatus + var IClientRPCServiceFetchMetadataResult_Success_DEFAULT *TSFetchMetadataResp + func NewTSFetchMetadataResp() *TSFetchMetadataResp + func (p *TSFetchMetadataResp) Equals(other *TSFetchMetadataResp) bool + func (p *TSFetchMetadataResp) GetColumnsList() []string + func (p *TSFetchMetadataResp) GetDataType() string + func (p *TSFetchMetadataResp) GetMetadataInJson() string + func (p *TSFetchMetadataResp) GetStatus() *common.TSStatus + func (p *TSFetchMetadataResp) IsSetColumnsList() bool + func (p *TSFetchMetadataResp) IsSetDataType() bool + func (p *TSFetchMetadataResp) IsSetMetadataInJson() bool + func (p *TSFetchMetadataResp) IsSetStatus() bool + func (p *TSFetchMetadataResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchMetadataResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchMetadataResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchMetadataResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchMetadataResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchMetadataResp) String() string + func (p *TSFetchMetadataResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSFetchResultsReq struct + FetchSize int32 + IsAlign bool + QueryId int64 + SessionId int64 + Statement string + StatementId *int64 + Timeout *int64 + var IClientRPCServiceFetchResultsArgs_Req_DEFAULT *TSFetchResultsReq + var IClientRPCServiceFetchResultsV2Args_Req_DEFAULT *TSFetchResultsReq + func NewTSFetchResultsReq() *TSFetchResultsReq + func (p *TSFetchResultsReq) Equals(other *TSFetchResultsReq) bool + func (p *TSFetchResultsReq) GetFetchSize() int32 + func (p *TSFetchResultsReq) GetIsAlign() bool + func (p *TSFetchResultsReq) GetQueryId() int64 + func (p *TSFetchResultsReq) GetSessionId() int64 + func (p *TSFetchResultsReq) GetStatement() string + func (p *TSFetchResultsReq) GetStatementId() int64 + func (p *TSFetchResultsReq) GetTimeout() int64 + func (p *TSFetchResultsReq) IsSetStatementId() bool + func (p *TSFetchResultsReq) IsSetTimeout() bool + func (p *TSFetchResultsReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsReq) String() string + func (p *TSFetchResultsReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSFetchResultsResp struct + HasResultSet bool + IsAlign bool + MoreData *bool + NonAlignQueryDataSet *TSQueryNonAlignDataSet + QueryDataSet *TSQueryDataSet + QueryResult_ [][]byte + Status *common.TSStatus + var IClientRPCServiceFetchResultsResult_Success_DEFAULT *TSFetchResultsResp + var IClientRPCServiceFetchResultsV2Result_Success_DEFAULT *TSFetchResultsResp + func NewTSFetchResultsResp() *TSFetchResultsResp + func (p *TSFetchResultsResp) Equals(other *TSFetchResultsResp) bool + func (p *TSFetchResultsResp) GetHasResultSet() bool + func (p *TSFetchResultsResp) GetIsAlign() bool + func (p *TSFetchResultsResp) GetMoreData() bool + func (p *TSFetchResultsResp) GetNonAlignQueryDataSet() *TSQueryNonAlignDataSet + func (p *TSFetchResultsResp) GetQueryDataSet() *TSQueryDataSet + func (p *TSFetchResultsResp) GetQueryResult_() [][]byte + func (p *TSFetchResultsResp) GetStatus() *common.TSStatus + func (p *TSFetchResultsResp) IsSetMoreData() bool + func (p *TSFetchResultsResp) IsSetNonAlignQueryDataSet() bool + func (p *TSFetchResultsResp) IsSetQueryDataSet() bool + func (p *TSFetchResultsResp) IsSetQueryResult_() bool + func (p *TSFetchResultsResp) IsSetStatus() bool + func (p *TSFetchResultsResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsResp) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsResp) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsResp) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSFetchResultsResp) String() string + func (p *TSFetchResultsResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSGetOperationStatusReq struct + QueryId int64 + SessionId int64 + func NewTSGetOperationStatusReq() *TSGetOperationStatusReq + func (p *TSGetOperationStatusReq) Equals(other *TSGetOperationStatusReq) bool + func (p *TSGetOperationStatusReq) GetQueryId() int64 + func (p *TSGetOperationStatusReq) GetSessionId() int64 + func (p *TSGetOperationStatusReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSGetOperationStatusReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSGetOperationStatusReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSGetOperationStatusReq) String() string + func (p *TSGetOperationStatusReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSGetTimeZoneResp struct + Status *common.TSStatus + TimeZone string + var IClientRPCServiceGetTimeZoneResult_Success_DEFAULT *TSGetTimeZoneResp + func NewTSGetTimeZoneResp() *TSGetTimeZoneResp + func (p *TSGetTimeZoneResp) Equals(other *TSGetTimeZoneResp) bool + func (p *TSGetTimeZoneResp) GetStatus() *common.TSStatus + func (p *TSGetTimeZoneResp) GetTimeZone() string + func (p *TSGetTimeZoneResp) IsSetStatus() bool + func (p *TSGetTimeZoneResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSGetTimeZoneResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSGetTimeZoneResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSGetTimeZoneResp) String() string + func (p *TSGetTimeZoneResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSInsertRecordReq struct + ColumnCategoryies []int8 + IsAligned *bool + IsWriteToTable *bool + Measurements []string + PrefixPath string + SessionId int64 + Timestamp int64 + Values []byte + var IClientRPCServiceInsertRecordArgs_Req_DEFAULT *TSInsertRecordReq + var IClientRPCServiceTestInsertRecordArgs_Req_DEFAULT *TSInsertRecordReq + func NewTSInsertRecordReq() *TSInsertRecordReq + func (p *TSInsertRecordReq) Equals(other *TSInsertRecordReq) bool + func (p *TSInsertRecordReq) GetColumnCategoryies() []int8 + func (p *TSInsertRecordReq) GetIsAligned() bool + func (p *TSInsertRecordReq) GetIsWriteToTable() bool + func (p *TSInsertRecordReq) GetMeasurements() []string + func (p *TSInsertRecordReq) GetPrefixPath() string + func (p *TSInsertRecordReq) GetSessionId() int64 + func (p *TSInsertRecordReq) GetTimestamp() int64 + func (p *TSInsertRecordReq) GetValues() []byte + func (p *TSInsertRecordReq) IsSetColumnCategoryies() bool + func (p *TSInsertRecordReq) IsSetIsAligned() bool + func (p *TSInsertRecordReq) IsSetIsWriteToTable() bool + func (p *TSInsertRecordReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordReq) String() string + func (p *TSInsertRecordReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSInsertRecordsOfOneDeviceReq struct + IsAligned *bool + MeasurementsList [][]string + PrefixPath string + SessionId int64 + Timestamps []int64 + ValuesList [][]byte + var IClientRPCServiceInsertRecordsOfOneDeviceArgs_Req_DEFAULT *TSInsertRecordsOfOneDeviceReq + var IClientRPCServiceTestInsertRecordsOfOneDeviceArgs_Req_DEFAULT *TSInsertRecordsOfOneDeviceReq + func NewTSInsertRecordsOfOneDeviceReq() *TSInsertRecordsOfOneDeviceReq + func (p *TSInsertRecordsOfOneDeviceReq) Equals(other *TSInsertRecordsOfOneDeviceReq) bool + func (p *TSInsertRecordsOfOneDeviceReq) GetIsAligned() bool + func (p *TSInsertRecordsOfOneDeviceReq) GetMeasurementsList() [][]string + func (p *TSInsertRecordsOfOneDeviceReq) GetPrefixPath() string + func (p *TSInsertRecordsOfOneDeviceReq) GetSessionId() int64 + func (p *TSInsertRecordsOfOneDeviceReq) GetTimestamps() []int64 + func (p *TSInsertRecordsOfOneDeviceReq) GetValuesList() [][]byte + func (p *TSInsertRecordsOfOneDeviceReq) IsSetIsAligned() bool + func (p *TSInsertRecordsOfOneDeviceReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordsOfOneDeviceReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordsOfOneDeviceReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordsOfOneDeviceReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordsOfOneDeviceReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordsOfOneDeviceReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordsOfOneDeviceReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordsOfOneDeviceReq) String() string + func (p *TSInsertRecordsOfOneDeviceReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSInsertRecordsReq struct + IsAligned *bool + MeasurementsList [][]string + PrefixPaths []string + SessionId int64 + Timestamps []int64 + ValuesList [][]byte + var IClientRPCServiceInsertRecordsArgs_Req_DEFAULT *TSInsertRecordsReq + var IClientRPCServiceTestInsertRecordsArgs_Req_DEFAULT *TSInsertRecordsReq + func NewTSInsertRecordsReq() *TSInsertRecordsReq + func (p *TSInsertRecordsReq) Equals(other *TSInsertRecordsReq) bool + func (p *TSInsertRecordsReq) GetIsAligned() bool + func (p *TSInsertRecordsReq) GetMeasurementsList() [][]string + func (p *TSInsertRecordsReq) GetPrefixPaths() []string + func (p *TSInsertRecordsReq) GetSessionId() int64 + func (p *TSInsertRecordsReq) GetTimestamps() []int64 + func (p *TSInsertRecordsReq) GetValuesList() [][]byte + func (p *TSInsertRecordsReq) IsSetIsAligned() bool + func (p *TSInsertRecordsReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordsReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordsReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordsReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordsReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordsReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordsReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertRecordsReq) String() string + func (p *TSInsertRecordsReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSInsertStringRecordReq struct + IsAligned *bool + Measurements []string + PrefixPath string + SessionId int64 + Timeout *int64 + Timestamp int64 + Values []string + var IClientRPCServiceInsertStringRecordArgs_Req_DEFAULT *TSInsertStringRecordReq + var IClientRPCServiceTestInsertStringRecordArgs_Req_DEFAULT *TSInsertStringRecordReq + func NewTSInsertStringRecordReq() *TSInsertStringRecordReq + func (p *TSInsertStringRecordReq) Equals(other *TSInsertStringRecordReq) bool + func (p *TSInsertStringRecordReq) GetIsAligned() bool + func (p *TSInsertStringRecordReq) GetMeasurements() []string + func (p *TSInsertStringRecordReq) GetPrefixPath() string + func (p *TSInsertStringRecordReq) GetSessionId() int64 + func (p *TSInsertStringRecordReq) GetTimeout() int64 + func (p *TSInsertStringRecordReq) GetTimestamp() int64 + func (p *TSInsertStringRecordReq) GetValues() []string + func (p *TSInsertStringRecordReq) IsSetIsAligned() bool + func (p *TSInsertStringRecordReq) IsSetTimeout() bool + func (p *TSInsertStringRecordReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordReq) String() string + func (p *TSInsertStringRecordReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSInsertStringRecordsOfOneDeviceReq struct + IsAligned *bool + MeasurementsList [][]string + PrefixPath string + SessionId int64 + Timestamps []int64 + ValuesList [][]string + var IClientRPCServiceInsertStringRecordsOfOneDeviceArgs_Req_DEFAULT *TSInsertStringRecordsOfOneDeviceReq + func NewTSInsertStringRecordsOfOneDeviceReq() *TSInsertStringRecordsOfOneDeviceReq + func (p *TSInsertStringRecordsOfOneDeviceReq) Equals(other *TSInsertStringRecordsOfOneDeviceReq) bool + func (p *TSInsertStringRecordsOfOneDeviceReq) GetIsAligned() bool + func (p *TSInsertStringRecordsOfOneDeviceReq) GetMeasurementsList() [][]string + func (p *TSInsertStringRecordsOfOneDeviceReq) GetPrefixPath() string + func (p *TSInsertStringRecordsOfOneDeviceReq) GetSessionId() int64 + func (p *TSInsertStringRecordsOfOneDeviceReq) GetTimestamps() []int64 + func (p *TSInsertStringRecordsOfOneDeviceReq) GetValuesList() [][]string + func (p *TSInsertStringRecordsOfOneDeviceReq) IsSetIsAligned() bool + func (p *TSInsertStringRecordsOfOneDeviceReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordsOfOneDeviceReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordsOfOneDeviceReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordsOfOneDeviceReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordsOfOneDeviceReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordsOfOneDeviceReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordsOfOneDeviceReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordsOfOneDeviceReq) String() string + func (p *TSInsertStringRecordsOfOneDeviceReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSInsertStringRecordsReq struct + IsAligned *bool + MeasurementsList [][]string + PrefixPaths []string + SessionId int64 + Timestamps []int64 + ValuesList [][]string + var IClientRPCServiceInsertStringRecordsArgs_Req_DEFAULT *TSInsertStringRecordsReq + var IClientRPCServiceTestInsertStringRecordsArgs_Req_DEFAULT *TSInsertStringRecordsReq + func NewTSInsertStringRecordsReq() *TSInsertStringRecordsReq + func (p *TSInsertStringRecordsReq) Equals(other *TSInsertStringRecordsReq) bool + func (p *TSInsertStringRecordsReq) GetIsAligned() bool + func (p *TSInsertStringRecordsReq) GetMeasurementsList() [][]string + func (p *TSInsertStringRecordsReq) GetPrefixPaths() []string + func (p *TSInsertStringRecordsReq) GetSessionId() int64 + func (p *TSInsertStringRecordsReq) GetTimestamps() []int64 + func (p *TSInsertStringRecordsReq) GetValuesList() [][]string + func (p *TSInsertStringRecordsReq) IsSetIsAligned() bool + func (p *TSInsertStringRecordsReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordsReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordsReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordsReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordsReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordsReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordsReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertStringRecordsReq) String() string + func (p *TSInsertStringRecordsReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSInsertTabletReq struct + ColumnCategories []int8 + CompressType *int8 + EncodingTypes []int8 + IsAligned *bool + IsCompressed *bool + Measurements []string + PrefixPath string + SessionId int64 + Size int32 + Timestamps []byte + Types []int32 + Values []byte + WriteToTable *bool + var IClientRPCServiceInsertTabletArgs_Req_DEFAULT *TSInsertTabletReq + var IClientRPCServiceTestInsertTabletArgs_Req_DEFAULT *TSInsertTabletReq + func NewTSInsertTabletReq() *TSInsertTabletReq + func (p *TSInsertTabletReq) Equals(other *TSInsertTabletReq) bool + func (p *TSInsertTabletReq) GetColumnCategories() []int8 + func (p *TSInsertTabletReq) GetCompressType() int8 + func (p *TSInsertTabletReq) GetEncodingTypes() []int8 + func (p *TSInsertTabletReq) GetIsAligned() bool + func (p *TSInsertTabletReq) GetIsCompressed() bool + func (p *TSInsertTabletReq) GetMeasurements() []string + func (p *TSInsertTabletReq) GetPrefixPath() string + func (p *TSInsertTabletReq) GetSessionId() int64 + func (p *TSInsertTabletReq) GetSize() int32 + func (p *TSInsertTabletReq) GetTimestamps() []byte + func (p *TSInsertTabletReq) GetTypes() []int32 + func (p *TSInsertTabletReq) GetValues() []byte + func (p *TSInsertTabletReq) GetWriteToTable() bool + func (p *TSInsertTabletReq) IsSetColumnCategories() bool + func (p *TSInsertTabletReq) IsSetCompressType() bool + func (p *TSInsertTabletReq) IsSetEncodingTypes() bool + func (p *TSInsertTabletReq) IsSetIsAligned() bool + func (p *TSInsertTabletReq) IsSetIsCompressed() bool + func (p *TSInsertTabletReq) IsSetWriteToTable() bool + func (p *TSInsertTabletReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletReq) ReadField10(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletReq) ReadField11(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletReq) ReadField12(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletReq) ReadField13(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletReq) ReadField9(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletReq) String() string + func (p *TSInsertTabletReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSInsertTabletsReq struct + IsAligned *bool + MeasurementsList [][]string + PrefixPaths []string + SessionId int64 + SizeList []int32 + TimestampsList [][]byte + TypesList [][]int32 + ValuesList [][]byte + var IClientRPCServiceInsertTabletsArgs_Req_DEFAULT *TSInsertTabletsReq + var IClientRPCServiceTestInsertTabletsArgs_Req_DEFAULT *TSInsertTabletsReq + func NewTSInsertTabletsReq() *TSInsertTabletsReq + func (p *TSInsertTabletsReq) Equals(other *TSInsertTabletsReq) bool + func (p *TSInsertTabletsReq) GetIsAligned() bool + func (p *TSInsertTabletsReq) GetMeasurementsList() [][]string + func (p *TSInsertTabletsReq) GetPrefixPaths() []string + func (p *TSInsertTabletsReq) GetSessionId() int64 + func (p *TSInsertTabletsReq) GetSizeList() []int32 + func (p *TSInsertTabletsReq) GetTimestampsList() [][]byte + func (p *TSInsertTabletsReq) GetTypesList() [][]int32 + func (p *TSInsertTabletsReq) GetValuesList() [][]byte + func (p *TSInsertTabletsReq) IsSetIsAligned() bool + func (p *TSInsertTabletsReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletsReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletsReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletsReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletsReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletsReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletsReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletsReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletsReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSInsertTabletsReq) String() string + func (p *TSInsertTabletsReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSLastDataQueryReq struct + EnableRedirectQuery *bool + FetchSize *int32 + JdbcQuery *bool + LegalPathNodes *bool + Paths []string + SessionId int64 + StatementId int64 + Time int64 + Timeout *int64 + var IClientRPCServiceExecuteLastDataQueryArgs_Req_DEFAULT *TSLastDataQueryReq + var IClientRPCServiceExecuteLastDataQueryV2Args_Req_DEFAULT *TSLastDataQueryReq + func NewTSLastDataQueryReq() *TSLastDataQueryReq + func (p *TSLastDataQueryReq) Equals(other *TSLastDataQueryReq) bool + func (p *TSLastDataQueryReq) GetEnableRedirectQuery() bool + func (p *TSLastDataQueryReq) GetFetchSize() int32 + func (p *TSLastDataQueryReq) GetJdbcQuery() bool + func (p *TSLastDataQueryReq) GetLegalPathNodes() bool + func (p *TSLastDataQueryReq) GetPaths() []string + func (p *TSLastDataQueryReq) GetSessionId() int64 + func (p *TSLastDataQueryReq) GetStatementId() int64 + func (p *TSLastDataQueryReq) GetTime() int64 + func (p *TSLastDataQueryReq) GetTimeout() int64 + func (p *TSLastDataQueryReq) IsSetEnableRedirectQuery() bool + func (p *TSLastDataQueryReq) IsSetFetchSize() bool + func (p *TSLastDataQueryReq) IsSetJdbcQuery() bool + func (p *TSLastDataQueryReq) IsSetLegalPathNodes() bool + func (p *TSLastDataQueryReq) IsSetTimeout() bool + func (p *TSLastDataQueryReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSLastDataQueryReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSLastDataQueryReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSLastDataQueryReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSLastDataQueryReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSLastDataQueryReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSLastDataQueryReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSLastDataQueryReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSLastDataQueryReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSLastDataQueryReq) ReadField9(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSLastDataQueryReq) String() string + func (p *TSLastDataQueryReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSOpenSessionReq struct + ClientProtocol TSProtocolVersion + Configuration map[string]string + Password *string + Username string + ZoneId string + var IClientRPCServiceOpenSessionArgs_Req_DEFAULT *TSOpenSessionReq + func NewTSOpenSessionReq() *TSOpenSessionReq + func (p *TSOpenSessionReq) Equals(other *TSOpenSessionReq) bool + func (p *TSOpenSessionReq) GetClientProtocol() TSProtocolVersion + func (p *TSOpenSessionReq) GetConfiguration() map[string]string + func (p *TSOpenSessionReq) GetPassword() string + func (p *TSOpenSessionReq) GetUsername() string + func (p *TSOpenSessionReq) GetZoneId() string + func (p *TSOpenSessionReq) IsSetConfiguration() bool + func (p *TSOpenSessionReq) IsSetPassword() bool + func (p *TSOpenSessionReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSOpenSessionReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSOpenSessionReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSOpenSessionReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSOpenSessionReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSOpenSessionReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSOpenSessionReq) String() string + func (p *TSOpenSessionReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSOpenSessionResp struct + Configuration map[string]string + ServerProtocolVersion TSProtocolVersion + SessionId *int64 + Status *common.TSStatus + var IClientRPCServiceOpenSessionResult_Success_DEFAULT *TSOpenSessionResp + func NewTSOpenSessionResp() *TSOpenSessionResp + func (p *TSOpenSessionResp) Equals(other *TSOpenSessionResp) bool + func (p *TSOpenSessionResp) GetConfiguration() map[string]string + func (p *TSOpenSessionResp) GetServerProtocolVersion() TSProtocolVersion + func (p *TSOpenSessionResp) GetSessionId() int64 + func (p *TSOpenSessionResp) GetStatus() *common.TSStatus + func (p *TSOpenSessionResp) IsSetConfiguration() bool + func (p *TSOpenSessionResp) IsSetSessionId() bool + func (p *TSOpenSessionResp) IsSetStatus() bool + func (p *TSOpenSessionResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSOpenSessionResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSOpenSessionResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSOpenSessionResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSOpenSessionResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSOpenSessionResp) String() string + func (p *TSOpenSessionResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSPrepareReq struct + SessionId int64 + Sql string + StatementName string + var IClientRPCServicePrepareStatementArgs_Req_DEFAULT *TSPrepareReq + func NewTSPrepareReq() *TSPrepareReq + func (p *TSPrepareReq) Equals(other *TSPrepareReq) bool + func (p *TSPrepareReq) GetSessionId() int64 + func (p *TSPrepareReq) GetSql() string + func (p *TSPrepareReq) GetStatementName() string + func (p *TSPrepareReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSPrepareReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSPrepareReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSPrepareReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSPrepareReq) String() string + func (p *TSPrepareReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSPrepareResp struct + ParameterCount *int32 + Status *common.TSStatus + var IClientRPCServicePrepareStatementResult_Success_DEFAULT *TSPrepareResp + func NewTSPrepareResp() *TSPrepareResp + func (p *TSPrepareResp) Equals(other *TSPrepareResp) bool + func (p *TSPrepareResp) GetParameterCount() int32 + func (p *TSPrepareResp) GetStatus() *common.TSStatus + func (p *TSPrepareResp) IsSetParameterCount() bool + func (p *TSPrepareResp) IsSetStatus() bool + func (p *TSPrepareResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSPrepareResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSPrepareResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSPrepareResp) String() string + func (p *TSPrepareResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSProtocolVersion int64 + const TSProtocolVersion_IOTDB_SERVICE_PROTOCOL_V1 + const TSProtocolVersion_IOTDB_SERVICE_PROTOCOL_V2 + const TSProtocolVersion_IOTDB_SERVICE_PROTOCOL_V3 + func TSProtocolVersionFromString(s string) (TSProtocolVersion, error) + func TSProtocolVersionPtr(v TSProtocolVersion) *TSProtocolVersion + func (p *TSProtocolVersion) Scan(value interface{}) error + func (p *TSProtocolVersion) UnmarshalText(text []byte) error + func (p *TSProtocolVersion) Value() (driver.Value, error) + func (p TSProtocolVersion) MarshalText() ([]byte, error) + func (p TSProtocolVersion) String() string + type TSPruneSchemaTemplateReq struct + Name string + Path string + SessionId int64 + var IClientRPCServicePruneSchemaTemplateArgs_Req_DEFAULT *TSPruneSchemaTemplateReq + func NewTSPruneSchemaTemplateReq() *TSPruneSchemaTemplateReq + func (p *TSPruneSchemaTemplateReq) Equals(other *TSPruneSchemaTemplateReq) bool + func (p *TSPruneSchemaTemplateReq) GetName() string + func (p *TSPruneSchemaTemplateReq) GetPath() string + func (p *TSPruneSchemaTemplateReq) GetSessionId() int64 + func (p *TSPruneSchemaTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSPruneSchemaTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSPruneSchemaTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSPruneSchemaTemplateReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSPruneSchemaTemplateReq) String() string + func (p *TSPruneSchemaTemplateReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSQueryDataSet struct + BitmapList [][]byte + Time []byte + ValueList [][]byte + var TSExecuteStatementResp_QueryDataSet_DEFAULT *TSQueryDataSet + var TSFetchResultsResp_QueryDataSet_DEFAULT *TSQueryDataSet + func NewTSQueryDataSet() *TSQueryDataSet + func (p *TSQueryDataSet) Equals(other *TSQueryDataSet) bool + func (p *TSQueryDataSet) GetBitmapList() [][]byte + func (p *TSQueryDataSet) GetTime() []byte + func (p *TSQueryDataSet) GetValueList() [][]byte + func (p *TSQueryDataSet) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryDataSet) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryDataSet) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryDataSet) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryDataSet) String() string + func (p *TSQueryDataSet) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSQueryNonAlignDataSet struct + TimeList [][]byte + ValueList [][]byte + var TSExecuteStatementResp_NonAlignQueryDataSet_DEFAULT *TSQueryNonAlignDataSet + var TSFetchResultsResp_NonAlignQueryDataSet_DEFAULT *TSQueryNonAlignDataSet + func NewTSQueryNonAlignDataSet() *TSQueryNonAlignDataSet + func (p *TSQueryNonAlignDataSet) Equals(other *TSQueryNonAlignDataSet) bool + func (p *TSQueryNonAlignDataSet) GetTimeList() [][]byte + func (p *TSQueryNonAlignDataSet) GetValueList() [][]byte + func (p *TSQueryNonAlignDataSet) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryNonAlignDataSet) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryNonAlignDataSet) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryNonAlignDataSet) String() string + func (p *TSQueryNonAlignDataSet) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSQueryTemplateReq struct + Measurement *string + Name string + QueryType int32 + SessionId int64 + var IClientRPCServiceQuerySchemaTemplateArgs_Req_DEFAULT *TSQueryTemplateReq + func NewTSQueryTemplateReq() *TSQueryTemplateReq + func (p *TSQueryTemplateReq) Equals(other *TSQueryTemplateReq) bool + func (p *TSQueryTemplateReq) GetMeasurement() string + func (p *TSQueryTemplateReq) GetName() string + func (p *TSQueryTemplateReq) GetQueryType() int32 + func (p *TSQueryTemplateReq) GetSessionId() int64 + func (p *TSQueryTemplateReq) IsSetMeasurement() bool + func (p *TSQueryTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryTemplateReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryTemplateReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryTemplateReq) String() string + func (p *TSQueryTemplateReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSQueryTemplateResp struct + Count *int32 + Measurements []string + QueryType int32 + Result_ *bool + Status *common.TSStatus + var IClientRPCServiceQuerySchemaTemplateResult_Success_DEFAULT *TSQueryTemplateResp + func NewTSQueryTemplateResp() *TSQueryTemplateResp + func (p *TSQueryTemplateResp) Equals(other *TSQueryTemplateResp) bool + func (p *TSQueryTemplateResp) GetCount() int32 + func (p *TSQueryTemplateResp) GetMeasurements() []string + func (p *TSQueryTemplateResp) GetQueryType() int32 + func (p *TSQueryTemplateResp) GetResult_() bool + func (p *TSQueryTemplateResp) GetStatus() *common.TSStatus + func (p *TSQueryTemplateResp) IsSetCount() bool + func (p *TSQueryTemplateResp) IsSetMeasurements() bool + func (p *TSQueryTemplateResp) IsSetResult_() bool + func (p *TSQueryTemplateResp) IsSetStatus() bool + func (p *TSQueryTemplateResp) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryTemplateResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryTemplateResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryTemplateResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryTemplateResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryTemplateResp) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSQueryTemplateResp) String() string + func (p *TSQueryTemplateResp) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSRawDataQueryReq struct + EnableRedirectQuery *bool + EndTime int64 + FetchSize *int32 + JdbcQuery *bool + LegalPathNodes *bool + Paths []string + SessionId int64 + StartTime int64 + StatementId int64 + Timeout *int64 + var IClientRPCServiceExecuteRawDataQueryArgs_Req_DEFAULT *TSRawDataQueryReq + var IClientRPCServiceExecuteRawDataQueryV2Args_Req_DEFAULT *TSRawDataQueryReq + func NewTSRawDataQueryReq() *TSRawDataQueryReq + func (p *TSRawDataQueryReq) Equals(other *TSRawDataQueryReq) bool + func (p *TSRawDataQueryReq) GetEnableRedirectQuery() bool + func (p *TSRawDataQueryReq) GetEndTime() int64 + func (p *TSRawDataQueryReq) GetFetchSize() int32 + func (p *TSRawDataQueryReq) GetJdbcQuery() bool + func (p *TSRawDataQueryReq) GetLegalPathNodes() bool + func (p *TSRawDataQueryReq) GetPaths() []string + func (p *TSRawDataQueryReq) GetSessionId() int64 + func (p *TSRawDataQueryReq) GetStartTime() int64 + func (p *TSRawDataQueryReq) GetStatementId() int64 + func (p *TSRawDataQueryReq) GetTimeout() int64 + func (p *TSRawDataQueryReq) IsSetEnableRedirectQuery() bool + func (p *TSRawDataQueryReq) IsSetFetchSize() bool + func (p *TSRawDataQueryReq) IsSetJdbcQuery() bool + func (p *TSRawDataQueryReq) IsSetLegalPathNodes() bool + func (p *TSRawDataQueryReq) IsSetTimeout() bool + func (p *TSRawDataQueryReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSRawDataQueryReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSRawDataQueryReq) ReadField10(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSRawDataQueryReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSRawDataQueryReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSRawDataQueryReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSRawDataQueryReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSRawDataQueryReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSRawDataQueryReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSRawDataQueryReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSRawDataQueryReq) ReadField9(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSRawDataQueryReq) String() string + func (p *TSRawDataQueryReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSSetSchemaTemplateReq struct + PrefixPath string + SessionId int64 + TemplateName string + var IClientRPCServiceSetSchemaTemplateArgs_Req_DEFAULT *TSSetSchemaTemplateReq + func NewTSSetSchemaTemplateReq() *TSSetSchemaTemplateReq + func (p *TSSetSchemaTemplateReq) Equals(other *TSSetSchemaTemplateReq) bool + func (p *TSSetSchemaTemplateReq) GetPrefixPath() string + func (p *TSSetSchemaTemplateReq) GetSessionId() int64 + func (p *TSSetSchemaTemplateReq) GetTemplateName() string + func (p *TSSetSchemaTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSSetSchemaTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSSetSchemaTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSSetSchemaTemplateReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSSetSchemaTemplateReq) String() string + func (p *TSSetSchemaTemplateReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSSetTimeZoneReq struct + SessionId int64 + TimeZone string + var IClientRPCServiceSetTimeZoneArgs_Req_DEFAULT *TSSetTimeZoneReq + func NewTSSetTimeZoneReq() *TSSetTimeZoneReq + func (p *TSSetTimeZoneReq) Equals(other *TSSetTimeZoneReq) bool + func (p *TSSetTimeZoneReq) GetSessionId() int64 + func (p *TSSetTimeZoneReq) GetTimeZone() string + func (p *TSSetTimeZoneReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSSetTimeZoneReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSSetTimeZoneReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSSetTimeZoneReq) String() string + func (p *TSSetTimeZoneReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSTracingInfo struct + ActivityList []string + ElapsedTimeList []int64 + OverlappedPageNum *int32 + SeqFileNum *int32 + SequenceChunkNum *int32 + SequenceChunkPointNum *int64 + SeriesPathNum *int32 + TotalPageNum *int32 + UnSeqFileNum *int32 + UnsequenceChunkNum *int32 + UnsequenceChunkPointNum *int64 + var TSExecuteStatementResp_TracingInfo_DEFAULT *TSTracingInfo + func NewTSTracingInfo() *TSTracingInfo + func (p *TSTracingInfo) Equals(other *TSTracingInfo) bool + func (p *TSTracingInfo) GetActivityList() []string + func (p *TSTracingInfo) GetElapsedTimeList() []int64 + func (p *TSTracingInfo) GetOverlappedPageNum() int32 + func (p *TSTracingInfo) GetSeqFileNum() int32 + func (p *TSTracingInfo) GetSequenceChunkNum() int32 + func (p *TSTracingInfo) GetSequenceChunkPointNum() int64 + func (p *TSTracingInfo) GetSeriesPathNum() int32 + func (p *TSTracingInfo) GetTotalPageNum() int32 + func (p *TSTracingInfo) GetUnSeqFileNum() int32 + func (p *TSTracingInfo) GetUnsequenceChunkNum() int32 + func (p *TSTracingInfo) GetUnsequenceChunkPointNum() int64 + func (p *TSTracingInfo) IsSetOverlappedPageNum() bool + func (p *TSTracingInfo) IsSetSeqFileNum() bool + func (p *TSTracingInfo) IsSetSequenceChunkNum() bool + func (p *TSTracingInfo) IsSetSequenceChunkPointNum() bool + func (p *TSTracingInfo) IsSetSeriesPathNum() bool + func (p *TSTracingInfo) IsSetTotalPageNum() bool + func (p *TSTracingInfo) IsSetUnSeqFileNum() bool + func (p *TSTracingInfo) IsSetUnsequenceChunkNum() bool + func (p *TSTracingInfo) IsSetUnsequenceChunkPointNum() bool + func (p *TSTracingInfo) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSTracingInfo) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSTracingInfo) ReadField10(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSTracingInfo) ReadField11(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSTracingInfo) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSTracingInfo) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSTracingInfo) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSTracingInfo) ReadField5(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSTracingInfo) ReadField6(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSTracingInfo) ReadField7(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSTracingInfo) ReadField8(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSTracingInfo) ReadField9(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSTracingInfo) String() string + func (p *TSTracingInfo) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSUnsetSchemaTemplateReq struct + PrefixPath string + SessionId int64 + TemplateName string + var IClientRPCServiceUnsetSchemaTemplateArgs_Req_DEFAULT *TSUnsetSchemaTemplateReq + func NewTSUnsetSchemaTemplateReq() *TSUnsetSchemaTemplateReq + func (p *TSUnsetSchemaTemplateReq) Equals(other *TSUnsetSchemaTemplateReq) bool + func (p *TSUnsetSchemaTemplateReq) GetPrefixPath() string + func (p *TSUnsetSchemaTemplateReq) GetSessionId() int64 + func (p *TSUnsetSchemaTemplateReq) GetTemplateName() string + func (p *TSUnsetSchemaTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSUnsetSchemaTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSUnsetSchemaTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSUnsetSchemaTemplateReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSUnsetSchemaTemplateReq) String() string + func (p *TSUnsetSchemaTemplateReq) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSyncIdentityInfo struct + CreateTime int64 + Database string + PipeName string + Version string + var IClientRPCServiceHandshakeArgs_Info_DEFAULT *TSyncIdentityInfo + func NewTSyncIdentityInfo() *TSyncIdentityInfo + func (p *TSyncIdentityInfo) Equals(other *TSyncIdentityInfo) bool + func (p *TSyncIdentityInfo) GetCreateTime() int64 + func (p *TSyncIdentityInfo) GetDatabase() string + func (p *TSyncIdentityInfo) GetPipeName() string + func (p *TSyncIdentityInfo) GetVersion() string + func (p *TSyncIdentityInfo) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSyncIdentityInfo) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSyncIdentityInfo) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSyncIdentityInfo) ReadField3(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSyncIdentityInfo) ReadField4(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSyncIdentityInfo) String() string + func (p *TSyncIdentityInfo) Write(ctx context.Context, oprot thrift.TProtocol) error + type TSyncTransportMetaInfo struct + FileName string + StartIndex int64 + var IClientRPCServiceSendFileArgs_MetaInfo_DEFAULT *TSyncTransportMetaInfo + func NewTSyncTransportMetaInfo() *TSyncTransportMetaInfo + func (p *TSyncTransportMetaInfo) Equals(other *TSyncTransportMetaInfo) bool + func (p *TSyncTransportMetaInfo) GetFileName() string + func (p *TSyncTransportMetaInfo) GetStartIndex() int64 + func (p *TSyncTransportMetaInfo) Read(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSyncTransportMetaInfo) ReadField1(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSyncTransportMetaInfo) ReadField2(ctx context.Context, iprot thrift.TProtocol) error + func (p *TSyncTransportMetaInfo) String() string + func (p *TSyncTransportMetaInfo) Write(ctx context.Context, oprot thrift.TProtocol) error v2.0.3-1 Jun 20, 2025 Other modules containing this package github.com/apache/iotdb-client-go
Go to main page