rpc

package

Go to main page

Versions in this module

v2

v2.0.10

Aug 21, 2026

Changes in this version

+ func TSConnectionTypeValues() iter.Seq[TSConnectionType]

+ func TSProtocolVersionValues() iter.Seq[TSProtocolVersion]

type IClientRPCServiceAppendSchemaTemplateArgs

+ func (p *IClientRPCServiceAppendSchemaTemplateArgs) LogValue() slog.Value

type IClientRPCServiceAppendSchemaTemplateResult

+ func (p *IClientRPCServiceAppendSchemaTemplateResult) LogValue() slog.Value

type IClientRPCServiceCancelOperationArgs

+ func (p *IClientRPCServiceCancelOperationArgs) LogValue() slog.Value

type IClientRPCServiceCancelOperationResult

+ func (p *IClientRPCServiceCancelOperationResult) LogValue() slog.Value

type IClientRPCServiceCloseOperationArgs

+ func (p *IClientRPCServiceCloseOperationArgs) LogValue() slog.Value

type IClientRPCServiceCloseOperationResult

+ func (p *IClientRPCServiceCloseOperationResult) LogValue() slog.Value

type IClientRPCServiceCloseSessionArgs

+ func (p *IClientRPCServiceCloseSessionArgs) LogValue() slog.Value

type IClientRPCServiceCloseSessionResult

+ func (p *IClientRPCServiceCloseSessionResult) LogValue() slog.Value

type IClientRPCServiceCreateAlignedTimeseriesArgs

+ func (p *IClientRPCServiceCreateAlignedTimeseriesArgs) LogValue() slog.Value

type IClientRPCServiceCreateAlignedTimeseriesResult

+ func (p *IClientRPCServiceCreateAlignedTimeseriesResult) LogValue() slog.Value

type IClientRPCServiceCreateMultiTimeseriesArgs

+ func (p *IClientRPCServiceCreateMultiTimeseriesArgs) LogValue() slog.Value

type IClientRPCServiceCreateMultiTimeseriesResult

+ func (p *IClientRPCServiceCreateMultiTimeseriesResult) LogValue() slog.Value

type IClientRPCServiceCreateSchemaTemplateArgs

+ func (p *IClientRPCServiceCreateSchemaTemplateArgs) LogValue() slog.Value

type IClientRPCServiceCreateSchemaTemplateResult

+ func (p *IClientRPCServiceCreateSchemaTemplateResult) LogValue() slog.Value

type IClientRPCServiceCreateTimeseriesArgs

+ func (p *IClientRPCServiceCreateTimeseriesArgs) LogValue() slog.Value

type IClientRPCServiceCreateTimeseriesResult

+ func (p *IClientRPCServiceCreateTimeseriesResult) LogValue() slog.Value

type IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs

+ func (p *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs) LogValue() slog.Value

type IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult

+ func (p *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult) LogValue() slog.Value

type IClientRPCServiceDeallocatePreparedStatementArgs

+ func (p *IClientRPCServiceDeallocatePreparedStatementArgs) LogValue() slog.Value

type IClientRPCServiceDeallocatePreparedStatementResult

+ func (p *IClientRPCServiceDeallocatePreparedStatementResult) LogValue() slog.Value

type IClientRPCServiceDeleteDataArgs

+ func (p *IClientRPCServiceDeleteDataArgs) LogValue() slog.Value

type IClientRPCServiceDeleteDataResult

+ func (p *IClientRPCServiceDeleteDataResult) LogValue() slog.Value

type IClientRPCServiceDeleteStorageGroupsArgs

+ func (p *IClientRPCServiceDeleteStorageGroupsArgs) LogValue() slog.Value

type IClientRPCServiceDeleteStorageGroupsResult

+ func (p *IClientRPCServiceDeleteStorageGroupsResult) LogValue() slog.Value

type IClientRPCServiceDeleteTimeseriesArgs

+ func (p *IClientRPCServiceDeleteTimeseriesArgs) LogValue() slog.Value

type IClientRPCServiceDeleteTimeseriesResult

+ func (p *IClientRPCServiceDeleteTimeseriesResult) LogValue() slog.Value

type IClientRPCServiceDropSchemaTemplateArgs

+ func (p *IClientRPCServiceDropSchemaTemplateArgs) LogValue() slog.Value

type IClientRPCServiceDropSchemaTemplateResult

+ func (p *IClientRPCServiceDropSchemaTemplateResult) LogValue() slog.Value

type IClientRPCServiceExecuteAggregationQueryArgs

+ func (p *IClientRPCServiceExecuteAggregationQueryArgs) LogValue() slog.Value

type IClientRPCServiceExecuteAggregationQueryResult

+ func (p *IClientRPCServiceExecuteAggregationQueryResult) LogValue() slog.Value

type IClientRPCServiceExecuteAggregationQueryV2Args

+ func (p *IClientRPCServiceExecuteAggregationQueryV2Args) LogValue() slog.Value

type IClientRPCServiceExecuteAggregationQueryV2Result

+ func (p *IClientRPCServiceExecuteAggregationQueryV2Result) LogValue() slog.Value

type IClientRPCServiceExecuteBatchStatementArgs

+ func (p *IClientRPCServiceExecuteBatchStatementArgs) LogValue() slog.Value

type IClientRPCServiceExecuteBatchStatementResult

+ func (p *IClientRPCServiceExecuteBatchStatementResult) LogValue() slog.Value

type IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Args

+ func (p *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Args) LogValue() slog.Value

type IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Result

+ func (p *IClientRPCServiceExecuteFastLastDataQueryForOneDeviceV2Result) LogValue() slog.Value

type IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathArgs

+ func (p *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathArgs) LogValue() slog.Value

type IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathResult

+ func (p *IClientRPCServiceExecuteFastLastDataQueryForOnePrefixPathResult) LogValue() slog.Value

type IClientRPCServiceExecuteLastDataQueryArgs

+ func (p *IClientRPCServiceExecuteLastDataQueryArgs) LogValue() slog.Value

type IClientRPCServiceExecuteLastDataQueryResult

+ func (p *IClientRPCServiceExecuteLastDataQueryResult) LogValue() slog.Value

type IClientRPCServiceExecuteLastDataQueryV2Args

+ func (p *IClientRPCServiceExecuteLastDataQueryV2Args) LogValue() slog.Value

type IClientRPCServiceExecuteLastDataQueryV2Result

+ func (p *IClientRPCServiceExecuteLastDataQueryV2Result) LogValue() slog.Value

type IClientRPCServiceExecutePreparedStatementArgs

+ func (p *IClientRPCServiceExecutePreparedStatementArgs) LogValue() slog.Value

type IClientRPCServiceExecutePreparedStatementResult

+ func (p *IClientRPCServiceExecutePreparedStatementResult) LogValue() slog.Value

type IClientRPCServiceExecuteQueryStatementArgs

+ func (p *IClientRPCServiceExecuteQueryStatementArgs) LogValue() slog.Value

type IClientRPCServiceExecuteQueryStatementResult

+ func (p *IClientRPCServiceExecuteQueryStatementResult) LogValue() slog.Value

type IClientRPCServiceExecuteQueryStatementV2Args

+ func (p *IClientRPCServiceExecuteQueryStatementV2Args) LogValue() slog.Value

type IClientRPCServiceExecuteQueryStatementV2Result

+ func (p *IClientRPCServiceExecuteQueryStatementV2Result) LogValue() slog.Value

type IClientRPCServiceExecuteRawDataQueryArgs

+ func (p *IClientRPCServiceExecuteRawDataQueryArgs) LogValue() slog.Value

type IClientRPCServiceExecuteRawDataQueryResult

+ func (p *IClientRPCServiceExecuteRawDataQueryResult) LogValue() slog.Value

type IClientRPCServiceExecuteRawDataQueryV2Args

+ func (p *IClientRPCServiceExecuteRawDataQueryV2Args) LogValue() slog.Value

type IClientRPCServiceExecuteRawDataQueryV2Result

+ func (p *IClientRPCServiceExecuteRawDataQueryV2Result) LogValue() slog.Value

type IClientRPCServiceExecuteStatementArgs

+ func (p *IClientRPCServiceExecuteStatementArgs) LogValue() slog.Value

type IClientRPCServiceExecuteStatementResult

+ func (p *IClientRPCServiceExecuteStatementResult) LogValue() slog.Value

type IClientRPCServiceExecuteStatementV2Args

+ func (p *IClientRPCServiceExecuteStatementV2Args) LogValue() slog.Value

type IClientRPCServiceExecuteStatementV2Result

+ func (p *IClientRPCServiceExecuteStatementV2Result) LogValue() slog.Value

type IClientRPCServiceExecuteUpdateStatementArgs

+ func (p *IClientRPCServiceExecuteUpdateStatementArgs) LogValue() slog.Value

type IClientRPCServiceExecuteUpdateStatementResult

+ func (p *IClientRPCServiceExecuteUpdateStatementResult) LogValue() slog.Value

type IClientRPCServiceExecuteUpdateStatementV2Args

+ func (p *IClientRPCServiceExecuteUpdateStatementV2Args) LogValue() slog.Value

type IClientRPCServiceExecuteUpdateStatementV2Result

+ func (p *IClientRPCServiceExecuteUpdateStatementV2Result) LogValue() slog.Value

type IClientRPCServiceFetchAllConnectionsInfoArgs

+ func (p *IClientRPCServiceFetchAllConnectionsInfoArgs) LogValue() slog.Value

type IClientRPCServiceFetchAllConnectionsInfoResult

+ func (p *IClientRPCServiceFetchAllConnectionsInfoResult) LogValue() slog.Value

type IClientRPCServiceFetchMetadataArgs

+ func (p *IClientRPCServiceFetchMetadataArgs) LogValue() slog.Value

type IClientRPCServiceFetchMetadataResult

+ func (p *IClientRPCServiceFetchMetadataResult) LogValue() slog.Value

type IClientRPCServiceFetchResultsArgs

+ func (p *IClientRPCServiceFetchResultsArgs) LogValue() slog.Value

type IClientRPCServiceFetchResultsResult

+ func (p *IClientRPCServiceFetchResultsResult) LogValue() slog.Value

type IClientRPCServiceFetchResultsV2Args

+ func (p *IClientRPCServiceFetchResultsV2Args) LogValue() slog.Value

type IClientRPCServiceFetchResultsV2Result

+ func (p *IClientRPCServiceFetchResultsV2Result) LogValue() slog.Value

type IClientRPCServiceGetBackupConfigurationArgs

+ func (p *IClientRPCServiceGetBackupConfigurationArgs) LogValue() slog.Value

type IClientRPCServiceGetBackupConfigurationResult

+ func (p *IClientRPCServiceGetBackupConfigurationResult) LogValue() slog.Value

type IClientRPCServiceGetPropertiesArgs

+ func (p *IClientRPCServiceGetPropertiesArgs) LogValue() slog.Value

type IClientRPCServiceGetPropertiesResult

+ func (p *IClientRPCServiceGetPropertiesResult) LogValue() slog.Value

type IClientRPCServiceGetTimeZoneArgs

+ func (p *IClientRPCServiceGetTimeZoneArgs) LogValue() slog.Value

type IClientRPCServiceGetTimeZoneResult

+ func (p *IClientRPCServiceGetTimeZoneResult) LogValue() slog.Value

type IClientRPCServiceHandshakeArgs

+ func (p *IClientRPCServiceHandshakeArgs) LogValue() slog.Value

type IClientRPCServiceHandshakeResult

+ func (p *IClientRPCServiceHandshakeResult) LogValue() slog.Value

type IClientRPCServiceInsertRecordArgs

+ func (p *IClientRPCServiceInsertRecordArgs) LogValue() slog.Value

type IClientRPCServiceInsertRecordResult

+ func (p *IClientRPCServiceInsertRecordResult) LogValue() slog.Value

type IClientRPCServiceInsertRecordsArgs

+ func (p *IClientRPCServiceInsertRecordsArgs) LogValue() slog.Value

type IClientRPCServiceInsertRecordsOfOneDeviceArgs

+ func (p *IClientRPCServiceInsertRecordsOfOneDeviceArgs) LogValue() slog.Value

type IClientRPCServiceInsertRecordsOfOneDeviceResult

+ func (p *IClientRPCServiceInsertRecordsOfOneDeviceResult) LogValue() slog.Value

type IClientRPCServiceInsertRecordsResult

+ func (p *IClientRPCServiceInsertRecordsResult) LogValue() slog.Value

type IClientRPCServiceInsertStringRecordArgs

+ func (p *IClientRPCServiceInsertStringRecordArgs) LogValue() slog.Value

type IClientRPCServiceInsertStringRecordResult

+ func (p *IClientRPCServiceInsertStringRecordResult) LogValue() slog.Value

type IClientRPCServiceInsertStringRecordsArgs

+ func (p *IClientRPCServiceInsertStringRecordsArgs) LogValue() slog.Value

type IClientRPCServiceInsertStringRecordsOfOneDeviceArgs

+ func (p *IClientRPCServiceInsertStringRecordsOfOneDeviceArgs) LogValue() slog.Value

type IClientRPCServiceInsertStringRecordsOfOneDeviceResult

+ func (p *IClientRPCServiceInsertStringRecordsOfOneDeviceResult) LogValue() slog.Value

type IClientRPCServiceInsertStringRecordsResult

+ func (p *IClientRPCServiceInsertStringRecordsResult) LogValue() slog.Value

type IClientRPCServiceInsertTabletArgs

+ func (p *IClientRPCServiceInsertTabletArgs) LogValue() slog.Value

type IClientRPCServiceInsertTabletResult

+ func (p *IClientRPCServiceInsertTabletResult) LogValue() slog.Value

type IClientRPCServiceInsertTabletsArgs

+ func (p *IClientRPCServiceInsertTabletsArgs) LogValue() slog.Value

type IClientRPCServiceInsertTabletsResult

+ func (p *IClientRPCServiceInsertTabletsResult) LogValue() slog.Value

type IClientRPCServiceOpenSessionArgs

+ func (p *IClientRPCServiceOpenSessionArgs) LogValue() slog.Value

type IClientRPCServiceOpenSessionResult

+ func (p *IClientRPCServiceOpenSessionResult) LogValue() slog.Value

type IClientRPCServicePipeSubscribeArgs

+ func (p *IClientRPCServicePipeSubscribeArgs) LogValue() slog.Value

type IClientRPCServicePipeSubscribeResult

+ func (p *IClientRPCServicePipeSubscribeResult) LogValue() slog.Value

type IClientRPCServicePipeTransferArgs

+ func (p *IClientRPCServicePipeTransferArgs) LogValue() slog.Value

type IClientRPCServicePipeTransferResult

+ func (p *IClientRPCServicePipeTransferResult) LogValue() slog.Value

type IClientRPCServicePrepareStatementArgs

+ func (p *IClientRPCServicePrepareStatementArgs) LogValue() slog.Value

type IClientRPCServicePrepareStatementResult

+ func (p *IClientRPCServicePrepareStatementResult) LogValue() slog.Value

type IClientRPCServicePruneSchemaTemplateArgs

+ func (p *IClientRPCServicePruneSchemaTemplateArgs) LogValue() slog.Value

type IClientRPCServicePruneSchemaTemplateResult

+ func (p *IClientRPCServicePruneSchemaTemplateResult) LogValue() slog.Value

type IClientRPCServiceQuerySchemaTemplateArgs

+ func (p *IClientRPCServiceQuerySchemaTemplateArgs) LogValue() slog.Value

type IClientRPCServiceQuerySchemaTemplateResult

+ func (p *IClientRPCServiceQuerySchemaTemplateResult) LogValue() slog.Value

type IClientRPCServiceRequestStatementIdArgs

+ func (p *IClientRPCServiceRequestStatementIdArgs) LogValue() slog.Value

type IClientRPCServiceRequestStatementIdResult

+ func (p *IClientRPCServiceRequestStatementIdResult) LogValue() slog.Value

type IClientRPCServiceSendFileArgs

+ func (p *IClientRPCServiceSendFileArgs) LogValue() slog.Value

type IClientRPCServiceSendFileResult

+ func (p *IClientRPCServiceSendFileResult) LogValue() slog.Value

type IClientRPCServiceSendPipeDataArgs

+ func (p *IClientRPCServiceSendPipeDataArgs) LogValue() slog.Value

type IClientRPCServiceSendPipeDataResult

+ func (p *IClientRPCServiceSendPipeDataResult) LogValue() slog.Value

type IClientRPCServiceSetSchemaTemplateArgs

+ func (p *IClientRPCServiceSetSchemaTemplateArgs) LogValue() slog.Value

type IClientRPCServiceSetSchemaTemplateResult

+ func (p *IClientRPCServiceSetSchemaTemplateResult) LogValue() slog.Value

type IClientRPCServiceSetStorageGroupArgs

+ func (p *IClientRPCServiceSetStorageGroupArgs) LogValue() slog.Value

type IClientRPCServiceSetStorageGroupResult

+ func (p *IClientRPCServiceSetStorageGroupResult) LogValue() slog.Value

type IClientRPCServiceSetTimeZoneArgs

+ func (p *IClientRPCServiceSetTimeZoneArgs) LogValue() slog.Value

type IClientRPCServiceSetTimeZoneResult

+ func (p *IClientRPCServiceSetTimeZoneResult) LogValue() slog.Value

type IClientRPCServiceShowConfigurationArgs

+ func (p *IClientRPCServiceShowConfigurationArgs) LogValue() slog.Value

type IClientRPCServiceShowConfigurationResult

+ func (p *IClientRPCServiceShowConfigurationResult) LogValue() slog.Value

type IClientRPCServiceShowConfigurationTemplateArgs

+ func (p *IClientRPCServiceShowConfigurationTemplateArgs) LogValue() slog.Value

type IClientRPCServiceShowConfigurationTemplateResult

+ func (p *IClientRPCServiceShowConfigurationTemplateResult) LogValue() slog.Value

type IClientRPCServiceTestConnectionEmptyRPCArgs

+ func (p *IClientRPCServiceTestConnectionEmptyRPCArgs) LogValue() slog.Value

type IClientRPCServiceTestConnectionEmptyRPCResult

+ func (p *IClientRPCServiceTestConnectionEmptyRPCResult) LogValue() slog.Value

type IClientRPCServiceTestInsertRecordArgs

+ func (p *IClientRPCServiceTestInsertRecordArgs) LogValue() slog.Value

type IClientRPCServiceTestInsertRecordResult

+ func (p *IClientRPCServiceTestInsertRecordResult) LogValue() slog.Value

type IClientRPCServiceTestInsertRecordsArgs

+ func (p *IClientRPCServiceTestInsertRecordsArgs) LogValue() slog.Value

type IClientRPCServiceTestInsertRecordsOfOneDeviceArgs

+ func (p *IClientRPCServiceTestInsertRecordsOfOneDeviceArgs) LogValue() slog.Value

type IClientRPCServiceTestInsertRecordsOfOneDeviceResult

+ func (p *IClientRPCServiceTestInsertRecordsOfOneDeviceResult) LogValue() slog.Value

type IClientRPCServiceTestInsertRecordsResult

+ func (p *IClientRPCServiceTestInsertRecordsResult) LogValue() slog.Value

type IClientRPCServiceTestInsertStringRecordArgs

+ func (p *IClientRPCServiceTestInsertStringRecordArgs) LogValue() slog.Value

type IClientRPCServiceTestInsertStringRecordResult

+ func (p *IClientRPCServiceTestInsertStringRecordResult) LogValue() slog.Value

type IClientRPCServiceTestInsertStringRecordsArgs

+ func (p *IClientRPCServiceTestInsertStringRecordsArgs) LogValue() slog.Value

type IClientRPCServiceTestInsertStringRecordsResult

+ func (p *IClientRPCServiceTestInsertStringRecordsResult) LogValue() slog.Value

type IClientRPCServiceTestInsertTabletArgs

+ func (p *IClientRPCServiceTestInsertTabletArgs) LogValue() slog.Value

type IClientRPCServiceTestInsertTabletResult

+ func (p *IClientRPCServiceTestInsertTabletResult) LogValue() slog.Value

type IClientRPCServiceTestInsertTabletsArgs

+ func (p *IClientRPCServiceTestInsertTabletsArgs) LogValue() slog.Value

type IClientRPCServiceTestInsertTabletsResult

+ func (p *IClientRPCServiceTestInsertTabletsResult) LogValue() slog.Value

type IClientRPCServiceUnsetSchemaTemplateArgs

+ func (p *IClientRPCServiceUnsetSchemaTemplateArgs) LogValue() slog.Value

type IClientRPCServiceUnsetSchemaTemplateResult

+ func (p *IClientRPCServiceUnsetSchemaTemplateResult) LogValue() slog.Value

type ServerProperties

+ func (p *ServerProperties) LogValue() slog.Value

+ func (p *ServerProperties) Validate() error

type TCreateTimeseriesUsingSchemaTemplateReq

+ func (p *TCreateTimeseriesUsingSchemaTemplateReq) LogValue() slog.Value

+ func (p *TCreateTimeseriesUsingSchemaTemplateReq) Validate() error

type TPipeSubscribeReq

+ func (p *TPipeSubscribeReq) LogValue() slog.Value

+ func (p *TPipeSubscribeReq) Validate() error

type TPipeSubscribeResp

+ func (p *TPipeSubscribeResp) LogValue() slog.Value

+ func (p *TPipeSubscribeResp) Validate() error

type TPipeTransferReq

+ func (p *TPipeTransferReq) LogValue() slog.Value

+ func (p *TPipeTransferReq) Validate() error

type TPipeTransferResp

+ func (p *TPipeTransferResp) LogValue() slog.Value

+ func (p *TPipeTransferResp) Validate() error

type TSAggregationQueryReq

+ func (p *TSAggregationQueryReq) LogValue() slog.Value

+ func (p *TSAggregationQueryReq) Validate() error

type TSAppendSchemaTemplateReq

+ func (p *TSAppendSchemaTemplateReq) LogValue() slog.Value

+ func (p *TSAppendSchemaTemplateReq) Validate() error

type TSBackupConfigurationResp

+ func (p *TSBackupConfigurationResp) LogValue() slog.Value

+ func (p *TSBackupConfigurationResp) Validate() error

type TSCancelOperationReq

+ func (p *TSCancelOperationReq) LogValue() slog.Value

+ func (p *TSCancelOperationReq) Validate() error

type TSCloseOperationReq

+ func (p *TSCloseOperationReq) LogValue() slog.Value

+ func (p *TSCloseOperationReq) Validate() error

type TSCloseSessionReq

+ func (p *TSCloseSessionReq) LogValue() slog.Value

+ func (p *TSCloseSessionReq) Validate() error

type TSConnectionInfo

+ func (p *TSConnectionInfo) LogValue() slog.Value

+ func (p *TSConnectionInfo) Validate() error

type TSConnectionInfoResp

+ func (p *TSConnectionInfoResp) LogValue() slog.Value

+ func (p *TSConnectionInfoResp) Validate() error

type TSCreateAlignedTimeseriesReq

+ func (p *TSCreateAlignedTimeseriesReq) LogValue() slog.Value

+ func (p *TSCreateAlignedTimeseriesReq) Validate() error

type TSCreateMultiTimeseriesReq

+ func (p *TSCreateMultiTimeseriesReq) LogValue() slog.Value

+ func (p *TSCreateMultiTimeseriesReq) Validate() error

type TSCreateSchemaTemplateReq

+ func (p *TSCreateSchemaTemplateReq) LogValue() slog.Value

+ func (p *TSCreateSchemaTemplateReq) Validate() error

type TSCreateTimeseriesReq

+ func (p *TSCreateTimeseriesReq) LogValue() slog.Value

+ func (p *TSCreateTimeseriesReq) Validate() error

type TSDeallocatePreparedReq

+ func (p *TSDeallocatePreparedReq) LogValue() slog.Value

+ func (p *TSDeallocatePreparedReq) Validate() error

type TSDeleteDataReq

+ func (p *TSDeleteDataReq) LogValue() slog.Value

+ func (p *TSDeleteDataReq) Validate() error

type TSDropSchemaTemplateReq

+ func (p *TSDropSchemaTemplateReq) LogValue() slog.Value

+ func (p *TSDropSchemaTemplateReq) Validate() error

type TSExecuteBatchStatementReq

+ func (p *TSExecuteBatchStatementReq) LogValue() slog.Value

+ func (p *TSExecuteBatchStatementReq) Validate() error

type TSExecutePreparedReq

+ func (p *TSExecutePreparedReq) LogValue() slog.Value

+ func (p *TSExecutePreparedReq) Validate() error

type TSExecuteStatementReq

+ func (p *TSExecuteStatementReq) LogValue() slog.Value

+ func (p *TSExecuteStatementReq) Validate() error

type TSExecuteStatementResp

+ func (p *TSExecuteStatementResp) LogValue() slog.Value

+ func (p *TSExecuteStatementResp) Validate() error

type TSFastLastDataQueryForOneDeviceReq

+ func (p *TSFastLastDataQueryForOneDeviceReq) LogValue() slog.Value

+ func (p *TSFastLastDataQueryForOneDeviceReq) Validate() error

type TSFastLastDataQueryForOnePrefixPathReq

+ func (p *TSFastLastDataQueryForOnePrefixPathReq) LogValue() slog.Value

+ func (p *TSFastLastDataQueryForOnePrefixPathReq) Validate() error

type TSFetchMetadataReq

+ func (p *TSFetchMetadataReq) LogValue() slog.Value

+ func (p *TSFetchMetadataReq) Validate() error

type TSFetchMetadataResp

+ func (p *TSFetchMetadataResp) LogValue() slog.Value

+ func (p *TSFetchMetadataResp) Validate() error

type TSFetchResultsReq

+ func (p *TSFetchResultsReq) LogValue() slog.Value

+ func (p *TSFetchResultsReq) Validate() error

type TSFetchResultsResp

+ func (p *TSFetchResultsResp) LogValue() slog.Value

+ func (p *TSFetchResultsResp) Validate() error

type TSGetOperationStatusReq

+ func (p *TSGetOperationStatusReq) LogValue() slog.Value

+ func (p *TSGetOperationStatusReq) Validate() error

type TSGetTimeZoneResp

+ func (p *TSGetTimeZoneResp) LogValue() slog.Value

+ func (p *TSGetTimeZoneResp) Validate() error

type TSInsertRecordReq

+ func (p *TSInsertRecordReq) LogValue() slog.Value

+ func (p *TSInsertRecordReq) Validate() error

type TSInsertRecordsOfOneDeviceReq

+ func (p *TSInsertRecordsOfOneDeviceReq) LogValue() slog.Value

+ func (p *TSInsertRecordsOfOneDeviceReq) Validate() error

type TSInsertRecordsReq

+ func (p *TSInsertRecordsReq) LogValue() slog.Value

+ func (p *TSInsertRecordsReq) Validate() error

type TSInsertStringRecordReq

+ func (p *TSInsertStringRecordReq) LogValue() slog.Value

+ func (p *TSInsertStringRecordReq) Validate() error

type TSInsertStringRecordsOfOneDeviceReq

+ func (p *TSInsertStringRecordsOfOneDeviceReq) LogValue() slog.Value

+ func (p *TSInsertStringRecordsOfOneDeviceReq) Validate() error

type TSInsertStringRecordsReq

+ func (p *TSInsertStringRecordsReq) LogValue() slog.Value

+ func (p *TSInsertStringRecordsReq) Validate() error

type TSInsertTabletReq

+ func (p *TSInsertTabletReq) LogValue() slog.Value

+ func (p *TSInsertTabletReq) Validate() error

type TSInsertTabletsReq

+ func (p *TSInsertTabletsReq) LogValue() slog.Value

+ func (p *TSInsertTabletsReq) Validate() error

type TSLastDataQueryReq

+ func (p *TSLastDataQueryReq) LogValue() slog.Value

+ func (p *TSLastDataQueryReq) Validate() error

type TSOpenSessionReq

+ func (p *TSOpenSessionReq) LogValue() slog.Value

+ func (p *TSOpenSessionReq) Validate() error

type TSOpenSessionResp

+ func (p *TSOpenSessionResp) LogValue() slog.Value

+ func (p *TSOpenSessionResp) Validate() error

type TSPrepareReq

+ func (p *TSPrepareReq) LogValue() slog.Value

+ func (p *TSPrepareReq) Validate() error

type TSPrepareResp

+ func (p *TSPrepareResp) LogValue() slog.Value

+ func (p *TSPrepareResp) Validate() error

type TSPruneSchemaTemplateReq

+ func (p *TSPruneSchemaTemplateReq) LogValue() slog.Value

+ func (p *TSPruneSchemaTemplateReq) Validate() error

type TSQueryDataSet

+ func (p *TSQueryDataSet) LogValue() slog.Value

+ func (p *TSQueryDataSet) Validate() error

type TSQueryNonAlignDataSet

+ func (p *TSQueryNonAlignDataSet) LogValue() slog.Value

+ func (p *TSQueryNonAlignDataSet) Validate() error

type TSQueryTemplateReq

+ func (p *TSQueryTemplateReq) LogValue() slog.Value

+ func (p *TSQueryTemplateReq) Validate() error

type TSQueryTemplateResp

+ func (p *TSQueryTemplateResp) LogValue() slog.Value

+ func (p *TSQueryTemplateResp) Validate() error

type TSRawDataQueryReq

+ func (p *TSRawDataQueryReq) LogValue() slog.Value

+ func (p *TSRawDataQueryReq) Validate() error

type TSSetSchemaTemplateReq

+ func (p *TSSetSchemaTemplateReq) LogValue() slog.Value

+ func (p *TSSetSchemaTemplateReq) Validate() error

type TSSetTimeZoneReq

+ func (p *TSSetTimeZoneReq) LogValue() slog.Value

+ func (p *TSSetTimeZoneReq) Validate() error

type TSTracingInfo

+ func (p *TSTracingInfo) LogValue() slog.Value

+ func (p *TSTracingInfo) Validate() error

type TSUnsetSchemaTemplateReq

+ func (p *TSUnsetSchemaTemplateReq) LogValue() slog.Value

+ func (p *TSUnsetSchemaTemplateReq) Validate() error

type TSyncIdentityInfo

+ func (p *TSyncIdentityInfo) LogValue() slog.Value

+ func (p *TSyncIdentityInfo) Validate() error

type TSyncTransportMetaInfo

+ func (p *TSyncTransportMetaInfo) LogValue() slog.Value

+ func (p *TSyncTransportMetaInfo) Validate() error

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL