rpc

package
v1.1.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 25, 2023 License: Apache-2.0 Imports: 8 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source
var GoUnusedProtection__ int
View Source
var IClientRPCServiceAppendSchemaTemplateResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceCancelOperationResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceCloseOperationResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceCloseSessionResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceCreateAlignedTimeseriesResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceCreateMultiTimeseriesResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceCreateSchemaTemplateResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceCreateTimeseriesResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceDeleteDataResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceDeleteStorageGroupsResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceDeleteTimeseriesResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceDropSchemaTemplateResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceExecuteBatchStatementResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceFastInsertRecordsResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceHandshakeResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceInsertRecordResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceInsertRecordsOfOneDeviceResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceInsertRecordsResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceInsertStringRecordResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceInsertStringRecordsOfOneDeviceResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceInsertStringRecordsResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceInsertTabletResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceInsertTabletsResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServicePruneSchemaTemplateResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceRequestStatementIdResult_Success_DEFAULT int64
View Source
var IClientRPCServiceSendFileResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceSendPipeDataResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceSetSchemaTemplateResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceSetStorageGroupResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceSetTimeZoneResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceTestInsertRecordResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceTestInsertRecordsOfOneDeviceResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceTestInsertRecordsResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceTestInsertStringRecordResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceTestInsertStringRecordsResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceTestInsertTabletResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceTestInsertTabletsResult_Success_DEFAULT *common.TSStatus
View Source
var IClientRPCServiceUnsetSchemaTemplateResult_Success_DEFAULT *common.TSStatus
View Source
var ServerProperties_BuildInfo_DEFAULT string
View Source
var ServerProperties_IsReadOnly_DEFAULT bool
View Source
var ServerProperties_Logo_DEFAULT string
View Source
var ServerProperties_ThriftMaxFrameSize_DEFAULT int32
View Source
var ServerProperties_WatermarkBitString_DEFAULT string
View Source
var ServerProperties_WatermarkParamMarkRate_DEFAULT int32
View Source
var ServerProperties_WatermarkParamMaxRightBit_DEFAULT int32
View Source
var ServerProperties_WatermarkSecretKey_DEFAULT string
View Source
var TSAggregationQueryReq_EndTime_DEFAULT int64
View Source
var TSAggregationQueryReq_FetchSize_DEFAULT int32
View Source
var TSAggregationQueryReq_Interval_DEFAULT int64
View Source
var TSAggregationQueryReq_SlidingStep_DEFAULT int64
View Source
var TSAggregationQueryReq_StartTime_DEFAULT int64
View Source
var TSAggregationQueryReq_Timeout_DEFAULT int64
View Source
var TSBackupConfigurationResp_EnableOperationSync_DEFAULT bool
View Source
var TSBackupConfigurationResp_SecondaryAddress_DEFAULT string
View Source
var TSBackupConfigurationResp_SecondaryPort_DEFAULT int32
View Source
var TSBackupConfigurationResp_Status_DEFAULT *common.TSStatus
View Source
var TSCloseOperationReq_QueryId_DEFAULT int64
View Source
var TSCloseOperationReq_StatementId_DEFAULT int64
View Source
var TSCreateAlignedTimeseriesReq_AttributesList_DEFAULT []map[string]string
View Source
var TSCreateAlignedTimeseriesReq_MeasurementAlias_DEFAULT []string
View Source
var TSCreateAlignedTimeseriesReq_TagsList_DEFAULT []map[string]string
View Source
var TSCreateMultiTimeseriesReq_AttributesList_DEFAULT []map[string]string
View Source
var TSCreateMultiTimeseriesReq_MeasurementAliasList_DEFAULT []string
View Source
var TSCreateMultiTimeseriesReq_PropsList_DEFAULT []map[string]string
View Source
var TSCreateMultiTimeseriesReq_TagsList_DEFAULT []map[string]string
View Source
var TSCreateTimeseriesReq_Attributes_DEFAULT map[string]string
View Source
var TSCreateTimeseriesReq_MeasurementAlias_DEFAULT string
View Source
var TSCreateTimeseriesReq_Props_DEFAULT map[string]string
View Source
var TSCreateTimeseriesReq_Tags_DEFAULT map[string]string
View Source
var TSExecuteStatementReq_EnableRedirectQuery_DEFAULT bool
View Source
var TSExecuteStatementReq_FetchSize_DEFAULT int32
View Source
var TSExecuteStatementReq_JdbcQuery_DEFAULT bool
View Source
var TSExecuteStatementReq_Timeout_DEFAULT int64
View Source
var TSExecuteStatementResp_AliasColumns_DEFAULT []int8
View Source
var TSExecuteStatementResp_ColumnNameIndexMap_DEFAULT map[string]int32
View Source
var TSExecuteStatementResp_Columns_DEFAULT []string
View Source
var TSExecuteStatementResp_DataTypeList_DEFAULT []string
View Source
var TSExecuteStatementResp_IgnoreTimeStamp_DEFAULT bool
View Source
var TSExecuteStatementResp_MoreData_DEFAULT bool
View Source
var TSExecuteStatementResp_OperationType_DEFAULT string
View Source
var TSExecuteStatementResp_QueryId_DEFAULT int64
View Source
var TSExecuteStatementResp_QueryResult__DEFAULT [][]byte
View Source
var TSExecuteStatementResp_SgColumns_DEFAULT []string
View Source
var TSExecuteStatementResp_Status_DEFAULT *common.TSStatus
View Source
var TSFetchMetadataReq_ColumnPath_DEFAULT string
View Source
var TSFetchMetadataResp_ColumnsList_DEFAULT []string
View Source
var TSFetchMetadataResp_DataType_DEFAULT string
View Source
var TSFetchMetadataResp_MetadataInJson_DEFAULT string
View Source
var TSFetchMetadataResp_Status_DEFAULT *common.TSStatus
View Source
var TSFetchResultsReq_Timeout_DEFAULT int64
View Source
var TSFetchResultsResp_MoreData_DEFAULT bool
View Source
var TSFetchResultsResp_QueryResult__DEFAULT [][]byte
View Source
var TSFetchResultsResp_Status_DEFAULT *common.TSStatus
View Source
var TSGetTimeZoneResp_Status_DEFAULT *common.TSStatus
View Source
var TSInsertRecordReq_IsAligned_DEFAULT bool
View Source
var TSInsertRecordsOfOneDeviceReq_IsAligned_DEFAULT bool
View Source
var TSInsertRecordsReq_IsAligned_DEFAULT bool
View Source
var TSInsertStringRecordReq_IsAligned_DEFAULT bool
View Source
var TSInsertStringRecordReq_Timeout_DEFAULT int64
View Source
var TSInsertStringRecordsOfOneDeviceReq_IsAligned_DEFAULT bool
View Source
var TSInsertStringRecordsReq_IsAligned_DEFAULT bool
View Source
var TSInsertTabletReq_IsAligned_DEFAULT bool
View Source
var TSInsertTabletsReq_IsAligned_DEFAULT bool
View Source
var TSLastDataQueryReq_EnableRedirectQuery_DEFAULT bool
View Source
var TSLastDataQueryReq_FetchSize_DEFAULT int32
View Source
var TSLastDataQueryReq_JdbcQuery_DEFAULT bool
View Source
var TSLastDataQueryReq_Timeout_DEFAULT int64
View Source
var TSOpenSessionReq_Configuration_DEFAULT map[string]string
View Source
var TSOpenSessionReq_Password_DEFAULT string
View Source
var TSOpenSessionResp_Configuration_DEFAULT map[string]string
View Source
var TSOpenSessionResp_SessionId_DEFAULT int64
View Source
var TSOpenSessionResp_Status_DEFAULT *common.TSStatus
View Source
var TSQueryTemplateReq_Measurement_DEFAULT string
View Source
var TSQueryTemplateResp_Count_DEFAULT int32
View Source
var TSQueryTemplateResp_Measurements_DEFAULT []string
View Source
var TSQueryTemplateResp_Result__DEFAULT bool
View Source
var TSQueryTemplateResp_Status_DEFAULT *common.TSStatus
View Source
var TSRawDataQueryReq_EnableRedirectQuery_DEFAULT bool
View Source
var TSRawDataQueryReq_FetchSize_DEFAULT int32
View Source
var TSRawDataQueryReq_JdbcQuery_DEFAULT bool
View Source
var TSRawDataQueryReq_Timeout_DEFAULT int64
View Source
var TSTracingInfo_OverlappedPageNum_DEFAULT int32
View Source
var TSTracingInfo_SeqFileNum_DEFAULT int32
View Source
var TSTracingInfo_SequenceChunkNum_DEFAULT int32
View Source
var TSTracingInfo_SequenceChunkPointNum_DEFAULT int64
View Source
var TSTracingInfo_SeriesPathNum_DEFAULT int32
View Source
var TSTracingInfo_TotalPageNum_DEFAULT int32
View Source
var TSTracingInfo_UnSeqFileNum_DEFAULT int32
View Source
var TSTracingInfo_UnsequenceChunkNum_DEFAULT int32
View Source
var TSTracingInfo_UnsequenceChunkPointNum_DEFAULT int64

Functions

This section is empty.

Types

type IClientRPCService added in v1.1.5

type IClientRPCService interface {
	// Parameters:
	//  - Req
	ExecuteQueryStatementV2(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error)
	// Parameters:
	//  - Req
	ExecuteUpdateStatementV2(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error)
	// Parameters:
	//  - Req
	ExecuteStatementV2(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error)
	// Parameters:
	//  - Req
	ExecuteRawDataQueryV2(ctx context.Context, req *TSRawDataQueryReq) (_r *TSExecuteStatementResp, _err error)
	// Parameters:
	//  - Req
	ExecuteLastDataQueryV2(ctx context.Context, req *TSLastDataQueryReq) (_r *TSExecuteStatementResp, _err error)
	// Parameters:
	//  - Req
	ExecuteAggregationQueryV2(ctx context.Context, req *TSAggregationQueryReq) (_r *TSExecuteStatementResp, _err error)
	// Parameters:
	//  - Req
	FetchResultsV2(ctx context.Context, req *TSFetchResultsReq) (_r *TSFetchResultsResp, _err error)
	// Parameters:
	//  - Req
	OpenSession(ctx context.Context, req *TSOpenSessionReq) (_r *TSOpenSessionResp, _err error)
	// Parameters:
	//  - Req
	CloseSession(ctx context.Context, req *TSCloseSessionReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	ExecuteStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error)
	// Parameters:
	//  - Req
	ExecuteBatchStatement(ctx context.Context, req *TSExecuteBatchStatementReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	ExecuteQueryStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error)
	// Parameters:
	//  - Req
	ExecuteUpdateStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error)
	// Parameters:
	//  - Req
	FetchResults(ctx context.Context, req *TSFetchResultsReq) (_r *TSFetchResultsResp, _err error)
	// Parameters:
	//  - Req
	FetchMetadata(ctx context.Context, req *TSFetchMetadataReq) (_r *TSFetchMetadataResp, _err error)
	// Parameters:
	//  - Req
	CancelOperation(ctx context.Context, req *TSCancelOperationReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	CloseOperation(ctx context.Context, req *TSCloseOperationReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - SessionId
	GetTimeZone(ctx context.Context, sessionId int64) (_r *TSGetTimeZoneResp, _err error)
	// Parameters:
	//  - Req
	SetTimeZone(ctx context.Context, req *TSSetTimeZoneReq) (_r *common.TSStatus, _err error)
	GetProperties(ctx context.Context) (_r *ServerProperties, _err error)
	// Parameters:
	//  - SessionId
	//  - StorageGroup
	SetStorageGroup(ctx context.Context, sessionId int64, storageGroup string) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	CreateTimeseries(ctx context.Context, req *TSCreateTimeseriesReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	CreateAlignedTimeseries(ctx context.Context, req *TSCreateAlignedTimeseriesReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	CreateMultiTimeseries(ctx context.Context, req *TSCreateMultiTimeseriesReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - SessionId
	//  - Path
	DeleteTimeseries(ctx context.Context, sessionId int64, path []string) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - SessionId
	//  - StorageGroup
	DeleteStorageGroups(ctx context.Context, sessionId int64, storageGroup []string) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertRecord(ctx context.Context, req *TSInsertRecordReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertStringRecord(ctx context.Context, req *TSInsertStringRecordReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertTablet(ctx context.Context, req *TSInsertTabletReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertTablets(ctx context.Context, req *TSInsertTabletsReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertRecords(ctx context.Context, req *TSInsertRecordsReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	FastInsertRecords(ctx context.Context, req *TSFastInsertRecordsReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertRecordsOfOneDevice(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertStringRecordsOfOneDevice(ctx context.Context, req *TSInsertStringRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertStringRecords(ctx context.Context, req *TSInsertStringRecordsReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	TestInsertTablet(ctx context.Context, req *TSInsertTabletReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	TestInsertTablets(ctx context.Context, req *TSInsertTabletsReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	TestInsertRecord(ctx context.Context, req *TSInsertRecordReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	TestInsertStringRecord(ctx context.Context, req *TSInsertStringRecordReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	TestInsertRecords(ctx context.Context, req *TSInsertRecordsReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	TestInsertRecordsOfOneDevice(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	TestInsertStringRecords(ctx context.Context, req *TSInsertStringRecordsReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	DeleteData(ctx context.Context, req *TSDeleteDataReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	ExecuteRawDataQuery(ctx context.Context, req *TSRawDataQueryReq) (_r *TSExecuteStatementResp, _err error)
	// Parameters:
	//  - Req
	ExecuteLastDataQuery(ctx context.Context, req *TSLastDataQueryReq) (_r *TSExecuteStatementResp, _err error)
	// Parameters:
	//  - Req
	ExecuteAggregationQuery(ctx context.Context, req *TSAggregationQueryReq) (_r *TSExecuteStatementResp, _err error)
	// Parameters:
	//  - SessionId
	RequestStatementId(ctx context.Context, sessionId int64) (_r int64, _err error)
	// Parameters:
	//  - Req
	CreateSchemaTemplate(ctx context.Context, req *TSCreateSchemaTemplateReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	AppendSchemaTemplate(ctx context.Context, req *TSAppendSchemaTemplateReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	PruneSchemaTemplate(ctx context.Context, req *TSPruneSchemaTemplateReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	QuerySchemaTemplate(ctx context.Context, req *TSQueryTemplateReq) (_r *TSQueryTemplateResp, _err error)
	// Parameters:
	//  - Req
	SetSchemaTemplate(ctx context.Context, req *TSSetSchemaTemplateReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	UnsetSchemaTemplate(ctx context.Context, req *TSUnsetSchemaTemplateReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	DropSchemaTemplate(ctx context.Context, req *TSDropSchemaTemplateReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Req
	CreateTimeseriesUsingSchemaTemplate(ctx context.Context, req *TCreateTimeseriesUsingSchemaTemplateReq) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Info
	Handshake(ctx context.Context, info *TSyncIdentityInfo) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - Buff
	SendPipeData(ctx context.Context, buff []byte) (_r *common.TSStatus, _err error)
	// Parameters:
	//  - MetaInfo
	//  - Buff
	SendFile(ctx context.Context, metaInfo *TSyncTransportMetaInfo, buff []byte) (_r *common.TSStatus, _err error)
	GetBackupConfiguration(ctx context.Context) (_r *TSBackupConfigurationResp, _err error)
	FetchAllConnectionsInfo(ctx context.Context) (_r *TSConnectionInfoResp, _err error)
}

type IClientRPCServiceAppendSchemaTemplateArgs added in v1.1.5

type IClientRPCServiceAppendSchemaTemplateArgs struct {
	Req *TSAppendSchemaTemplateReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceAppendSchemaTemplateArgs added in v1.1.5

func NewIClientRPCServiceAppendSchemaTemplateArgs() *IClientRPCServiceAppendSchemaTemplateArgs

func (*IClientRPCServiceAppendSchemaTemplateArgs) GetReq added in v1.1.5

func (*IClientRPCServiceAppendSchemaTemplateArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceAppendSchemaTemplateArgs) Read added in v1.1.5

func (*IClientRPCServiceAppendSchemaTemplateArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceAppendSchemaTemplateArgs) String added in v1.1.5

func (*IClientRPCServiceAppendSchemaTemplateArgs) Write added in v1.1.5

type IClientRPCServiceAppendSchemaTemplateResult added in v1.1.5

type IClientRPCServiceAppendSchemaTemplateResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceAppendSchemaTemplateResult added in v1.1.5

func NewIClientRPCServiceAppendSchemaTemplateResult() *IClientRPCServiceAppendSchemaTemplateResult

func (*IClientRPCServiceAppendSchemaTemplateResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceAppendSchemaTemplateResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceAppendSchemaTemplateResult) Read added in v1.1.5

func (*IClientRPCServiceAppendSchemaTemplateResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceAppendSchemaTemplateResult) String added in v1.1.5

func (*IClientRPCServiceAppendSchemaTemplateResult) Write added in v1.1.5

type IClientRPCServiceCancelOperationArgs added in v1.1.5

type IClientRPCServiceCancelOperationArgs struct {
	Req *TSCancelOperationReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceCancelOperationArgs added in v1.1.5

func NewIClientRPCServiceCancelOperationArgs() *IClientRPCServiceCancelOperationArgs

func (*IClientRPCServiceCancelOperationArgs) GetReq added in v1.1.5

func (*IClientRPCServiceCancelOperationArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceCancelOperationArgs) Read added in v1.1.5

func (*IClientRPCServiceCancelOperationArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceCancelOperationArgs) String added in v1.1.5

func (*IClientRPCServiceCancelOperationArgs) Write added in v1.1.5

type IClientRPCServiceCancelOperationResult added in v1.1.5

type IClientRPCServiceCancelOperationResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceCancelOperationResult added in v1.1.5

func NewIClientRPCServiceCancelOperationResult() *IClientRPCServiceCancelOperationResult

func (*IClientRPCServiceCancelOperationResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceCancelOperationResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceCancelOperationResult) IsSetSuccess() bool

func (*IClientRPCServiceCancelOperationResult) Read added in v1.1.5

func (*IClientRPCServiceCancelOperationResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceCancelOperationResult) String added in v1.1.5

func (*IClientRPCServiceCancelOperationResult) Write added in v1.1.5

type IClientRPCServiceClient added in v1.1.5

type IClientRPCServiceClient struct {
	// contains filtered or unexported fields
}

func NewIClientRPCServiceClient added in v1.1.5

func NewIClientRPCServiceClient(c thrift.TClient) *IClientRPCServiceClient

func NewIClientRPCServiceClientFactory added in v1.1.5

func NewIClientRPCServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *IClientRPCServiceClient

func NewIClientRPCServiceClientProtocol added in v1.1.5

func NewIClientRPCServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *IClientRPCServiceClient

func (*IClientRPCServiceClient) AppendSchemaTemplate added in v1.1.5

func (p *IClientRPCServiceClient) AppendSchemaTemplate(ctx context.Context, req *TSAppendSchemaTemplateReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) CancelOperation added in v1.1.5

func (p *IClientRPCServiceClient) CancelOperation(ctx context.Context, req *TSCancelOperationReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) Client_ added in v1.1.5

func (p *IClientRPCServiceClient) Client_() thrift.TClient

func (*IClientRPCServiceClient) CloseOperation added in v1.1.5

func (p *IClientRPCServiceClient) CloseOperation(ctx context.Context, req *TSCloseOperationReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) CloseSession added in v1.1.5

func (p *IClientRPCServiceClient) CloseSession(ctx context.Context, req *TSCloseSessionReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) CreateAlignedTimeseries added in v1.1.5

func (p *IClientRPCServiceClient) CreateAlignedTimeseries(ctx context.Context, req *TSCreateAlignedTimeseriesReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) CreateMultiTimeseries added in v1.1.5

func (p *IClientRPCServiceClient) CreateMultiTimeseries(ctx context.Context, req *TSCreateMultiTimeseriesReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) CreateSchemaTemplate added in v1.1.5

func (p *IClientRPCServiceClient) CreateSchemaTemplate(ctx context.Context, req *TSCreateSchemaTemplateReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) CreateTimeseries added in v1.1.5

func (p *IClientRPCServiceClient) CreateTimeseries(ctx context.Context, req *TSCreateTimeseriesReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) CreateTimeseriesUsingSchemaTemplate added in v1.1.5

func (p *IClientRPCServiceClient) CreateTimeseriesUsingSchemaTemplate(ctx context.Context, req *TCreateTimeseriesUsingSchemaTemplateReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) DeleteData added in v1.1.5

func (p *IClientRPCServiceClient) DeleteData(ctx context.Context, req *TSDeleteDataReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) DeleteStorageGroups added in v1.1.5

func (p *IClientRPCServiceClient) DeleteStorageGroups(ctx context.Context, sessionId int64, storageGroup []string) (_r *common.TSStatus, _err error)

Parameters:

  • SessionId
  • StorageGroup

func (*IClientRPCServiceClient) DeleteTimeseries added in v1.1.5

func (p *IClientRPCServiceClient) DeleteTimeseries(ctx context.Context, sessionId int64, path []string) (_r *common.TSStatus, _err error)

Parameters:

  • SessionId
  • Path

func (*IClientRPCServiceClient) DropSchemaTemplate added in v1.1.5

func (p *IClientRPCServiceClient) DropSchemaTemplate(ctx context.Context, req *TSDropSchemaTemplateReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) ExecuteAggregationQuery added in v1.1.5

func (p *IClientRPCServiceClient) ExecuteAggregationQuery(ctx context.Context, req *TSAggregationQueryReq) (_r *TSExecuteStatementResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) ExecuteAggregationQueryV2 added in v1.1.5

func (p *IClientRPCServiceClient) ExecuteAggregationQueryV2(ctx context.Context, req *TSAggregationQueryReq) (_r *TSExecuteStatementResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) ExecuteBatchStatement added in v1.1.5

func (p *IClientRPCServiceClient) ExecuteBatchStatement(ctx context.Context, req *TSExecuteBatchStatementReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) ExecuteLastDataQuery added in v1.1.5

func (p *IClientRPCServiceClient) ExecuteLastDataQuery(ctx context.Context, req *TSLastDataQueryReq) (_r *TSExecuteStatementResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) ExecuteLastDataQueryV2 added in v1.1.5

func (p *IClientRPCServiceClient) ExecuteLastDataQueryV2(ctx context.Context, req *TSLastDataQueryReq) (_r *TSExecuteStatementResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) ExecuteQueryStatement added in v1.1.5

func (p *IClientRPCServiceClient) ExecuteQueryStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) ExecuteQueryStatementV2 added in v1.1.5

func (p *IClientRPCServiceClient) ExecuteQueryStatementV2(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) ExecuteRawDataQuery added in v1.1.5

func (p *IClientRPCServiceClient) ExecuteRawDataQuery(ctx context.Context, req *TSRawDataQueryReq) (_r *TSExecuteStatementResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) ExecuteRawDataQueryV2 added in v1.1.5

func (p *IClientRPCServiceClient) ExecuteRawDataQueryV2(ctx context.Context, req *TSRawDataQueryReq) (_r *TSExecuteStatementResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) ExecuteStatement added in v1.1.5

func (p *IClientRPCServiceClient) ExecuteStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) ExecuteStatementV2 added in v1.1.5

func (p *IClientRPCServiceClient) ExecuteStatementV2(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) ExecuteUpdateStatement added in v1.1.5

func (p *IClientRPCServiceClient) ExecuteUpdateStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) ExecuteUpdateStatementV2 added in v1.1.5

func (p *IClientRPCServiceClient) ExecuteUpdateStatementV2(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) FastInsertRecords added in v1.1.6

func (p *IClientRPCServiceClient) FastInsertRecords(ctx context.Context, req *TSFastInsertRecordsReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) FetchAllConnectionsInfo added in v1.1.5

func (p *IClientRPCServiceClient) FetchAllConnectionsInfo(ctx context.Context) (_r *TSConnectionInfoResp, _err error)

func (*IClientRPCServiceClient) FetchMetadata added in v1.1.5

func (p *IClientRPCServiceClient) FetchMetadata(ctx context.Context, req *TSFetchMetadataReq) (_r *TSFetchMetadataResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) FetchResults added in v1.1.5

func (p *IClientRPCServiceClient) FetchResults(ctx context.Context, req *TSFetchResultsReq) (_r *TSFetchResultsResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) FetchResultsV2 added in v1.1.5

func (p *IClientRPCServiceClient) FetchResultsV2(ctx context.Context, req *TSFetchResultsReq) (_r *TSFetchResultsResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) GetBackupConfiguration added in v1.1.5

func (p *IClientRPCServiceClient) GetBackupConfiguration(ctx context.Context) (_r *TSBackupConfigurationResp, _err error)

func (*IClientRPCServiceClient) GetProperties added in v1.1.5

func (p *IClientRPCServiceClient) GetProperties(ctx context.Context) (_r *ServerProperties, _err error)

func (*IClientRPCServiceClient) GetTimeZone added in v1.1.5

func (p *IClientRPCServiceClient) GetTimeZone(ctx context.Context, sessionId int64) (_r *TSGetTimeZoneResp, _err error)

Parameters:

  • SessionId

func (*IClientRPCServiceClient) Handshake added in v1.1.5

func (p *IClientRPCServiceClient) Handshake(ctx context.Context, info *TSyncIdentityInfo) (_r *common.TSStatus, _err error)

Parameters:

  • Info

func (*IClientRPCServiceClient) InsertRecord added in v1.1.5

func (p *IClientRPCServiceClient) InsertRecord(ctx context.Context, req *TSInsertRecordReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) InsertRecords added in v1.1.5

func (p *IClientRPCServiceClient) InsertRecords(ctx context.Context, req *TSInsertRecordsReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) InsertRecordsOfOneDevice added in v1.1.5

func (p *IClientRPCServiceClient) InsertRecordsOfOneDevice(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) InsertStringRecord added in v1.1.5

func (p *IClientRPCServiceClient) InsertStringRecord(ctx context.Context, req *TSInsertStringRecordReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) InsertStringRecords added in v1.1.5

func (p *IClientRPCServiceClient) InsertStringRecords(ctx context.Context, req *TSInsertStringRecordsReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) InsertStringRecordsOfOneDevice added in v1.1.5

func (p *IClientRPCServiceClient) InsertStringRecordsOfOneDevice(ctx context.Context, req *TSInsertStringRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) InsertTablet added in v1.1.5

func (p *IClientRPCServiceClient) InsertTablet(ctx context.Context, req *TSInsertTabletReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) InsertTablets added in v1.1.5

func (p *IClientRPCServiceClient) InsertTablets(ctx context.Context, req *TSInsertTabletsReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) LastResponseMeta_ added in v1.1.5

func (p *IClientRPCServiceClient) LastResponseMeta_() thrift.ResponseMeta

func (*IClientRPCServiceClient) OpenSession added in v1.1.5

func (p *IClientRPCServiceClient) OpenSession(ctx context.Context, req *TSOpenSessionReq) (_r *TSOpenSessionResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) PruneSchemaTemplate added in v1.1.5

func (p *IClientRPCServiceClient) PruneSchemaTemplate(ctx context.Context, req *TSPruneSchemaTemplateReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) QuerySchemaTemplate added in v1.1.5

func (p *IClientRPCServiceClient) QuerySchemaTemplate(ctx context.Context, req *TSQueryTemplateReq) (_r *TSQueryTemplateResp, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) RequestStatementId added in v1.1.5

func (p *IClientRPCServiceClient) RequestStatementId(ctx context.Context, sessionId int64) (_r int64, _err error)

Parameters:

  • SessionId

func (*IClientRPCServiceClient) SendFile added in v1.1.5

func (p *IClientRPCServiceClient) SendFile(ctx context.Context, metaInfo *TSyncTransportMetaInfo, buff []byte) (_r *common.TSStatus, _err error)

Parameters:

  • MetaInfo
  • Buff

func (*IClientRPCServiceClient) SendPipeData added in v1.1.5

func (p *IClientRPCServiceClient) SendPipeData(ctx context.Context, buff []byte) (_r *common.TSStatus, _err error)

Parameters:

  • Buff

func (*IClientRPCServiceClient) SetLastResponseMeta_ added in v1.1.5

func (p *IClientRPCServiceClient) SetLastResponseMeta_(meta thrift.ResponseMeta)

func (*IClientRPCServiceClient) SetSchemaTemplate added in v1.1.5

func (p *IClientRPCServiceClient) SetSchemaTemplate(ctx context.Context, req *TSSetSchemaTemplateReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) SetStorageGroup added in v1.1.5

func (p *IClientRPCServiceClient) SetStorageGroup(ctx context.Context, sessionId int64, storageGroup string) (_r *common.TSStatus, _err error)

Parameters:

  • SessionId
  • StorageGroup

func (*IClientRPCServiceClient) SetTimeZone added in v1.1.5

func (p *IClientRPCServiceClient) SetTimeZone(ctx context.Context, req *TSSetTimeZoneReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) TestInsertRecord added in v1.1.5

func (p *IClientRPCServiceClient) TestInsertRecord(ctx context.Context, req *TSInsertRecordReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) TestInsertRecords added in v1.1.5

func (p *IClientRPCServiceClient) TestInsertRecords(ctx context.Context, req *TSInsertRecordsReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) TestInsertRecordsOfOneDevice added in v1.1.5

func (p *IClientRPCServiceClient) TestInsertRecordsOfOneDevice(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) TestInsertStringRecord added in v1.1.5

func (p *IClientRPCServiceClient) TestInsertStringRecord(ctx context.Context, req *TSInsertStringRecordReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) TestInsertStringRecords added in v1.1.5

func (p *IClientRPCServiceClient) TestInsertStringRecords(ctx context.Context, req *TSInsertStringRecordsReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) TestInsertTablet added in v1.1.5

func (p *IClientRPCServiceClient) TestInsertTablet(ctx context.Context, req *TSInsertTabletReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) TestInsertTablets added in v1.1.5

func (p *IClientRPCServiceClient) TestInsertTablets(ctx context.Context, req *TSInsertTabletsReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

func (*IClientRPCServiceClient) UnsetSchemaTemplate added in v1.1.5

func (p *IClientRPCServiceClient) UnsetSchemaTemplate(ctx context.Context, req *TSUnsetSchemaTemplateReq) (_r *common.TSStatus, _err error)

Parameters:

  • Req

type IClientRPCServiceCloseOperationArgs added in v1.1.5

type IClientRPCServiceCloseOperationArgs struct {
	Req *TSCloseOperationReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceCloseOperationArgs added in v1.1.5

func NewIClientRPCServiceCloseOperationArgs() *IClientRPCServiceCloseOperationArgs

func (*IClientRPCServiceCloseOperationArgs) GetReq added in v1.1.5

func (*IClientRPCServiceCloseOperationArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceCloseOperationArgs) Read added in v1.1.5

func (*IClientRPCServiceCloseOperationArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceCloseOperationArgs) String added in v1.1.5

func (*IClientRPCServiceCloseOperationArgs) Write added in v1.1.5

type IClientRPCServiceCloseOperationResult added in v1.1.5

type IClientRPCServiceCloseOperationResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceCloseOperationResult added in v1.1.5

func NewIClientRPCServiceCloseOperationResult() *IClientRPCServiceCloseOperationResult

func (*IClientRPCServiceCloseOperationResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceCloseOperationResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceCloseOperationResult) IsSetSuccess() bool

func (*IClientRPCServiceCloseOperationResult) Read added in v1.1.5

func (*IClientRPCServiceCloseOperationResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceCloseOperationResult) String added in v1.1.5

func (*IClientRPCServiceCloseOperationResult) Write added in v1.1.5

type IClientRPCServiceCloseSessionArgs added in v1.1.5

type IClientRPCServiceCloseSessionArgs struct {
	Req *TSCloseSessionReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceCloseSessionArgs added in v1.1.5

func NewIClientRPCServiceCloseSessionArgs() *IClientRPCServiceCloseSessionArgs

func (*IClientRPCServiceCloseSessionArgs) GetReq added in v1.1.5

func (*IClientRPCServiceCloseSessionArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceCloseSessionArgs) Read added in v1.1.5

func (*IClientRPCServiceCloseSessionArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceCloseSessionArgs) String added in v1.1.5

func (*IClientRPCServiceCloseSessionArgs) Write added in v1.1.5

type IClientRPCServiceCloseSessionResult added in v1.1.5

type IClientRPCServiceCloseSessionResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceCloseSessionResult added in v1.1.5

func NewIClientRPCServiceCloseSessionResult() *IClientRPCServiceCloseSessionResult

func (*IClientRPCServiceCloseSessionResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceCloseSessionResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceCloseSessionResult) IsSetSuccess() bool

func (*IClientRPCServiceCloseSessionResult) Read added in v1.1.5

func (*IClientRPCServiceCloseSessionResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceCloseSessionResult) String added in v1.1.5

func (*IClientRPCServiceCloseSessionResult) Write added in v1.1.5

type IClientRPCServiceCreateAlignedTimeseriesArgs added in v1.1.5

type IClientRPCServiceCreateAlignedTimeseriesArgs struct {
	Req *TSCreateAlignedTimeseriesReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceCreateAlignedTimeseriesArgs added in v1.1.5

func NewIClientRPCServiceCreateAlignedTimeseriesArgs() *IClientRPCServiceCreateAlignedTimeseriesArgs

func (*IClientRPCServiceCreateAlignedTimeseriesArgs) GetReq added in v1.1.5

func (*IClientRPCServiceCreateAlignedTimeseriesArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceCreateAlignedTimeseriesArgs) Read added in v1.1.5

func (*IClientRPCServiceCreateAlignedTimeseriesArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceCreateAlignedTimeseriesArgs) String added in v1.1.5

func (*IClientRPCServiceCreateAlignedTimeseriesArgs) Write added in v1.1.5

type IClientRPCServiceCreateAlignedTimeseriesResult added in v1.1.5

type IClientRPCServiceCreateAlignedTimeseriesResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceCreateAlignedTimeseriesResult added in v1.1.5

func NewIClientRPCServiceCreateAlignedTimeseriesResult() *IClientRPCServiceCreateAlignedTimeseriesResult

func (*IClientRPCServiceCreateAlignedTimeseriesResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceCreateAlignedTimeseriesResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceCreateAlignedTimeseriesResult) Read added in v1.1.5

func (*IClientRPCServiceCreateAlignedTimeseriesResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceCreateAlignedTimeseriesResult) String added in v1.1.5

func (*IClientRPCServiceCreateAlignedTimeseriesResult) Write added in v1.1.5

type IClientRPCServiceCreateMultiTimeseriesArgs added in v1.1.5

type IClientRPCServiceCreateMultiTimeseriesArgs struct {
	Req *TSCreateMultiTimeseriesReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceCreateMultiTimeseriesArgs added in v1.1.5

func NewIClientRPCServiceCreateMultiTimeseriesArgs() *IClientRPCServiceCreateMultiTimeseriesArgs

func (*IClientRPCServiceCreateMultiTimeseriesArgs) GetReq added in v1.1.5

func (*IClientRPCServiceCreateMultiTimeseriesArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceCreateMultiTimeseriesArgs) Read added in v1.1.5

func (*IClientRPCServiceCreateMultiTimeseriesArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceCreateMultiTimeseriesArgs) String added in v1.1.5

func (*IClientRPCServiceCreateMultiTimeseriesArgs) Write added in v1.1.5

type IClientRPCServiceCreateMultiTimeseriesResult added in v1.1.5

type IClientRPCServiceCreateMultiTimeseriesResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceCreateMultiTimeseriesResult added in v1.1.5

func NewIClientRPCServiceCreateMultiTimeseriesResult() *IClientRPCServiceCreateMultiTimeseriesResult

func (*IClientRPCServiceCreateMultiTimeseriesResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceCreateMultiTimeseriesResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceCreateMultiTimeseriesResult) Read added in v1.1.5

func (*IClientRPCServiceCreateMultiTimeseriesResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceCreateMultiTimeseriesResult) String added in v1.1.5

func (*IClientRPCServiceCreateMultiTimeseriesResult) Write added in v1.1.5

type IClientRPCServiceCreateSchemaTemplateArgs added in v1.1.5

type IClientRPCServiceCreateSchemaTemplateArgs struct {
	Req *TSCreateSchemaTemplateReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceCreateSchemaTemplateArgs added in v1.1.5

func NewIClientRPCServiceCreateSchemaTemplateArgs() *IClientRPCServiceCreateSchemaTemplateArgs

func (*IClientRPCServiceCreateSchemaTemplateArgs) GetReq added in v1.1.5

func (*IClientRPCServiceCreateSchemaTemplateArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceCreateSchemaTemplateArgs) Read added in v1.1.5

func (*IClientRPCServiceCreateSchemaTemplateArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceCreateSchemaTemplateArgs) String added in v1.1.5

func (*IClientRPCServiceCreateSchemaTemplateArgs) Write added in v1.1.5

type IClientRPCServiceCreateSchemaTemplateResult added in v1.1.5

type IClientRPCServiceCreateSchemaTemplateResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceCreateSchemaTemplateResult added in v1.1.5

func NewIClientRPCServiceCreateSchemaTemplateResult() *IClientRPCServiceCreateSchemaTemplateResult

func (*IClientRPCServiceCreateSchemaTemplateResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceCreateSchemaTemplateResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceCreateSchemaTemplateResult) Read added in v1.1.5

func (*IClientRPCServiceCreateSchemaTemplateResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceCreateSchemaTemplateResult) String added in v1.1.5

func (*IClientRPCServiceCreateSchemaTemplateResult) Write added in v1.1.5

type IClientRPCServiceCreateTimeseriesArgs added in v1.1.5

type IClientRPCServiceCreateTimeseriesArgs struct {
	Req *TSCreateTimeseriesReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceCreateTimeseriesArgs added in v1.1.5

func NewIClientRPCServiceCreateTimeseriesArgs() *IClientRPCServiceCreateTimeseriesArgs

func (*IClientRPCServiceCreateTimeseriesArgs) GetReq added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesArgs) Read added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesArgs) String added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesArgs) Write added in v1.1.5

type IClientRPCServiceCreateTimeseriesResult added in v1.1.5

type IClientRPCServiceCreateTimeseriesResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceCreateTimeseriesResult added in v1.1.5

func NewIClientRPCServiceCreateTimeseriesResult() *IClientRPCServiceCreateTimeseriesResult

func (*IClientRPCServiceCreateTimeseriesResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesResult) Read added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesResult) String added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesResult) Write added in v1.1.5

type IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs added in v1.1.5

type IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs struct {
	Req *TCreateTimeseriesUsingSchemaTemplateReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs added in v1.1.5

func NewIClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs() *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs

func (*IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs) GetReq added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs) Read added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs) String added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs) Write added in v1.1.5

type IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult added in v1.1.5

type IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult added in v1.1.5

func NewIClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult() *IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult

func (*IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult) Read added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult) String added in v1.1.5

func (*IClientRPCServiceCreateTimeseriesUsingSchemaTemplateResult) Write added in v1.1.5

type IClientRPCServiceDeleteDataArgs added in v1.1.5

type IClientRPCServiceDeleteDataArgs struct {
	Req *TSDeleteDataReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceDeleteDataArgs added in v1.1.5

func NewIClientRPCServiceDeleteDataArgs() *IClientRPCServiceDeleteDataArgs

func (*IClientRPCServiceDeleteDataArgs) GetReq added in v1.1.5

func (*IClientRPCServiceDeleteDataArgs) IsSetReq added in v1.1.5

func (p *IClientRPCServiceDeleteDataArgs) IsSetReq() bool

func (*IClientRPCServiceDeleteDataArgs) Read added in v1.1.5

func (*IClientRPCServiceDeleteDataArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceDeleteDataArgs) String added in v1.1.5

func (*IClientRPCServiceDeleteDataArgs) Write added in v1.1.5

type IClientRPCServiceDeleteDataResult added in v1.1.5

type IClientRPCServiceDeleteDataResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceDeleteDataResult added in v1.1.5

func NewIClientRPCServiceDeleteDataResult() *IClientRPCServiceDeleteDataResult

func (*IClientRPCServiceDeleteDataResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceDeleteDataResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceDeleteDataResult) IsSetSuccess() bool

func (*IClientRPCServiceDeleteDataResult) Read added in v1.1.5

func (*IClientRPCServiceDeleteDataResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceDeleteDataResult) String added in v1.1.5

func (*IClientRPCServiceDeleteDataResult) Write added in v1.1.5

type IClientRPCServiceDeleteStorageGroupsArgs added in v1.1.5

type IClientRPCServiceDeleteStorageGroupsArgs struct {
	SessionId    int64    `thrift:"sessionId,1" db:"sessionId" json:"sessionId"`
	StorageGroup []string `thrift:"storageGroup,2" db:"storageGroup" json:"storageGroup"`
}

Attributes:

  • SessionId
  • StorageGroup

func NewIClientRPCServiceDeleteStorageGroupsArgs added in v1.1.5

func NewIClientRPCServiceDeleteStorageGroupsArgs() *IClientRPCServiceDeleteStorageGroupsArgs

func (*IClientRPCServiceDeleteStorageGroupsArgs) GetSessionId added in v1.1.5

func (*IClientRPCServiceDeleteStorageGroupsArgs) GetStorageGroup added in v1.1.5

func (p *IClientRPCServiceDeleteStorageGroupsArgs) GetStorageGroup() []string

func (*IClientRPCServiceDeleteStorageGroupsArgs) Read added in v1.1.5

func (*IClientRPCServiceDeleteStorageGroupsArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceDeleteStorageGroupsArgs) ReadField2 added in v1.1.5

func (*IClientRPCServiceDeleteStorageGroupsArgs) String added in v1.1.5

func (*IClientRPCServiceDeleteStorageGroupsArgs) Write added in v1.1.5

type IClientRPCServiceDeleteStorageGroupsResult added in v1.1.5

type IClientRPCServiceDeleteStorageGroupsResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceDeleteStorageGroupsResult added in v1.1.5

func NewIClientRPCServiceDeleteStorageGroupsResult() *IClientRPCServiceDeleteStorageGroupsResult

func (*IClientRPCServiceDeleteStorageGroupsResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceDeleteStorageGroupsResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceDeleteStorageGroupsResult) Read added in v1.1.5

func (*IClientRPCServiceDeleteStorageGroupsResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceDeleteStorageGroupsResult) String added in v1.1.5

func (*IClientRPCServiceDeleteStorageGroupsResult) Write added in v1.1.5

type IClientRPCServiceDeleteTimeseriesArgs added in v1.1.5

type IClientRPCServiceDeleteTimeseriesArgs struct {
	SessionId int64    `thrift:"sessionId,1" db:"sessionId" json:"sessionId"`
	Path      []string `thrift:"path,2" db:"path" json:"path"`
}

Attributes:

  • SessionId
  • Path

func NewIClientRPCServiceDeleteTimeseriesArgs added in v1.1.5

func NewIClientRPCServiceDeleteTimeseriesArgs() *IClientRPCServiceDeleteTimeseriesArgs

func (*IClientRPCServiceDeleteTimeseriesArgs) GetPath added in v1.1.5

func (*IClientRPCServiceDeleteTimeseriesArgs) GetSessionId added in v1.1.5

func (p *IClientRPCServiceDeleteTimeseriesArgs) GetSessionId() int64

func (*IClientRPCServiceDeleteTimeseriesArgs) Read added in v1.1.5

func (*IClientRPCServiceDeleteTimeseriesArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceDeleteTimeseriesArgs) ReadField2 added in v1.1.5

func (*IClientRPCServiceDeleteTimeseriesArgs) String added in v1.1.5

func (*IClientRPCServiceDeleteTimeseriesArgs) Write added in v1.1.5

type IClientRPCServiceDeleteTimeseriesResult added in v1.1.5

type IClientRPCServiceDeleteTimeseriesResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceDeleteTimeseriesResult added in v1.1.5

func NewIClientRPCServiceDeleteTimeseriesResult() *IClientRPCServiceDeleteTimeseriesResult

func (*IClientRPCServiceDeleteTimeseriesResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceDeleteTimeseriesResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceDeleteTimeseriesResult) Read added in v1.1.5

func (*IClientRPCServiceDeleteTimeseriesResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceDeleteTimeseriesResult) String added in v1.1.5

func (*IClientRPCServiceDeleteTimeseriesResult) Write added in v1.1.5

type IClientRPCServiceDropSchemaTemplateArgs added in v1.1.5

type IClientRPCServiceDropSchemaTemplateArgs struct {
	Req *TSDropSchemaTemplateReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceDropSchemaTemplateArgs added in v1.1.5

func NewIClientRPCServiceDropSchemaTemplateArgs() *IClientRPCServiceDropSchemaTemplateArgs

func (*IClientRPCServiceDropSchemaTemplateArgs) GetReq added in v1.1.5

func (*IClientRPCServiceDropSchemaTemplateArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceDropSchemaTemplateArgs) Read added in v1.1.5

func (*IClientRPCServiceDropSchemaTemplateArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceDropSchemaTemplateArgs) String added in v1.1.5

func (*IClientRPCServiceDropSchemaTemplateArgs) Write added in v1.1.5

type IClientRPCServiceDropSchemaTemplateResult added in v1.1.5

type IClientRPCServiceDropSchemaTemplateResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceDropSchemaTemplateResult added in v1.1.5

func NewIClientRPCServiceDropSchemaTemplateResult() *IClientRPCServiceDropSchemaTemplateResult

func (*IClientRPCServiceDropSchemaTemplateResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceDropSchemaTemplateResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceDropSchemaTemplateResult) Read added in v1.1.5

func (*IClientRPCServiceDropSchemaTemplateResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceDropSchemaTemplateResult) String added in v1.1.5

func (*IClientRPCServiceDropSchemaTemplateResult) Write added in v1.1.5

type IClientRPCServiceExecuteAggregationQueryArgs added in v1.1.5

type IClientRPCServiceExecuteAggregationQueryArgs struct {
	Req *TSAggregationQueryReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceExecuteAggregationQueryArgs added in v1.1.5

func NewIClientRPCServiceExecuteAggregationQueryArgs() *IClientRPCServiceExecuteAggregationQueryArgs

func (*IClientRPCServiceExecuteAggregationQueryArgs) GetReq added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryArgs) Read added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryArgs) String added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryArgs) Write added in v1.1.5

type IClientRPCServiceExecuteAggregationQueryResult added in v1.1.5

type IClientRPCServiceExecuteAggregationQueryResult struct {
	Success *TSExecuteStatementResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceExecuteAggregationQueryResult added in v1.1.5

func NewIClientRPCServiceExecuteAggregationQueryResult() *IClientRPCServiceExecuteAggregationQueryResult

func (*IClientRPCServiceExecuteAggregationQueryResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryResult) Read added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryResult) String added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryResult) Write added in v1.1.5

type IClientRPCServiceExecuteAggregationQueryV2Args added in v1.1.5

type IClientRPCServiceExecuteAggregationQueryV2Args struct {
	Req *TSAggregationQueryReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceExecuteAggregationQueryV2Args added in v1.1.5

func NewIClientRPCServiceExecuteAggregationQueryV2Args() *IClientRPCServiceExecuteAggregationQueryV2Args

func (*IClientRPCServiceExecuteAggregationQueryV2Args) GetReq added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryV2Args) IsSetReq added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryV2Args) Read added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryV2Args) ReadField1 added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryV2Args) String added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryV2Args) Write added in v1.1.5

type IClientRPCServiceExecuteAggregationQueryV2Result added in v1.1.5

type IClientRPCServiceExecuteAggregationQueryV2Result struct {
	Success *TSExecuteStatementResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceExecuteAggregationQueryV2Result added in v1.1.5

func NewIClientRPCServiceExecuteAggregationQueryV2Result() *IClientRPCServiceExecuteAggregationQueryV2Result

func (*IClientRPCServiceExecuteAggregationQueryV2Result) GetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryV2Result) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryV2Result) Read added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryV2Result) ReadField0 added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryV2Result) String added in v1.1.5

func (*IClientRPCServiceExecuteAggregationQueryV2Result) Write added in v1.1.5

type IClientRPCServiceExecuteBatchStatementArgs added in v1.1.5

type IClientRPCServiceExecuteBatchStatementArgs struct {
	Req *TSExecuteBatchStatementReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceExecuteBatchStatementArgs added in v1.1.5

func NewIClientRPCServiceExecuteBatchStatementArgs() *IClientRPCServiceExecuteBatchStatementArgs

func (*IClientRPCServiceExecuteBatchStatementArgs) GetReq added in v1.1.5

func (*IClientRPCServiceExecuteBatchStatementArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceExecuteBatchStatementArgs) Read added in v1.1.5

func (*IClientRPCServiceExecuteBatchStatementArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceExecuteBatchStatementArgs) String added in v1.1.5

func (*IClientRPCServiceExecuteBatchStatementArgs) Write added in v1.1.5

type IClientRPCServiceExecuteBatchStatementResult added in v1.1.5

type IClientRPCServiceExecuteBatchStatementResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceExecuteBatchStatementResult added in v1.1.5

func NewIClientRPCServiceExecuteBatchStatementResult() *IClientRPCServiceExecuteBatchStatementResult

func (*IClientRPCServiceExecuteBatchStatementResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteBatchStatementResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteBatchStatementResult) Read added in v1.1.5

func (*IClientRPCServiceExecuteBatchStatementResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceExecuteBatchStatementResult) String added in v1.1.5

func (*IClientRPCServiceExecuteBatchStatementResult) Write added in v1.1.5

type IClientRPCServiceExecuteLastDataQueryArgs added in v1.1.5

type IClientRPCServiceExecuteLastDataQueryArgs struct {
	Req *TSLastDataQueryReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceExecuteLastDataQueryArgs added in v1.1.5

func NewIClientRPCServiceExecuteLastDataQueryArgs() *IClientRPCServiceExecuteLastDataQueryArgs

func (*IClientRPCServiceExecuteLastDataQueryArgs) GetReq added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryArgs) Read added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryArgs) String added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryArgs) Write added in v1.1.5

type IClientRPCServiceExecuteLastDataQueryResult added in v1.1.5

type IClientRPCServiceExecuteLastDataQueryResult struct {
	Success *TSExecuteStatementResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceExecuteLastDataQueryResult added in v1.1.5

func NewIClientRPCServiceExecuteLastDataQueryResult() *IClientRPCServiceExecuteLastDataQueryResult

func (*IClientRPCServiceExecuteLastDataQueryResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryResult) Read added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryResult) String added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryResult) Write added in v1.1.5

type IClientRPCServiceExecuteLastDataQueryV2Args added in v1.1.5

type IClientRPCServiceExecuteLastDataQueryV2Args struct {
	Req *TSLastDataQueryReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceExecuteLastDataQueryV2Args added in v1.1.5

func NewIClientRPCServiceExecuteLastDataQueryV2Args() *IClientRPCServiceExecuteLastDataQueryV2Args

func (*IClientRPCServiceExecuteLastDataQueryV2Args) GetReq added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryV2Args) IsSetReq added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryV2Args) Read added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryV2Args) ReadField1 added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryV2Args) String added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryV2Args) Write added in v1.1.5

type IClientRPCServiceExecuteLastDataQueryV2Result added in v1.1.5

type IClientRPCServiceExecuteLastDataQueryV2Result struct {
	Success *TSExecuteStatementResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceExecuteLastDataQueryV2Result added in v1.1.5

func NewIClientRPCServiceExecuteLastDataQueryV2Result() *IClientRPCServiceExecuteLastDataQueryV2Result

func (*IClientRPCServiceExecuteLastDataQueryV2Result) GetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryV2Result) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryV2Result) Read added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryV2Result) ReadField0 added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryV2Result) String added in v1.1.5

func (*IClientRPCServiceExecuteLastDataQueryV2Result) Write added in v1.1.5

type IClientRPCServiceExecuteQueryStatementArgs added in v1.1.5

type IClientRPCServiceExecuteQueryStatementArgs struct {
	Req *TSExecuteStatementReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceExecuteQueryStatementArgs added in v1.1.5

func NewIClientRPCServiceExecuteQueryStatementArgs() *IClientRPCServiceExecuteQueryStatementArgs

func (*IClientRPCServiceExecuteQueryStatementArgs) GetReq added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementArgs) Read added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementArgs) String added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementArgs) Write added in v1.1.5

type IClientRPCServiceExecuteQueryStatementResult added in v1.1.5

type IClientRPCServiceExecuteQueryStatementResult struct {
	Success *TSExecuteStatementResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceExecuteQueryStatementResult added in v1.1.5

func NewIClientRPCServiceExecuteQueryStatementResult() *IClientRPCServiceExecuteQueryStatementResult

func (*IClientRPCServiceExecuteQueryStatementResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementResult) Read added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementResult) String added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementResult) Write added in v1.1.5

type IClientRPCServiceExecuteQueryStatementV2Args added in v1.1.5

type IClientRPCServiceExecuteQueryStatementV2Args struct {
	Req *TSExecuteStatementReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceExecuteQueryStatementV2Args added in v1.1.5

func NewIClientRPCServiceExecuteQueryStatementV2Args() *IClientRPCServiceExecuteQueryStatementV2Args

func (*IClientRPCServiceExecuteQueryStatementV2Args) GetReq added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementV2Args) IsSetReq added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementV2Args) Read added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementV2Args) ReadField1 added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementV2Args) String added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementV2Args) Write added in v1.1.5

type IClientRPCServiceExecuteQueryStatementV2Result added in v1.1.5

type IClientRPCServiceExecuteQueryStatementV2Result struct {
	Success *TSExecuteStatementResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceExecuteQueryStatementV2Result added in v1.1.5

func NewIClientRPCServiceExecuteQueryStatementV2Result() *IClientRPCServiceExecuteQueryStatementV2Result

func (*IClientRPCServiceExecuteQueryStatementV2Result) GetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementV2Result) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementV2Result) Read added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementV2Result) ReadField0 added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementV2Result) String added in v1.1.5

func (*IClientRPCServiceExecuteQueryStatementV2Result) Write added in v1.1.5

type IClientRPCServiceExecuteRawDataQueryArgs added in v1.1.5

type IClientRPCServiceExecuteRawDataQueryArgs struct {
	Req *TSRawDataQueryReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceExecuteRawDataQueryArgs added in v1.1.5

func NewIClientRPCServiceExecuteRawDataQueryArgs() *IClientRPCServiceExecuteRawDataQueryArgs

func (*IClientRPCServiceExecuteRawDataQueryArgs) GetReq added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryArgs) Read added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryArgs) String added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryArgs) Write added in v1.1.5

type IClientRPCServiceExecuteRawDataQueryResult added in v1.1.5

type IClientRPCServiceExecuteRawDataQueryResult struct {
	Success *TSExecuteStatementResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceExecuteRawDataQueryResult added in v1.1.5

func NewIClientRPCServiceExecuteRawDataQueryResult() *IClientRPCServiceExecuteRawDataQueryResult

func (*IClientRPCServiceExecuteRawDataQueryResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryResult) Read added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryResult) String added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryResult) Write added in v1.1.5

type IClientRPCServiceExecuteRawDataQueryV2Args added in v1.1.5

type IClientRPCServiceExecuteRawDataQueryV2Args struct {
	Req *TSRawDataQueryReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceExecuteRawDataQueryV2Args added in v1.1.5

func NewIClientRPCServiceExecuteRawDataQueryV2Args() *IClientRPCServiceExecuteRawDataQueryV2Args

func (*IClientRPCServiceExecuteRawDataQueryV2Args) GetReq added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryV2Args) IsSetReq added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryV2Args) Read added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryV2Args) ReadField1 added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryV2Args) String added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryV2Args) Write added in v1.1.5

type IClientRPCServiceExecuteRawDataQueryV2Result added in v1.1.5

type IClientRPCServiceExecuteRawDataQueryV2Result struct {
	Success *TSExecuteStatementResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceExecuteRawDataQueryV2Result added in v1.1.5

func NewIClientRPCServiceExecuteRawDataQueryV2Result() *IClientRPCServiceExecuteRawDataQueryV2Result

func (*IClientRPCServiceExecuteRawDataQueryV2Result) GetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryV2Result) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryV2Result) Read added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryV2Result) ReadField0 added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryV2Result) String added in v1.1.5

func (*IClientRPCServiceExecuteRawDataQueryV2Result) Write added in v1.1.5

type IClientRPCServiceExecuteStatementArgs added in v1.1.5

type IClientRPCServiceExecuteStatementArgs struct {
	Req *TSExecuteStatementReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceExecuteStatementArgs added in v1.1.5

func NewIClientRPCServiceExecuteStatementArgs() *IClientRPCServiceExecuteStatementArgs

func (*IClientRPCServiceExecuteStatementArgs) GetReq added in v1.1.5

func (*IClientRPCServiceExecuteStatementArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceExecuteStatementArgs) Read added in v1.1.5

func (*IClientRPCServiceExecuteStatementArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceExecuteStatementArgs) String added in v1.1.5

func (*IClientRPCServiceExecuteStatementArgs) Write added in v1.1.5

type IClientRPCServiceExecuteStatementResult added in v1.1.5

type IClientRPCServiceExecuteStatementResult struct {
	Success *TSExecuteStatementResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceExecuteStatementResult added in v1.1.5

func NewIClientRPCServiceExecuteStatementResult() *IClientRPCServiceExecuteStatementResult

func (*IClientRPCServiceExecuteStatementResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteStatementResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteStatementResult) Read added in v1.1.5

func (*IClientRPCServiceExecuteStatementResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceExecuteStatementResult) String added in v1.1.5

func (*IClientRPCServiceExecuteStatementResult) Write added in v1.1.5

type IClientRPCServiceExecuteStatementV2Args added in v1.1.5

type IClientRPCServiceExecuteStatementV2Args struct {
	Req *TSExecuteStatementReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceExecuteStatementV2Args added in v1.1.5

func NewIClientRPCServiceExecuteStatementV2Args() *IClientRPCServiceExecuteStatementV2Args

func (*IClientRPCServiceExecuteStatementV2Args) GetReq added in v1.1.5

func (*IClientRPCServiceExecuteStatementV2Args) IsSetReq added in v1.1.5

func (*IClientRPCServiceExecuteStatementV2Args) Read added in v1.1.5

func (*IClientRPCServiceExecuteStatementV2Args) ReadField1 added in v1.1.5

func (*IClientRPCServiceExecuteStatementV2Args) String added in v1.1.5

func (*IClientRPCServiceExecuteStatementV2Args) Write added in v1.1.5

type IClientRPCServiceExecuteStatementV2Result added in v1.1.5

type IClientRPCServiceExecuteStatementV2Result struct {
	Success *TSExecuteStatementResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceExecuteStatementV2Result added in v1.1.5

func NewIClientRPCServiceExecuteStatementV2Result() *IClientRPCServiceExecuteStatementV2Result

func (*IClientRPCServiceExecuteStatementV2Result) GetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteStatementV2Result) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteStatementV2Result) Read added in v1.1.5

func (*IClientRPCServiceExecuteStatementV2Result) ReadField0 added in v1.1.5

func (*IClientRPCServiceExecuteStatementV2Result) String added in v1.1.5

func (*IClientRPCServiceExecuteStatementV2Result) Write added in v1.1.5

type IClientRPCServiceExecuteUpdateStatementArgs added in v1.1.5

type IClientRPCServiceExecuteUpdateStatementArgs struct {
	Req *TSExecuteStatementReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceExecuteUpdateStatementArgs added in v1.1.5

func NewIClientRPCServiceExecuteUpdateStatementArgs() *IClientRPCServiceExecuteUpdateStatementArgs

func (*IClientRPCServiceExecuteUpdateStatementArgs) GetReq added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementArgs) Read added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementArgs) String added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementArgs) Write added in v1.1.5

type IClientRPCServiceExecuteUpdateStatementResult added in v1.1.5

type IClientRPCServiceExecuteUpdateStatementResult struct {
	Success *TSExecuteStatementResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceExecuteUpdateStatementResult added in v1.1.5

func NewIClientRPCServiceExecuteUpdateStatementResult() *IClientRPCServiceExecuteUpdateStatementResult

func (*IClientRPCServiceExecuteUpdateStatementResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementResult) Read added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementResult) String added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementResult) Write added in v1.1.5

type IClientRPCServiceExecuteUpdateStatementV2Args added in v1.1.5

type IClientRPCServiceExecuteUpdateStatementV2Args struct {
	Req *TSExecuteStatementReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceExecuteUpdateStatementV2Args added in v1.1.5

func NewIClientRPCServiceExecuteUpdateStatementV2Args() *IClientRPCServiceExecuteUpdateStatementV2Args

func (*IClientRPCServiceExecuteUpdateStatementV2Args) GetReq added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementV2Args) IsSetReq added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementV2Args) Read added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementV2Args) ReadField1 added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementV2Args) String added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementV2Args) Write added in v1.1.5

type IClientRPCServiceExecuteUpdateStatementV2Result added in v1.1.5

type IClientRPCServiceExecuteUpdateStatementV2Result struct {
	Success *TSExecuteStatementResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceExecuteUpdateStatementV2Result added in v1.1.5

func NewIClientRPCServiceExecuteUpdateStatementV2Result() *IClientRPCServiceExecuteUpdateStatementV2Result

func (*IClientRPCServiceExecuteUpdateStatementV2Result) GetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementV2Result) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementV2Result) Read added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementV2Result) ReadField0 added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementV2Result) String added in v1.1.5

func (*IClientRPCServiceExecuteUpdateStatementV2Result) Write added in v1.1.5

type IClientRPCServiceFastInsertRecordsArgs added in v1.1.6

type IClientRPCServiceFastInsertRecordsArgs struct {
	Req *TSFastInsertRecordsReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceFastInsertRecordsArgs added in v1.1.6

func NewIClientRPCServiceFastInsertRecordsArgs() *IClientRPCServiceFastInsertRecordsArgs

func (*IClientRPCServiceFastInsertRecordsArgs) GetReq added in v1.1.6

func (*IClientRPCServiceFastInsertRecordsArgs) IsSetReq added in v1.1.6

func (*IClientRPCServiceFastInsertRecordsArgs) Read added in v1.1.6

func (*IClientRPCServiceFastInsertRecordsArgs) ReadField1 added in v1.1.6

func (*IClientRPCServiceFastInsertRecordsArgs) String added in v1.1.6

func (*IClientRPCServiceFastInsertRecordsArgs) Write added in v1.1.6

type IClientRPCServiceFastInsertRecordsResult added in v1.1.6

type IClientRPCServiceFastInsertRecordsResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceFastInsertRecordsResult added in v1.1.6

func NewIClientRPCServiceFastInsertRecordsResult() *IClientRPCServiceFastInsertRecordsResult

func (*IClientRPCServiceFastInsertRecordsResult) GetSuccess added in v1.1.6

func (*IClientRPCServiceFastInsertRecordsResult) IsSetSuccess added in v1.1.6

func (*IClientRPCServiceFastInsertRecordsResult) Read added in v1.1.6

func (*IClientRPCServiceFastInsertRecordsResult) ReadField0 added in v1.1.6

func (*IClientRPCServiceFastInsertRecordsResult) String added in v1.1.6

func (*IClientRPCServiceFastInsertRecordsResult) Write added in v1.1.6

type IClientRPCServiceFetchAllConnectionsInfoArgs added in v1.1.5

type IClientRPCServiceFetchAllConnectionsInfoArgs struct {
}

func NewIClientRPCServiceFetchAllConnectionsInfoArgs added in v1.1.5

func NewIClientRPCServiceFetchAllConnectionsInfoArgs() *IClientRPCServiceFetchAllConnectionsInfoArgs

func (*IClientRPCServiceFetchAllConnectionsInfoArgs) Read added in v1.1.5

func (*IClientRPCServiceFetchAllConnectionsInfoArgs) String added in v1.1.5

func (*IClientRPCServiceFetchAllConnectionsInfoArgs) Write added in v1.1.5

type IClientRPCServiceFetchAllConnectionsInfoResult added in v1.1.5

type IClientRPCServiceFetchAllConnectionsInfoResult struct {
	Success *TSConnectionInfoResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceFetchAllConnectionsInfoResult added in v1.1.5

func NewIClientRPCServiceFetchAllConnectionsInfoResult() *IClientRPCServiceFetchAllConnectionsInfoResult

func (*IClientRPCServiceFetchAllConnectionsInfoResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceFetchAllConnectionsInfoResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceFetchAllConnectionsInfoResult) Read added in v1.1.5

func (*IClientRPCServiceFetchAllConnectionsInfoResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceFetchAllConnectionsInfoResult) String added in v1.1.5

func (*IClientRPCServiceFetchAllConnectionsInfoResult) Write added in v1.1.5

type IClientRPCServiceFetchMetadataArgs added in v1.1.5

type IClientRPCServiceFetchMetadataArgs struct {
	Req *TSFetchMetadataReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceFetchMetadataArgs added in v1.1.5

func NewIClientRPCServiceFetchMetadataArgs() *IClientRPCServiceFetchMetadataArgs

func (*IClientRPCServiceFetchMetadataArgs) GetReq added in v1.1.5

func (*IClientRPCServiceFetchMetadataArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceFetchMetadataArgs) Read added in v1.1.5

func (*IClientRPCServiceFetchMetadataArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceFetchMetadataArgs) String added in v1.1.5

func (*IClientRPCServiceFetchMetadataArgs) Write added in v1.1.5

type IClientRPCServiceFetchMetadataResult added in v1.1.5

type IClientRPCServiceFetchMetadataResult struct {
	Success *TSFetchMetadataResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceFetchMetadataResult added in v1.1.5

func NewIClientRPCServiceFetchMetadataResult() *IClientRPCServiceFetchMetadataResult

func (*IClientRPCServiceFetchMetadataResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceFetchMetadataResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceFetchMetadataResult) IsSetSuccess() bool

func (*IClientRPCServiceFetchMetadataResult) Read added in v1.1.5

func (*IClientRPCServiceFetchMetadataResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceFetchMetadataResult) String added in v1.1.5

func (*IClientRPCServiceFetchMetadataResult) Write added in v1.1.5

type IClientRPCServiceFetchResultsArgs added in v1.1.5

type IClientRPCServiceFetchResultsArgs struct {
	Req *TSFetchResultsReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceFetchResultsArgs added in v1.1.5

func NewIClientRPCServiceFetchResultsArgs() *IClientRPCServiceFetchResultsArgs

func (*IClientRPCServiceFetchResultsArgs) GetReq added in v1.1.5

func (*IClientRPCServiceFetchResultsArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceFetchResultsArgs) Read added in v1.1.5

func (*IClientRPCServiceFetchResultsArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceFetchResultsArgs) String added in v1.1.5

func (*IClientRPCServiceFetchResultsArgs) Write added in v1.1.5

type IClientRPCServiceFetchResultsResult added in v1.1.5

type IClientRPCServiceFetchResultsResult struct {
	Success *TSFetchResultsResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceFetchResultsResult added in v1.1.5

func NewIClientRPCServiceFetchResultsResult() *IClientRPCServiceFetchResultsResult

func (*IClientRPCServiceFetchResultsResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceFetchResultsResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceFetchResultsResult) IsSetSuccess() bool

func (*IClientRPCServiceFetchResultsResult) Read added in v1.1.5

func (*IClientRPCServiceFetchResultsResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceFetchResultsResult) String added in v1.1.5

func (*IClientRPCServiceFetchResultsResult) Write added in v1.1.5

type IClientRPCServiceFetchResultsV2Args added in v1.1.5

type IClientRPCServiceFetchResultsV2Args struct {
	Req *TSFetchResultsReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceFetchResultsV2Args added in v1.1.5

func NewIClientRPCServiceFetchResultsV2Args() *IClientRPCServiceFetchResultsV2Args

func (*IClientRPCServiceFetchResultsV2Args) GetReq added in v1.1.5

func (*IClientRPCServiceFetchResultsV2Args) IsSetReq added in v1.1.5

func (*IClientRPCServiceFetchResultsV2Args) Read added in v1.1.5

func (*IClientRPCServiceFetchResultsV2Args) ReadField1 added in v1.1.5

func (*IClientRPCServiceFetchResultsV2Args) String added in v1.1.5

func (*IClientRPCServiceFetchResultsV2Args) Write added in v1.1.5

type IClientRPCServiceFetchResultsV2Result added in v1.1.5

type IClientRPCServiceFetchResultsV2Result struct {
	Success *TSFetchResultsResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceFetchResultsV2Result added in v1.1.5

func NewIClientRPCServiceFetchResultsV2Result() *IClientRPCServiceFetchResultsV2Result

func (*IClientRPCServiceFetchResultsV2Result) GetSuccess added in v1.1.5

func (*IClientRPCServiceFetchResultsV2Result) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceFetchResultsV2Result) IsSetSuccess() bool

func (*IClientRPCServiceFetchResultsV2Result) Read added in v1.1.5

func (*IClientRPCServiceFetchResultsV2Result) ReadField0 added in v1.1.5

func (*IClientRPCServiceFetchResultsV2Result) String added in v1.1.5

func (*IClientRPCServiceFetchResultsV2Result) Write added in v1.1.5

type IClientRPCServiceGetBackupConfigurationArgs added in v1.1.5

type IClientRPCServiceGetBackupConfigurationArgs struct {
}

func NewIClientRPCServiceGetBackupConfigurationArgs added in v1.1.5

func NewIClientRPCServiceGetBackupConfigurationArgs() *IClientRPCServiceGetBackupConfigurationArgs

func (*IClientRPCServiceGetBackupConfigurationArgs) Read added in v1.1.5

func (*IClientRPCServiceGetBackupConfigurationArgs) String added in v1.1.5

func (*IClientRPCServiceGetBackupConfigurationArgs) Write added in v1.1.5

type IClientRPCServiceGetBackupConfigurationResult added in v1.1.5

type IClientRPCServiceGetBackupConfigurationResult struct {
	Success *TSBackupConfigurationResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceGetBackupConfigurationResult added in v1.1.5

func NewIClientRPCServiceGetBackupConfigurationResult() *IClientRPCServiceGetBackupConfigurationResult

func (*IClientRPCServiceGetBackupConfigurationResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceGetBackupConfigurationResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceGetBackupConfigurationResult) Read added in v1.1.5

func (*IClientRPCServiceGetBackupConfigurationResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceGetBackupConfigurationResult) String added in v1.1.5

func (*IClientRPCServiceGetBackupConfigurationResult) Write added in v1.1.5

type IClientRPCServiceGetPropertiesArgs added in v1.1.5

type IClientRPCServiceGetPropertiesArgs struct {
}

func NewIClientRPCServiceGetPropertiesArgs added in v1.1.5

func NewIClientRPCServiceGetPropertiesArgs() *IClientRPCServiceGetPropertiesArgs

func (*IClientRPCServiceGetPropertiesArgs) Read added in v1.1.5

func (*IClientRPCServiceGetPropertiesArgs) String added in v1.1.5

func (*IClientRPCServiceGetPropertiesArgs) Write added in v1.1.5

type IClientRPCServiceGetPropertiesResult added in v1.1.5

type IClientRPCServiceGetPropertiesResult struct {
	Success *ServerProperties `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceGetPropertiesResult added in v1.1.5

func NewIClientRPCServiceGetPropertiesResult() *IClientRPCServiceGetPropertiesResult

func (*IClientRPCServiceGetPropertiesResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceGetPropertiesResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceGetPropertiesResult) IsSetSuccess() bool

func (*IClientRPCServiceGetPropertiesResult) Read added in v1.1.5

func (*IClientRPCServiceGetPropertiesResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceGetPropertiesResult) String added in v1.1.5

func (*IClientRPCServiceGetPropertiesResult) Write added in v1.1.5

type IClientRPCServiceGetTimeZoneArgs added in v1.1.5

type IClientRPCServiceGetTimeZoneArgs struct {
	SessionId int64 `thrift:"sessionId,1" db:"sessionId" json:"sessionId"`
}

Attributes:

  • SessionId

func NewIClientRPCServiceGetTimeZoneArgs added in v1.1.5

func NewIClientRPCServiceGetTimeZoneArgs() *IClientRPCServiceGetTimeZoneArgs

func (*IClientRPCServiceGetTimeZoneArgs) GetSessionId added in v1.1.5

func (p *IClientRPCServiceGetTimeZoneArgs) GetSessionId() int64

func (*IClientRPCServiceGetTimeZoneArgs) Read added in v1.1.5

func (*IClientRPCServiceGetTimeZoneArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceGetTimeZoneArgs) String added in v1.1.5

func (*IClientRPCServiceGetTimeZoneArgs) Write added in v1.1.5

type IClientRPCServiceGetTimeZoneResult added in v1.1.5

type IClientRPCServiceGetTimeZoneResult struct {
	Success *TSGetTimeZoneResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceGetTimeZoneResult added in v1.1.5

func NewIClientRPCServiceGetTimeZoneResult() *IClientRPCServiceGetTimeZoneResult

func (*IClientRPCServiceGetTimeZoneResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceGetTimeZoneResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceGetTimeZoneResult) IsSetSuccess() bool

func (*IClientRPCServiceGetTimeZoneResult) Read added in v1.1.5

func (*IClientRPCServiceGetTimeZoneResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceGetTimeZoneResult) String added in v1.1.5

func (*IClientRPCServiceGetTimeZoneResult) Write added in v1.1.5

type IClientRPCServiceHandshakeArgs added in v1.1.5

type IClientRPCServiceHandshakeArgs struct {
	Info *TSyncIdentityInfo
}

Attributes:

  • Info

func NewIClientRPCServiceHandshakeArgs added in v1.1.5

func NewIClientRPCServiceHandshakeArgs() *IClientRPCServiceHandshakeArgs

func (*IClientRPCServiceHandshakeArgs) GetInfo added in v1.1.5

func (*IClientRPCServiceHandshakeArgs) IsSetInfo added in v1.1.5

func (p *IClientRPCServiceHandshakeArgs) IsSetInfo() bool

func (*IClientRPCServiceHandshakeArgs) Read added in v1.1.5

func (*IClientRPCServiceHandshakeArgs) ReadField_1 added in v1.1.5

func (*IClientRPCServiceHandshakeArgs) String added in v1.1.5

func (*IClientRPCServiceHandshakeArgs) Write added in v1.1.5

type IClientRPCServiceHandshakeResult added in v1.1.5

type IClientRPCServiceHandshakeResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceHandshakeResult added in v1.1.5

func NewIClientRPCServiceHandshakeResult() *IClientRPCServiceHandshakeResult

func (*IClientRPCServiceHandshakeResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceHandshakeResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceHandshakeResult) IsSetSuccess() bool

func (*IClientRPCServiceHandshakeResult) Read added in v1.1.5

func (*IClientRPCServiceHandshakeResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceHandshakeResult) String added in v1.1.5

func (*IClientRPCServiceHandshakeResult) Write added in v1.1.5

type IClientRPCServiceInsertRecordArgs added in v1.1.5

type IClientRPCServiceInsertRecordArgs struct {
	Req *TSInsertRecordReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceInsertRecordArgs added in v1.1.5

func NewIClientRPCServiceInsertRecordArgs() *IClientRPCServiceInsertRecordArgs

func (*IClientRPCServiceInsertRecordArgs) GetReq added in v1.1.5

func (*IClientRPCServiceInsertRecordArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceInsertRecordArgs) Read added in v1.1.5

func (*IClientRPCServiceInsertRecordArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceInsertRecordArgs) String added in v1.1.5

func (*IClientRPCServiceInsertRecordArgs) Write added in v1.1.5

type IClientRPCServiceInsertRecordResult added in v1.1.5

type IClientRPCServiceInsertRecordResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceInsertRecordResult added in v1.1.5

func NewIClientRPCServiceInsertRecordResult() *IClientRPCServiceInsertRecordResult

func (*IClientRPCServiceInsertRecordResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceInsertRecordResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceInsertRecordResult) IsSetSuccess() bool

func (*IClientRPCServiceInsertRecordResult) Read added in v1.1.5

func (*IClientRPCServiceInsertRecordResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceInsertRecordResult) String added in v1.1.5

func (*IClientRPCServiceInsertRecordResult) Write added in v1.1.5

type IClientRPCServiceInsertRecordsArgs added in v1.1.5

type IClientRPCServiceInsertRecordsArgs struct {
	Req *TSInsertRecordsReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceInsertRecordsArgs added in v1.1.5

func NewIClientRPCServiceInsertRecordsArgs() *IClientRPCServiceInsertRecordsArgs

func (*IClientRPCServiceInsertRecordsArgs) GetReq added in v1.1.5

func (*IClientRPCServiceInsertRecordsArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceInsertRecordsArgs) Read added in v1.1.5

func (*IClientRPCServiceInsertRecordsArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceInsertRecordsArgs) String added in v1.1.5

func (*IClientRPCServiceInsertRecordsArgs) Write added in v1.1.5

type IClientRPCServiceInsertRecordsOfOneDeviceArgs added in v1.1.5

type IClientRPCServiceInsertRecordsOfOneDeviceArgs struct {
	Req *TSInsertRecordsOfOneDeviceReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceInsertRecordsOfOneDeviceArgs added in v1.1.5

func NewIClientRPCServiceInsertRecordsOfOneDeviceArgs() *IClientRPCServiceInsertRecordsOfOneDeviceArgs

func (*IClientRPCServiceInsertRecordsOfOneDeviceArgs) GetReq added in v1.1.5

func (*IClientRPCServiceInsertRecordsOfOneDeviceArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceInsertRecordsOfOneDeviceArgs) Read added in v1.1.5

func (*IClientRPCServiceInsertRecordsOfOneDeviceArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceInsertRecordsOfOneDeviceArgs) String added in v1.1.5

func (*IClientRPCServiceInsertRecordsOfOneDeviceArgs) Write added in v1.1.5

type IClientRPCServiceInsertRecordsOfOneDeviceResult added in v1.1.5

type IClientRPCServiceInsertRecordsOfOneDeviceResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceInsertRecordsOfOneDeviceResult added in v1.1.5

func NewIClientRPCServiceInsertRecordsOfOneDeviceResult() *IClientRPCServiceInsertRecordsOfOneDeviceResult

func (*IClientRPCServiceInsertRecordsOfOneDeviceResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceInsertRecordsOfOneDeviceResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceInsertRecordsOfOneDeviceResult) Read added in v1.1.5

func (*IClientRPCServiceInsertRecordsOfOneDeviceResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceInsertRecordsOfOneDeviceResult) String added in v1.1.5

func (*IClientRPCServiceInsertRecordsOfOneDeviceResult) Write added in v1.1.5

type IClientRPCServiceInsertRecordsResult added in v1.1.5

type IClientRPCServiceInsertRecordsResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceInsertRecordsResult added in v1.1.5

func NewIClientRPCServiceInsertRecordsResult() *IClientRPCServiceInsertRecordsResult

func (*IClientRPCServiceInsertRecordsResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceInsertRecordsResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceInsertRecordsResult) IsSetSuccess() bool

func (*IClientRPCServiceInsertRecordsResult) Read added in v1.1.5

func (*IClientRPCServiceInsertRecordsResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceInsertRecordsResult) String added in v1.1.5

func (*IClientRPCServiceInsertRecordsResult) Write added in v1.1.5

type IClientRPCServiceInsertStringRecordArgs added in v1.1.5

type IClientRPCServiceInsertStringRecordArgs struct {
	Req *TSInsertStringRecordReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceInsertStringRecordArgs added in v1.1.5

func NewIClientRPCServiceInsertStringRecordArgs() *IClientRPCServiceInsertStringRecordArgs

func (*IClientRPCServiceInsertStringRecordArgs) GetReq added in v1.1.5

func (*IClientRPCServiceInsertStringRecordArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceInsertStringRecordArgs) Read added in v1.1.5

func (*IClientRPCServiceInsertStringRecordArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceInsertStringRecordArgs) String added in v1.1.5

func (*IClientRPCServiceInsertStringRecordArgs) Write added in v1.1.5

type IClientRPCServiceInsertStringRecordResult added in v1.1.5

type IClientRPCServiceInsertStringRecordResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceInsertStringRecordResult added in v1.1.5

func NewIClientRPCServiceInsertStringRecordResult() *IClientRPCServiceInsertStringRecordResult

func (*IClientRPCServiceInsertStringRecordResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceInsertStringRecordResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceInsertStringRecordResult) Read added in v1.1.5

func (*IClientRPCServiceInsertStringRecordResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceInsertStringRecordResult) String added in v1.1.5

func (*IClientRPCServiceInsertStringRecordResult) Write added in v1.1.5

type IClientRPCServiceInsertStringRecordsArgs added in v1.1.5

type IClientRPCServiceInsertStringRecordsArgs struct {
	Req *TSInsertStringRecordsReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceInsertStringRecordsArgs added in v1.1.5

func NewIClientRPCServiceInsertStringRecordsArgs() *IClientRPCServiceInsertStringRecordsArgs

func (*IClientRPCServiceInsertStringRecordsArgs) GetReq added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsArgs) Read added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsArgs) String added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsArgs) Write added in v1.1.5

type IClientRPCServiceInsertStringRecordsOfOneDeviceArgs added in v1.1.5

type IClientRPCServiceInsertStringRecordsOfOneDeviceArgs struct {
	Req *TSInsertStringRecordsOfOneDeviceReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceInsertStringRecordsOfOneDeviceArgs added in v1.1.5

func NewIClientRPCServiceInsertStringRecordsOfOneDeviceArgs() *IClientRPCServiceInsertStringRecordsOfOneDeviceArgs

func (*IClientRPCServiceInsertStringRecordsOfOneDeviceArgs) GetReq added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsOfOneDeviceArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsOfOneDeviceArgs) Read added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsOfOneDeviceArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsOfOneDeviceArgs) String added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsOfOneDeviceArgs) Write added in v1.1.5

type IClientRPCServiceInsertStringRecordsOfOneDeviceResult added in v1.1.5

type IClientRPCServiceInsertStringRecordsOfOneDeviceResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceInsertStringRecordsOfOneDeviceResult added in v1.1.5

func NewIClientRPCServiceInsertStringRecordsOfOneDeviceResult() *IClientRPCServiceInsertStringRecordsOfOneDeviceResult

func (*IClientRPCServiceInsertStringRecordsOfOneDeviceResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsOfOneDeviceResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsOfOneDeviceResult) Read added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsOfOneDeviceResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsOfOneDeviceResult) String added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsOfOneDeviceResult) Write added in v1.1.5

type IClientRPCServiceInsertStringRecordsResult added in v1.1.5

type IClientRPCServiceInsertStringRecordsResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceInsertStringRecordsResult added in v1.1.5

func NewIClientRPCServiceInsertStringRecordsResult() *IClientRPCServiceInsertStringRecordsResult

func (*IClientRPCServiceInsertStringRecordsResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsResult) Read added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsResult) String added in v1.1.5

func (*IClientRPCServiceInsertStringRecordsResult) Write added in v1.1.5

type IClientRPCServiceInsertTabletArgs added in v1.1.5

type IClientRPCServiceInsertTabletArgs struct {
	Req *TSInsertTabletReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceInsertTabletArgs added in v1.1.5

func NewIClientRPCServiceInsertTabletArgs() *IClientRPCServiceInsertTabletArgs

func (*IClientRPCServiceInsertTabletArgs) GetReq added in v1.1.5

func (*IClientRPCServiceInsertTabletArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceInsertTabletArgs) Read added in v1.1.5

func (*IClientRPCServiceInsertTabletArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceInsertTabletArgs) String added in v1.1.5

func (*IClientRPCServiceInsertTabletArgs) Write added in v1.1.5

type IClientRPCServiceInsertTabletResult added in v1.1.5

type IClientRPCServiceInsertTabletResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceInsertTabletResult added in v1.1.5

func NewIClientRPCServiceInsertTabletResult() *IClientRPCServiceInsertTabletResult

func (*IClientRPCServiceInsertTabletResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceInsertTabletResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceInsertTabletResult) IsSetSuccess() bool

func (*IClientRPCServiceInsertTabletResult) Read added in v1.1.5

func (*IClientRPCServiceInsertTabletResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceInsertTabletResult) String added in v1.1.5

func (*IClientRPCServiceInsertTabletResult) Write added in v1.1.5

type IClientRPCServiceInsertTabletsArgs added in v1.1.5

type IClientRPCServiceInsertTabletsArgs struct {
	Req *TSInsertTabletsReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceInsertTabletsArgs added in v1.1.5

func NewIClientRPCServiceInsertTabletsArgs() *IClientRPCServiceInsertTabletsArgs

func (*IClientRPCServiceInsertTabletsArgs) GetReq added in v1.1.5

func (*IClientRPCServiceInsertTabletsArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceInsertTabletsArgs) Read added in v1.1.5

func (*IClientRPCServiceInsertTabletsArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceInsertTabletsArgs) String added in v1.1.5

func (*IClientRPCServiceInsertTabletsArgs) Write added in v1.1.5

type IClientRPCServiceInsertTabletsResult added in v1.1.5

type IClientRPCServiceInsertTabletsResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceInsertTabletsResult added in v1.1.5

func NewIClientRPCServiceInsertTabletsResult() *IClientRPCServiceInsertTabletsResult

func (*IClientRPCServiceInsertTabletsResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceInsertTabletsResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceInsertTabletsResult) IsSetSuccess() bool

func (*IClientRPCServiceInsertTabletsResult) Read added in v1.1.5

func (*IClientRPCServiceInsertTabletsResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceInsertTabletsResult) String added in v1.1.5

func (*IClientRPCServiceInsertTabletsResult) Write added in v1.1.5

type IClientRPCServiceOpenSessionArgs added in v1.1.5

type IClientRPCServiceOpenSessionArgs struct {
	Req *TSOpenSessionReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceOpenSessionArgs added in v1.1.5

func NewIClientRPCServiceOpenSessionArgs() *IClientRPCServiceOpenSessionArgs

func (*IClientRPCServiceOpenSessionArgs) GetReq added in v1.1.5

func (*IClientRPCServiceOpenSessionArgs) IsSetReq added in v1.1.5

func (p *IClientRPCServiceOpenSessionArgs) IsSetReq() bool

func (*IClientRPCServiceOpenSessionArgs) Read added in v1.1.5

func (*IClientRPCServiceOpenSessionArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceOpenSessionArgs) String added in v1.1.5

func (*IClientRPCServiceOpenSessionArgs) Write added in v1.1.5

type IClientRPCServiceOpenSessionResult added in v1.1.5

type IClientRPCServiceOpenSessionResult struct {
	Success *TSOpenSessionResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceOpenSessionResult added in v1.1.5

func NewIClientRPCServiceOpenSessionResult() *IClientRPCServiceOpenSessionResult

func (*IClientRPCServiceOpenSessionResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceOpenSessionResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceOpenSessionResult) IsSetSuccess() bool

func (*IClientRPCServiceOpenSessionResult) Read added in v1.1.5

func (*IClientRPCServiceOpenSessionResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceOpenSessionResult) String added in v1.1.5

func (*IClientRPCServiceOpenSessionResult) Write added in v1.1.5

type IClientRPCServiceProcessor added in v1.1.5

type IClientRPCServiceProcessor struct {
	// contains filtered or unexported fields
}

func NewIClientRPCServiceProcessor added in v1.1.5

func NewIClientRPCServiceProcessor(handler IClientRPCService) *IClientRPCServiceProcessor

func (*IClientRPCServiceProcessor) AddToProcessorMap added in v1.1.5

func (p *IClientRPCServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*IClientRPCServiceProcessor) GetProcessorFunction added in v1.1.5

func (p *IClientRPCServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*IClientRPCServiceProcessor) Process added in v1.1.5

func (p *IClientRPCServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*IClientRPCServiceProcessor) ProcessorMap added in v1.1.5

type IClientRPCServicePruneSchemaTemplateArgs added in v1.1.5

type IClientRPCServicePruneSchemaTemplateArgs struct {
	Req *TSPruneSchemaTemplateReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServicePruneSchemaTemplateArgs added in v1.1.5

func NewIClientRPCServicePruneSchemaTemplateArgs() *IClientRPCServicePruneSchemaTemplateArgs

func (*IClientRPCServicePruneSchemaTemplateArgs) GetReq added in v1.1.5

func (*IClientRPCServicePruneSchemaTemplateArgs) IsSetReq added in v1.1.5

func (*IClientRPCServicePruneSchemaTemplateArgs) Read added in v1.1.5

func (*IClientRPCServicePruneSchemaTemplateArgs) ReadField1 added in v1.1.5

func (*IClientRPCServicePruneSchemaTemplateArgs) String added in v1.1.5

func (*IClientRPCServicePruneSchemaTemplateArgs) Write added in v1.1.5

type IClientRPCServicePruneSchemaTemplateResult added in v1.1.5

type IClientRPCServicePruneSchemaTemplateResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServicePruneSchemaTemplateResult added in v1.1.5

func NewIClientRPCServicePruneSchemaTemplateResult() *IClientRPCServicePruneSchemaTemplateResult

func (*IClientRPCServicePruneSchemaTemplateResult) GetSuccess added in v1.1.5

func (*IClientRPCServicePruneSchemaTemplateResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServicePruneSchemaTemplateResult) Read added in v1.1.5

func (*IClientRPCServicePruneSchemaTemplateResult) ReadField0 added in v1.1.5

func (*IClientRPCServicePruneSchemaTemplateResult) String added in v1.1.5

func (*IClientRPCServicePruneSchemaTemplateResult) Write added in v1.1.5

type IClientRPCServiceQuerySchemaTemplateArgs added in v1.1.5

type IClientRPCServiceQuerySchemaTemplateArgs struct {
	Req *TSQueryTemplateReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceQuerySchemaTemplateArgs added in v1.1.5

func NewIClientRPCServiceQuerySchemaTemplateArgs() *IClientRPCServiceQuerySchemaTemplateArgs

func (*IClientRPCServiceQuerySchemaTemplateArgs) GetReq added in v1.1.5

func (*IClientRPCServiceQuerySchemaTemplateArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceQuerySchemaTemplateArgs) Read added in v1.1.5

func (*IClientRPCServiceQuerySchemaTemplateArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceQuerySchemaTemplateArgs) String added in v1.1.5

func (*IClientRPCServiceQuerySchemaTemplateArgs) Write added in v1.1.5

type IClientRPCServiceQuerySchemaTemplateResult added in v1.1.5

type IClientRPCServiceQuerySchemaTemplateResult struct {
	Success *TSQueryTemplateResp `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceQuerySchemaTemplateResult added in v1.1.5

func NewIClientRPCServiceQuerySchemaTemplateResult() *IClientRPCServiceQuerySchemaTemplateResult

func (*IClientRPCServiceQuerySchemaTemplateResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceQuerySchemaTemplateResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceQuerySchemaTemplateResult) Read added in v1.1.5

func (*IClientRPCServiceQuerySchemaTemplateResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceQuerySchemaTemplateResult) String added in v1.1.5

func (*IClientRPCServiceQuerySchemaTemplateResult) Write added in v1.1.5

type IClientRPCServiceRequestStatementIdArgs added in v1.1.5

type IClientRPCServiceRequestStatementIdArgs struct {
	SessionId int64 `thrift:"sessionId,1" db:"sessionId" json:"sessionId"`
}

Attributes:

  • SessionId

func NewIClientRPCServiceRequestStatementIdArgs added in v1.1.5

func NewIClientRPCServiceRequestStatementIdArgs() *IClientRPCServiceRequestStatementIdArgs

func (*IClientRPCServiceRequestStatementIdArgs) GetSessionId added in v1.1.5

func (*IClientRPCServiceRequestStatementIdArgs) Read added in v1.1.5

func (*IClientRPCServiceRequestStatementIdArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceRequestStatementIdArgs) String added in v1.1.5

func (*IClientRPCServiceRequestStatementIdArgs) Write added in v1.1.5

type IClientRPCServiceRequestStatementIdResult added in v1.1.5

type IClientRPCServiceRequestStatementIdResult struct {
	Success *int64 `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceRequestStatementIdResult added in v1.1.5

func NewIClientRPCServiceRequestStatementIdResult() *IClientRPCServiceRequestStatementIdResult

func (*IClientRPCServiceRequestStatementIdResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceRequestStatementIdResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceRequestStatementIdResult) Read added in v1.1.5

func (*IClientRPCServiceRequestStatementIdResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceRequestStatementIdResult) String added in v1.1.5

func (*IClientRPCServiceRequestStatementIdResult) Write added in v1.1.5

type IClientRPCServiceSendFileArgs added in v1.1.5

type IClientRPCServiceSendFileArgs struct {
	MetaInfo *TSyncTransportMetaInfo `thrift:"metaInfo,1" db:"metaInfo" json:"metaInfo"`
	Buff     []byte                  `thrift:"buff,2" db:"buff" json:"buff"`
}

Attributes:

  • MetaInfo
  • Buff

func NewIClientRPCServiceSendFileArgs added in v1.1.5

func NewIClientRPCServiceSendFileArgs() *IClientRPCServiceSendFileArgs

func (*IClientRPCServiceSendFileArgs) GetBuff added in v1.1.5

func (p *IClientRPCServiceSendFileArgs) GetBuff() []byte

func (*IClientRPCServiceSendFileArgs) GetMetaInfo added in v1.1.5

func (*IClientRPCServiceSendFileArgs) IsSetMetaInfo added in v1.1.5

func (p *IClientRPCServiceSendFileArgs) IsSetMetaInfo() bool

func (*IClientRPCServiceSendFileArgs) Read added in v1.1.5

func (*IClientRPCServiceSendFileArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceSendFileArgs) ReadField2 added in v1.1.5

func (*IClientRPCServiceSendFileArgs) String added in v1.1.5

func (*IClientRPCServiceSendFileArgs) Write added in v1.1.5

type IClientRPCServiceSendFileResult added in v1.1.5

type IClientRPCServiceSendFileResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceSendFileResult added in v1.1.5

func NewIClientRPCServiceSendFileResult() *IClientRPCServiceSendFileResult

func (*IClientRPCServiceSendFileResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceSendFileResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceSendFileResult) IsSetSuccess() bool

func (*IClientRPCServiceSendFileResult) Read added in v1.1.5

func (*IClientRPCServiceSendFileResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceSendFileResult) String added in v1.1.5

func (*IClientRPCServiceSendFileResult) Write added in v1.1.5

type IClientRPCServiceSendPipeDataArgs added in v1.1.5

type IClientRPCServiceSendPipeDataArgs struct {
	Buff []byte `thrift:"buff,1" db:"buff" json:"buff"`
}

Attributes:

  • Buff

func NewIClientRPCServiceSendPipeDataArgs added in v1.1.5

func NewIClientRPCServiceSendPipeDataArgs() *IClientRPCServiceSendPipeDataArgs

func (*IClientRPCServiceSendPipeDataArgs) GetBuff added in v1.1.5

func (p *IClientRPCServiceSendPipeDataArgs) GetBuff() []byte

func (*IClientRPCServiceSendPipeDataArgs) Read added in v1.1.5

func (*IClientRPCServiceSendPipeDataArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceSendPipeDataArgs) String added in v1.1.5

func (*IClientRPCServiceSendPipeDataArgs) Write added in v1.1.5

type IClientRPCServiceSendPipeDataResult added in v1.1.5

type IClientRPCServiceSendPipeDataResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceSendPipeDataResult added in v1.1.5

func NewIClientRPCServiceSendPipeDataResult() *IClientRPCServiceSendPipeDataResult

func (*IClientRPCServiceSendPipeDataResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceSendPipeDataResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceSendPipeDataResult) IsSetSuccess() bool

func (*IClientRPCServiceSendPipeDataResult) Read added in v1.1.5

func (*IClientRPCServiceSendPipeDataResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceSendPipeDataResult) String added in v1.1.5

func (*IClientRPCServiceSendPipeDataResult) Write added in v1.1.5

type IClientRPCServiceSetSchemaTemplateArgs added in v1.1.5

type IClientRPCServiceSetSchemaTemplateArgs struct {
	Req *TSSetSchemaTemplateReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceSetSchemaTemplateArgs added in v1.1.5

func NewIClientRPCServiceSetSchemaTemplateArgs() *IClientRPCServiceSetSchemaTemplateArgs

func (*IClientRPCServiceSetSchemaTemplateArgs) GetReq added in v1.1.5

func (*IClientRPCServiceSetSchemaTemplateArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceSetSchemaTemplateArgs) Read added in v1.1.5

func (*IClientRPCServiceSetSchemaTemplateArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceSetSchemaTemplateArgs) String added in v1.1.5

func (*IClientRPCServiceSetSchemaTemplateArgs) Write added in v1.1.5

type IClientRPCServiceSetSchemaTemplateResult added in v1.1.5

type IClientRPCServiceSetSchemaTemplateResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceSetSchemaTemplateResult added in v1.1.5

func NewIClientRPCServiceSetSchemaTemplateResult() *IClientRPCServiceSetSchemaTemplateResult

func (*IClientRPCServiceSetSchemaTemplateResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceSetSchemaTemplateResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceSetSchemaTemplateResult) Read added in v1.1.5

func (*IClientRPCServiceSetSchemaTemplateResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceSetSchemaTemplateResult) String added in v1.1.5

func (*IClientRPCServiceSetSchemaTemplateResult) Write added in v1.1.5

type IClientRPCServiceSetStorageGroupArgs added in v1.1.5

type IClientRPCServiceSetStorageGroupArgs struct {
	SessionId    int64  `thrift:"sessionId,1" db:"sessionId" json:"sessionId"`
	StorageGroup string `thrift:"storageGroup,2" db:"storageGroup" json:"storageGroup"`
}

Attributes:

  • SessionId
  • StorageGroup

func NewIClientRPCServiceSetStorageGroupArgs added in v1.1.5

func NewIClientRPCServiceSetStorageGroupArgs() *IClientRPCServiceSetStorageGroupArgs

func (*IClientRPCServiceSetStorageGroupArgs) GetSessionId added in v1.1.5

func (p *IClientRPCServiceSetStorageGroupArgs) GetSessionId() int64

func (*IClientRPCServiceSetStorageGroupArgs) GetStorageGroup added in v1.1.5

func (p *IClientRPCServiceSetStorageGroupArgs) GetStorageGroup() string

func (*IClientRPCServiceSetStorageGroupArgs) Read added in v1.1.5

func (*IClientRPCServiceSetStorageGroupArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceSetStorageGroupArgs) ReadField2 added in v1.1.5

func (*IClientRPCServiceSetStorageGroupArgs) String added in v1.1.5

func (*IClientRPCServiceSetStorageGroupArgs) Write added in v1.1.5

type IClientRPCServiceSetStorageGroupResult added in v1.1.5

type IClientRPCServiceSetStorageGroupResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceSetStorageGroupResult added in v1.1.5

func NewIClientRPCServiceSetStorageGroupResult() *IClientRPCServiceSetStorageGroupResult

func (*IClientRPCServiceSetStorageGroupResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceSetStorageGroupResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceSetStorageGroupResult) IsSetSuccess() bool

func (*IClientRPCServiceSetStorageGroupResult) Read added in v1.1.5

func (*IClientRPCServiceSetStorageGroupResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceSetStorageGroupResult) String added in v1.1.5

func (*IClientRPCServiceSetStorageGroupResult) Write added in v1.1.5

type IClientRPCServiceSetTimeZoneArgs added in v1.1.5

type IClientRPCServiceSetTimeZoneArgs struct {
	Req *TSSetTimeZoneReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceSetTimeZoneArgs added in v1.1.5

func NewIClientRPCServiceSetTimeZoneArgs() *IClientRPCServiceSetTimeZoneArgs

func (*IClientRPCServiceSetTimeZoneArgs) GetReq added in v1.1.5

func (*IClientRPCServiceSetTimeZoneArgs) IsSetReq added in v1.1.5

func (p *IClientRPCServiceSetTimeZoneArgs) IsSetReq() bool

func (*IClientRPCServiceSetTimeZoneArgs) Read added in v1.1.5

func (*IClientRPCServiceSetTimeZoneArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceSetTimeZoneArgs) String added in v1.1.5

func (*IClientRPCServiceSetTimeZoneArgs) Write added in v1.1.5

type IClientRPCServiceSetTimeZoneResult added in v1.1.5

type IClientRPCServiceSetTimeZoneResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceSetTimeZoneResult added in v1.1.5

func NewIClientRPCServiceSetTimeZoneResult() *IClientRPCServiceSetTimeZoneResult

func (*IClientRPCServiceSetTimeZoneResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceSetTimeZoneResult) IsSetSuccess added in v1.1.5

func (p *IClientRPCServiceSetTimeZoneResult) IsSetSuccess() bool

func (*IClientRPCServiceSetTimeZoneResult) Read added in v1.1.5

func (*IClientRPCServiceSetTimeZoneResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceSetTimeZoneResult) String added in v1.1.5

func (*IClientRPCServiceSetTimeZoneResult) Write added in v1.1.5

type IClientRPCServiceTestInsertRecordArgs added in v1.1.5

type IClientRPCServiceTestInsertRecordArgs struct {
	Req *TSInsertRecordReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceTestInsertRecordArgs added in v1.1.5

func NewIClientRPCServiceTestInsertRecordArgs() *IClientRPCServiceTestInsertRecordArgs

func (*IClientRPCServiceTestInsertRecordArgs) GetReq added in v1.1.5

func (*IClientRPCServiceTestInsertRecordArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceTestInsertRecordArgs) Read added in v1.1.5

func (*IClientRPCServiceTestInsertRecordArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceTestInsertRecordArgs) String added in v1.1.5

func (*IClientRPCServiceTestInsertRecordArgs) Write added in v1.1.5

type IClientRPCServiceTestInsertRecordResult added in v1.1.5

type IClientRPCServiceTestInsertRecordResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceTestInsertRecordResult added in v1.1.5

func NewIClientRPCServiceTestInsertRecordResult() *IClientRPCServiceTestInsertRecordResult

func (*IClientRPCServiceTestInsertRecordResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceTestInsertRecordResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceTestInsertRecordResult) Read added in v1.1.5

func (*IClientRPCServiceTestInsertRecordResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceTestInsertRecordResult) String added in v1.1.5

func (*IClientRPCServiceTestInsertRecordResult) Write added in v1.1.5

type IClientRPCServiceTestInsertRecordsArgs added in v1.1.5

type IClientRPCServiceTestInsertRecordsArgs struct {
	Req *TSInsertRecordsReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceTestInsertRecordsArgs added in v1.1.5

func NewIClientRPCServiceTestInsertRecordsArgs() *IClientRPCServiceTestInsertRecordsArgs

func (*IClientRPCServiceTestInsertRecordsArgs) GetReq added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsArgs) Read added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsArgs) String added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsArgs) Write added in v1.1.5

type IClientRPCServiceTestInsertRecordsOfOneDeviceArgs added in v1.1.5

type IClientRPCServiceTestInsertRecordsOfOneDeviceArgs struct {
	Req *TSInsertRecordsOfOneDeviceReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceTestInsertRecordsOfOneDeviceArgs added in v1.1.5

func NewIClientRPCServiceTestInsertRecordsOfOneDeviceArgs() *IClientRPCServiceTestInsertRecordsOfOneDeviceArgs

func (*IClientRPCServiceTestInsertRecordsOfOneDeviceArgs) GetReq added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsOfOneDeviceArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsOfOneDeviceArgs) Read added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsOfOneDeviceArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsOfOneDeviceArgs) String added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsOfOneDeviceArgs) Write added in v1.1.5

type IClientRPCServiceTestInsertRecordsOfOneDeviceResult added in v1.1.5

type IClientRPCServiceTestInsertRecordsOfOneDeviceResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceTestInsertRecordsOfOneDeviceResult added in v1.1.5

func NewIClientRPCServiceTestInsertRecordsOfOneDeviceResult() *IClientRPCServiceTestInsertRecordsOfOneDeviceResult

func (*IClientRPCServiceTestInsertRecordsOfOneDeviceResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsOfOneDeviceResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsOfOneDeviceResult) Read added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsOfOneDeviceResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsOfOneDeviceResult) String added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsOfOneDeviceResult) Write added in v1.1.5

type IClientRPCServiceTestInsertRecordsResult added in v1.1.5

type IClientRPCServiceTestInsertRecordsResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceTestInsertRecordsResult added in v1.1.5

func NewIClientRPCServiceTestInsertRecordsResult() *IClientRPCServiceTestInsertRecordsResult

func (*IClientRPCServiceTestInsertRecordsResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsResult) Read added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsResult) String added in v1.1.5

func (*IClientRPCServiceTestInsertRecordsResult) Write added in v1.1.5

type IClientRPCServiceTestInsertStringRecordArgs added in v1.1.5

type IClientRPCServiceTestInsertStringRecordArgs struct {
	Req *TSInsertStringRecordReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceTestInsertStringRecordArgs added in v1.1.5

func NewIClientRPCServiceTestInsertStringRecordArgs() *IClientRPCServiceTestInsertStringRecordArgs

func (*IClientRPCServiceTestInsertStringRecordArgs) GetReq added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordArgs) Read added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordArgs) String added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordArgs) Write added in v1.1.5

type IClientRPCServiceTestInsertStringRecordResult added in v1.1.5

type IClientRPCServiceTestInsertStringRecordResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceTestInsertStringRecordResult added in v1.1.5

func NewIClientRPCServiceTestInsertStringRecordResult() *IClientRPCServiceTestInsertStringRecordResult

func (*IClientRPCServiceTestInsertStringRecordResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordResult) Read added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordResult) String added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordResult) Write added in v1.1.5

type IClientRPCServiceTestInsertStringRecordsArgs added in v1.1.5

type IClientRPCServiceTestInsertStringRecordsArgs struct {
	Req *TSInsertStringRecordsReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceTestInsertStringRecordsArgs added in v1.1.5

func NewIClientRPCServiceTestInsertStringRecordsArgs() *IClientRPCServiceTestInsertStringRecordsArgs

func (*IClientRPCServiceTestInsertStringRecordsArgs) GetReq added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordsArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordsArgs) Read added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordsArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordsArgs) String added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordsArgs) Write added in v1.1.5

type IClientRPCServiceTestInsertStringRecordsResult added in v1.1.5

type IClientRPCServiceTestInsertStringRecordsResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceTestInsertStringRecordsResult added in v1.1.5

func NewIClientRPCServiceTestInsertStringRecordsResult() *IClientRPCServiceTestInsertStringRecordsResult

func (*IClientRPCServiceTestInsertStringRecordsResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordsResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordsResult) Read added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordsResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordsResult) String added in v1.1.5

func (*IClientRPCServiceTestInsertStringRecordsResult) Write added in v1.1.5

type IClientRPCServiceTestInsertTabletArgs added in v1.1.5

type IClientRPCServiceTestInsertTabletArgs struct {
	Req *TSInsertTabletReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceTestInsertTabletArgs added in v1.1.5

func NewIClientRPCServiceTestInsertTabletArgs() *IClientRPCServiceTestInsertTabletArgs

func (*IClientRPCServiceTestInsertTabletArgs) GetReq added in v1.1.5

func (*IClientRPCServiceTestInsertTabletArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceTestInsertTabletArgs) Read added in v1.1.5

func (*IClientRPCServiceTestInsertTabletArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceTestInsertTabletArgs) String added in v1.1.5

func (*IClientRPCServiceTestInsertTabletArgs) Write added in v1.1.5

type IClientRPCServiceTestInsertTabletResult added in v1.1.5

type IClientRPCServiceTestInsertTabletResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceTestInsertTabletResult added in v1.1.5

func NewIClientRPCServiceTestInsertTabletResult() *IClientRPCServiceTestInsertTabletResult

func (*IClientRPCServiceTestInsertTabletResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceTestInsertTabletResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceTestInsertTabletResult) Read added in v1.1.5

func (*IClientRPCServiceTestInsertTabletResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceTestInsertTabletResult) String added in v1.1.5

func (*IClientRPCServiceTestInsertTabletResult) Write added in v1.1.5

type IClientRPCServiceTestInsertTabletsArgs added in v1.1.5

type IClientRPCServiceTestInsertTabletsArgs struct {
	Req *TSInsertTabletsReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceTestInsertTabletsArgs added in v1.1.5

func NewIClientRPCServiceTestInsertTabletsArgs() *IClientRPCServiceTestInsertTabletsArgs

func (*IClientRPCServiceTestInsertTabletsArgs) GetReq added in v1.1.5

func (*IClientRPCServiceTestInsertTabletsArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceTestInsertTabletsArgs) Read added in v1.1.5

func (*IClientRPCServiceTestInsertTabletsArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceTestInsertTabletsArgs) String added in v1.1.5

func (*IClientRPCServiceTestInsertTabletsArgs) Write added in v1.1.5

type IClientRPCServiceTestInsertTabletsResult added in v1.1.5

type IClientRPCServiceTestInsertTabletsResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceTestInsertTabletsResult added in v1.1.5

func NewIClientRPCServiceTestInsertTabletsResult() *IClientRPCServiceTestInsertTabletsResult

func (*IClientRPCServiceTestInsertTabletsResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceTestInsertTabletsResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceTestInsertTabletsResult) Read added in v1.1.5

func (*IClientRPCServiceTestInsertTabletsResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceTestInsertTabletsResult) String added in v1.1.5

func (*IClientRPCServiceTestInsertTabletsResult) Write added in v1.1.5

type IClientRPCServiceUnsetSchemaTemplateArgs added in v1.1.5

type IClientRPCServiceUnsetSchemaTemplateArgs struct {
	Req *TSUnsetSchemaTemplateReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewIClientRPCServiceUnsetSchemaTemplateArgs added in v1.1.5

func NewIClientRPCServiceUnsetSchemaTemplateArgs() *IClientRPCServiceUnsetSchemaTemplateArgs

func (*IClientRPCServiceUnsetSchemaTemplateArgs) GetReq added in v1.1.5

func (*IClientRPCServiceUnsetSchemaTemplateArgs) IsSetReq added in v1.1.5

func (*IClientRPCServiceUnsetSchemaTemplateArgs) Read added in v1.1.5

func (*IClientRPCServiceUnsetSchemaTemplateArgs) ReadField1 added in v1.1.5

func (*IClientRPCServiceUnsetSchemaTemplateArgs) String added in v1.1.5

func (*IClientRPCServiceUnsetSchemaTemplateArgs) Write added in v1.1.5

type IClientRPCServiceUnsetSchemaTemplateResult added in v1.1.5

type IClientRPCServiceUnsetSchemaTemplateResult struct {
	Success *common.TSStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}

Attributes:

  • Success

func NewIClientRPCServiceUnsetSchemaTemplateResult added in v1.1.5

func NewIClientRPCServiceUnsetSchemaTemplateResult() *IClientRPCServiceUnsetSchemaTemplateResult

func (*IClientRPCServiceUnsetSchemaTemplateResult) GetSuccess added in v1.1.5

func (*IClientRPCServiceUnsetSchemaTemplateResult) IsSetSuccess added in v1.1.5

func (*IClientRPCServiceUnsetSchemaTemplateResult) Read added in v1.1.5

func (*IClientRPCServiceUnsetSchemaTemplateResult) ReadField0 added in v1.1.5

func (*IClientRPCServiceUnsetSchemaTemplateResult) String added in v1.1.5

func (*IClientRPCServiceUnsetSchemaTemplateResult) Write added in v1.1.5

type ServerProperties

type ServerProperties struct {
	Version                            string   `thrift:"version,1,required" db:"version" json:"version"`
	SupportedTimeAggregationOperations []string `` /* 136-byte string literal not displayed */
	TimestampPrecision                 string   `thrift:"timestampPrecision,3,required" db:"timestampPrecision" json:"timestampPrecision"`
	MaxConcurrentClientNum             int32    `thrift:"maxConcurrentClientNum,4" db:"maxConcurrentClientNum" json:"maxConcurrentClientNum"`
	WatermarkSecretKey                 *string  `thrift:"watermarkSecretKey,5" db:"watermarkSecretKey" json:"watermarkSecretKey,omitempty"`
	WatermarkBitString                 *string  `thrift:"watermarkBitString,6" db:"watermarkBitString" json:"watermarkBitString,omitempty"`
	WatermarkParamMarkRate             *int32   `thrift:"watermarkParamMarkRate,7" db:"watermarkParamMarkRate" json:"watermarkParamMarkRate,omitempty"`
	WatermarkParamMaxRightBit          *int32   `thrift:"watermarkParamMaxRightBit,8" db:"watermarkParamMaxRightBit" json:"watermarkParamMaxRightBit,omitempty"`
	ThriftMaxFrameSize                 *int32   `thrift:"thriftMaxFrameSize,9" db:"thriftMaxFrameSize" json:"thriftMaxFrameSize,omitempty"`
	IsReadOnly                         *bool    `thrift:"isReadOnly,10" db:"isReadOnly" json:"isReadOnly,omitempty"`
	BuildInfo                          *string  `thrift:"buildInfo,11" db:"buildInfo" json:"buildInfo,omitempty"`
}

Attributes:

  • Version
  • SupportedTimeAggregationOperations
  • TimestampPrecision
  • MaxConcurrentClientNum
  • WatermarkSecretKey
  • WatermarkBitString
  • WatermarkParamMarkRate
  • WatermarkParamMaxRightBit
  • ThriftMaxFrameSize
  • IsReadOnly
  • BuildInfo
  • Logo
var IClientRPCServiceGetPropertiesResult_Success_DEFAULT *ServerProperties

func NewServerProperties

func NewServerProperties() *ServerProperties

func (*ServerProperties) Equals added in v0.12.1

func (p *ServerProperties) Equals(other *ServerProperties) bool

func (*ServerProperties) GetBuildInfo added in v1.1.5

func (p *ServerProperties) GetBuildInfo() string

func (*ServerProperties) GetIsReadOnly added in v0.13.0

func (p *ServerProperties) GetIsReadOnly() bool
func (p *ServerProperties) GetLogo() string

func (*ServerProperties) GetMaxConcurrentClientNum added in v0.13.0

func (p *ServerProperties) GetMaxConcurrentClientNum() int32

func (*ServerProperties) GetSupportedTimeAggregationOperations

func (p *ServerProperties) GetSupportedTimeAggregationOperations() []string

func (*ServerProperties) GetThriftMaxFrameSize added in v0.13.0

func (p *ServerProperties) GetThriftMaxFrameSize() int32

func (*ServerProperties) GetTimestampPrecision

func (p *ServerProperties) GetTimestampPrecision() string

func (*ServerProperties) GetVersion

func (p *ServerProperties) GetVersion() string

func (*ServerProperties) GetWatermarkBitString added in v0.13.0

func (p *ServerProperties) GetWatermarkBitString() string

func (*ServerProperties) GetWatermarkParamMarkRate added in v0.13.0

func (p *ServerProperties) GetWatermarkParamMarkRate() int32

func (*ServerProperties) GetWatermarkParamMaxRightBit added in v0.13.0

func (p *ServerProperties) GetWatermarkParamMaxRightBit() int32

func (*ServerProperties) GetWatermarkSecretKey added in v0.13.0

func (p *ServerProperties) GetWatermarkSecretKey() string

func (*ServerProperties) IsSetBuildInfo added in v1.1.5

func (p *ServerProperties) IsSetBuildInfo() bool

func (*ServerProperties) IsSetIsReadOnly added in v0.13.0

func (p *ServerProperties) IsSetIsReadOnly() bool
func (p *ServerProperties) IsSetLogo() bool

func (*ServerProperties) IsSetThriftMaxFrameSize added in v0.13.0

func (p *ServerProperties) IsSetThriftMaxFrameSize() bool

func (*ServerProperties) IsSetWatermarkBitString added in v0.13.0

func (p *ServerProperties) IsSetWatermarkBitString() bool

func (*ServerProperties) IsSetWatermarkParamMarkRate added in v0.13.0

func (p *ServerProperties) IsSetWatermarkParamMarkRate() bool

func (*ServerProperties) IsSetWatermarkParamMaxRightBit added in v0.13.0

func (p *ServerProperties) IsSetWatermarkParamMaxRightBit() bool

func (*ServerProperties) IsSetWatermarkSecretKey added in v0.13.0

func (p *ServerProperties) IsSetWatermarkSecretKey() bool

func (*ServerProperties) Read

func (p *ServerProperties) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerProperties) ReadField1

func (p *ServerProperties) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerProperties) ReadField10 added in v0.13.0

func (p *ServerProperties) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerProperties) ReadField11 added in v1.1.5

func (p *ServerProperties) ReadField11(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerProperties) ReadField12 added in v1.1.5

func (p *ServerProperties) ReadField12(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerProperties) ReadField2

func (p *ServerProperties) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerProperties) ReadField3

func (p *ServerProperties) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerProperties) ReadField4 added in v0.13.0

func (p *ServerProperties) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerProperties) ReadField5 added in v0.13.0

func (p *ServerProperties) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerProperties) ReadField6 added in v0.13.0

func (p *ServerProperties) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerProperties) ReadField7 added in v0.13.0

func (p *ServerProperties) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerProperties) ReadField8 added in v0.13.0

func (p *ServerProperties) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerProperties) ReadField9 added in v0.13.0

func (p *ServerProperties) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*ServerProperties) String

func (p *ServerProperties) String() string

func (*ServerProperties) Write

func (p *ServerProperties) Write(ctx context.Context, oprot thrift.TProtocol) error

type TCreateTimeseriesUsingSchemaTemplateReq added in v1.1.5

type TCreateTimeseriesUsingSchemaTemplateReq struct {
	SessionId      int64    `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	DevicePathList []string `thrift:"devicePathList,2,required" db:"devicePathList" json:"devicePathList"`
}

Attributes:

  • SessionId
  • DevicePathList
var IClientRPCServiceCreateTimeseriesUsingSchemaTemplateArgs_Req_DEFAULT *TCreateTimeseriesUsingSchemaTemplateReq

func NewTCreateTimeseriesUsingSchemaTemplateReq added in v1.1.5

func NewTCreateTimeseriesUsingSchemaTemplateReq() *TCreateTimeseriesUsingSchemaTemplateReq

func (*TCreateTimeseriesUsingSchemaTemplateReq) Equals added in v1.1.5

func (*TCreateTimeseriesUsingSchemaTemplateReq) GetDevicePathList added in v1.1.5

func (p *TCreateTimeseriesUsingSchemaTemplateReq) GetDevicePathList() []string

func (*TCreateTimeseriesUsingSchemaTemplateReq) GetSessionId added in v1.1.5

func (*TCreateTimeseriesUsingSchemaTemplateReq) Read added in v1.1.5

func (*TCreateTimeseriesUsingSchemaTemplateReq) ReadField1 added in v1.1.5

func (*TCreateTimeseriesUsingSchemaTemplateReq) ReadField2 added in v1.1.5

func (*TCreateTimeseriesUsingSchemaTemplateReq) String added in v1.1.5

func (*TCreateTimeseriesUsingSchemaTemplateReq) Write added in v1.1.5

type TSAggregationQueryReq added in v1.1.5

type TSAggregationQueryReq struct {
	SessionId    int64                     `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	StatementId  int64                     `thrift:"statementId,2,required" db:"statementId" json:"statementId"`
	Paths        []string                  `thrift:"paths,3,required" db:"paths" json:"paths"`
	Aggregations []common.TAggregationType `thrift:"aggregations,4,required" db:"aggregations" json:"aggregations"`
	StartTime    *int64                    `thrift:"startTime,5" db:"startTime" json:"startTime,omitempty"`
	EndTime      *int64                    `thrift:"endTime,6" db:"endTime" json:"endTime,omitempty"`
	Interval     *int64                    `thrift:"interval,7" db:"interval" json:"interval,omitempty"`
	SlidingStep  *int64                    `thrift:"slidingStep,8" db:"slidingStep" json:"slidingStep,omitempty"`
	FetchSize    *int32                    `thrift:"fetchSize,9" db:"fetchSize" json:"fetchSize,omitempty"`
	Timeout      *int64                    `thrift:"timeout,10" db:"timeout" json:"timeout,omitempty"`
}

Attributes:

  • SessionId
  • StatementId
  • Paths
  • Aggregations
  • StartTime
  • EndTime
  • Interval
  • SlidingStep
  • FetchSize
  • Timeout
var IClientRPCServiceExecuteAggregationQueryArgs_Req_DEFAULT *TSAggregationQueryReq
var IClientRPCServiceExecuteAggregationQueryV2Args_Req_DEFAULT *TSAggregationQueryReq

func NewTSAggregationQueryReq added in v1.1.5

func NewTSAggregationQueryReq() *TSAggregationQueryReq

func (*TSAggregationQueryReq) Equals added in v1.1.5

func (*TSAggregationQueryReq) GetAggregations added in v1.1.5

func (p *TSAggregationQueryReq) GetAggregations() []common.TAggregationType

func (*TSAggregationQueryReq) GetEndTime added in v1.1.5

func (p *TSAggregationQueryReq) GetEndTime() int64

func (*TSAggregationQueryReq) GetFetchSize added in v1.1.5

func (p *TSAggregationQueryReq) GetFetchSize() int32

func (*TSAggregationQueryReq) GetInterval added in v1.1.5

func (p *TSAggregationQueryReq) GetInterval() int64

func (*TSAggregationQueryReq) GetPaths added in v1.1.5

func (p *TSAggregationQueryReq) GetPaths() []string

func (*TSAggregationQueryReq) GetSessionId added in v1.1.5

func (p *TSAggregationQueryReq) GetSessionId() int64

func (*TSAggregationQueryReq) GetSlidingStep added in v1.1.5

func (p *TSAggregationQueryReq) GetSlidingStep() int64

func (*TSAggregationQueryReq) GetStartTime added in v1.1.5

func (p *TSAggregationQueryReq) GetStartTime() int64

func (*TSAggregationQueryReq) GetStatementId added in v1.1.5

func (p *TSAggregationQueryReq) GetStatementId() int64

func (*TSAggregationQueryReq) GetTimeout added in v1.1.5

func (p *TSAggregationQueryReq) GetTimeout() int64

func (*TSAggregationQueryReq) IsSetEndTime added in v1.1.5

func (p *TSAggregationQueryReq) IsSetEndTime() bool

func (*TSAggregationQueryReq) IsSetFetchSize added in v1.1.5

func (p *TSAggregationQueryReq) IsSetFetchSize() bool

func (*TSAggregationQueryReq) IsSetInterval added in v1.1.5

func (p *TSAggregationQueryReq) IsSetInterval() bool

func (*TSAggregationQueryReq) IsSetSlidingStep added in v1.1.5

func (p *TSAggregationQueryReq) IsSetSlidingStep() bool

func (*TSAggregationQueryReq) IsSetStartTime added in v1.1.5

func (p *TSAggregationQueryReq) IsSetStartTime() bool

func (*TSAggregationQueryReq) IsSetTimeout added in v1.1.5

func (p *TSAggregationQueryReq) IsSetTimeout() bool

func (*TSAggregationQueryReq) Read added in v1.1.5

func (*TSAggregationQueryReq) ReadField1 added in v1.1.5

func (p *TSAggregationQueryReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAggregationQueryReq) ReadField10 added in v1.1.5

func (p *TSAggregationQueryReq) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAggregationQueryReq) ReadField2 added in v1.1.5

func (p *TSAggregationQueryReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAggregationQueryReq) ReadField3 added in v1.1.5

func (p *TSAggregationQueryReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAggregationQueryReq) ReadField4 added in v1.1.5

func (p *TSAggregationQueryReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAggregationQueryReq) ReadField5 added in v1.1.5

func (p *TSAggregationQueryReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAggregationQueryReq) ReadField6 added in v1.1.5

func (p *TSAggregationQueryReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAggregationQueryReq) ReadField7 added in v1.1.5

func (p *TSAggregationQueryReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAggregationQueryReq) ReadField8 added in v1.1.5

func (p *TSAggregationQueryReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAggregationQueryReq) ReadField9 added in v1.1.5

func (p *TSAggregationQueryReq) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAggregationQueryReq) String added in v1.1.5

func (p *TSAggregationQueryReq) String() string

func (*TSAggregationQueryReq) Write added in v1.1.5

type TSAppendSchemaTemplateReq added in v0.13.0

type TSAppendSchemaTemplateReq struct {
	SessionId    int64    `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	Name         string   `thrift:"name,2,required" db:"name" json:"name"`
	IsAligned    bool     `thrift:"isAligned,3,required" db:"isAligned" json:"isAligned"`
	Measurements []string `thrift:"measurements,4,required" db:"measurements" json:"measurements"`
	DataTypes    []int32  `thrift:"dataTypes,5,required" db:"dataTypes" json:"dataTypes"`
	Encodings    []int32  `thrift:"encodings,6,required" db:"encodings" json:"encodings"`
	Compressors  []int32  `thrift:"compressors,7,required" db:"compressors" json:"compressors"`
}

Attributes:

  • SessionId
  • Name
  • IsAligned
  • Measurements
  • DataTypes
  • Encodings
  • Compressors
var IClientRPCServiceAppendSchemaTemplateArgs_Req_DEFAULT *TSAppendSchemaTemplateReq

func NewTSAppendSchemaTemplateReq added in v0.13.0

func NewTSAppendSchemaTemplateReq() *TSAppendSchemaTemplateReq

func (*TSAppendSchemaTemplateReq) Equals added in v0.13.0

func (*TSAppendSchemaTemplateReq) GetCompressors added in v0.13.0

func (p *TSAppendSchemaTemplateReq) GetCompressors() []int32

func (*TSAppendSchemaTemplateReq) GetDataTypes added in v0.13.0

func (p *TSAppendSchemaTemplateReq) GetDataTypes() []int32

func (*TSAppendSchemaTemplateReq) GetEncodings added in v0.13.0

func (p *TSAppendSchemaTemplateReq) GetEncodings() []int32

func (*TSAppendSchemaTemplateReq) GetIsAligned added in v0.13.0

func (p *TSAppendSchemaTemplateReq) GetIsAligned() bool

func (*TSAppendSchemaTemplateReq) GetMeasurements added in v0.13.0

func (p *TSAppendSchemaTemplateReq) GetMeasurements() []string

func (*TSAppendSchemaTemplateReq) GetName added in v0.13.0

func (p *TSAppendSchemaTemplateReq) GetName() string

func (*TSAppendSchemaTemplateReq) GetSessionId added in v0.13.0

func (p *TSAppendSchemaTemplateReq) GetSessionId() int64

func (*TSAppendSchemaTemplateReq) Read added in v0.13.0

func (*TSAppendSchemaTemplateReq) ReadField1 added in v0.13.0

func (p *TSAppendSchemaTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAppendSchemaTemplateReq) ReadField2 added in v0.13.0

func (p *TSAppendSchemaTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAppendSchemaTemplateReq) ReadField3 added in v0.13.0

func (p *TSAppendSchemaTemplateReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAppendSchemaTemplateReq) ReadField4 added in v0.13.0

func (p *TSAppendSchemaTemplateReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAppendSchemaTemplateReq) ReadField5 added in v0.13.0

func (p *TSAppendSchemaTemplateReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAppendSchemaTemplateReq) ReadField6 added in v0.13.0

func (p *TSAppendSchemaTemplateReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAppendSchemaTemplateReq) ReadField7 added in v0.13.0

func (p *TSAppendSchemaTemplateReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TSAppendSchemaTemplateReq) String added in v0.13.0

func (p *TSAppendSchemaTemplateReq) String() string

func (*TSAppendSchemaTemplateReq) Write added in v0.13.0

type TSBackupConfigurationResp added in v1.1.5

type TSBackupConfigurationResp struct {
	Status              *common.TSStatus `thrift:"status,1,required" db:"status" json:"status"`
	EnableOperationSync *bool            `thrift:"enableOperationSync,2" db:"enableOperationSync" json:"enableOperationSync,omitempty"`
	SecondaryAddress    *string          `thrift:"secondaryAddress,3" db:"secondaryAddress" json:"secondaryAddress,omitempty"`
	SecondaryPort       *int32           `thrift:"secondaryPort,4" db:"secondaryPort" json:"secondaryPort,omitempty"`
}

Attributes:

  • Status
  • EnableOperationSync
  • SecondaryAddress
  • SecondaryPort
var IClientRPCServiceGetBackupConfigurationResult_Success_DEFAULT *TSBackupConfigurationResp

func NewTSBackupConfigurationResp added in v1.1.5

func NewTSBackupConfigurationResp() *TSBackupConfigurationResp

func (*TSBackupConfigurationResp) Equals added in v1.1.5

func (*TSBackupConfigurationResp) GetEnableOperationSync added in v1.1.5

func (p *TSBackupConfigurationResp) GetEnableOperationSync() bool

func (*TSBackupConfigurationResp) GetSecondaryAddress added in v1.1.5

func (p *TSBackupConfigurationResp) GetSecondaryAddress() string

func (*TSBackupConfigurationResp) GetSecondaryPort added in v1.1.5

func (p *TSBackupConfigurationResp) GetSecondaryPort() int32

func (*TSBackupConfigurationResp) GetStatus added in v1.1.5

func (p *TSBackupConfigurationResp) GetStatus() *common.TSStatus

func (*TSBackupConfigurationResp) IsSetEnableOperationSync added in v1.1.5

func (p *TSBackupConfigurationResp) IsSetEnableOperationSync() bool

func (*TSBackupConfigurationResp) IsSetSecondaryAddress added in v1.1.5

func (p *TSBackupConfigurationResp) IsSetSecondaryAddress() bool

func (*TSBackupConfigurationResp) IsSetSecondaryPort added in v1.1.5

func (p *TSBackupConfigurationResp) IsSetSecondaryPort() bool

func (*TSBackupConfigurationResp) IsSetStatus added in v1.1.5

func (p *TSBackupConfigurationResp) IsSetStatus() bool

func (*TSBackupConfigurationResp) Read added in v1.1.5

func (*TSBackupConfigurationResp) ReadField1 added in v1.1.5

func (p *TSBackupConfigurationResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSBackupConfigurationResp) ReadField2 added in v1.1.5

func (p *TSBackupConfigurationResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSBackupConfigurationResp) ReadField3 added in v1.1.5

func (p *TSBackupConfigurationResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSBackupConfigurationResp) ReadField4 added in v1.1.5

func (p *TSBackupConfigurationResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSBackupConfigurationResp) String added in v1.1.5

func (p *TSBackupConfigurationResp) String() string

func (*TSBackupConfigurationResp) Write added in v1.1.5

type TSCancelOperationReq

type TSCancelOperationReq struct {
	SessionId int64 `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	QueryId   int64 `thrift:"queryId,2,required" db:"queryId" json:"queryId"`
}

Attributes:

  • SessionId
  • QueryId
var IClientRPCServiceCancelOperationArgs_Req_DEFAULT *TSCancelOperationReq

func NewTSCancelOperationReq

func NewTSCancelOperationReq() *TSCancelOperationReq

func (*TSCancelOperationReq) Equals added in v0.12.1

func (*TSCancelOperationReq) GetQueryId

func (p *TSCancelOperationReq) GetQueryId() int64

func (*TSCancelOperationReq) GetSessionId

func (p *TSCancelOperationReq) GetSessionId() int64

func (*TSCancelOperationReq) Read

func (*TSCancelOperationReq) ReadField1

func (p *TSCancelOperationReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCancelOperationReq) ReadField2

func (p *TSCancelOperationReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCancelOperationReq) String

func (p *TSCancelOperationReq) String() string

func (*TSCancelOperationReq) Write

type TSCloseOperationReq

type TSCloseOperationReq struct {
	SessionId   int64  `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	QueryId     *int64 `thrift:"queryId,2" db:"queryId" json:"queryId,omitempty"`
	StatementId *int64 `thrift:"statementId,3" db:"statementId" json:"statementId,omitempty"`
}

Attributes:

  • SessionId
  • QueryId
  • StatementId
var IClientRPCServiceCloseOperationArgs_Req_DEFAULT *TSCloseOperationReq

func NewTSCloseOperationReq

func NewTSCloseOperationReq() *TSCloseOperationReq

func (*TSCloseOperationReq) Equals added in v0.12.1

func (p *TSCloseOperationReq) Equals(other *TSCloseOperationReq) bool

func (*TSCloseOperationReq) GetQueryId

func (p *TSCloseOperationReq) GetQueryId() int64

func (*TSCloseOperationReq) GetSessionId

func (p *TSCloseOperationReq) GetSessionId() int64

func (*TSCloseOperationReq) GetStatementId

func (p *TSCloseOperationReq) GetStatementId() int64

func (*TSCloseOperationReq) IsSetQueryId

func (p *TSCloseOperationReq) IsSetQueryId() bool

func (*TSCloseOperationReq) IsSetStatementId

func (p *TSCloseOperationReq) IsSetStatementId() bool

func (*TSCloseOperationReq) Read

func (*TSCloseOperationReq) ReadField1

func (p *TSCloseOperationReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCloseOperationReq) ReadField2

func (p *TSCloseOperationReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCloseOperationReq) ReadField3

func (p *TSCloseOperationReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCloseOperationReq) String

func (p *TSCloseOperationReq) String() string

func (*TSCloseOperationReq) Write

type TSCloseSessionReq

type TSCloseSessionReq struct {
	SessionId int64 `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
}

Attributes:

  • SessionId
var IClientRPCServiceCloseSessionArgs_Req_DEFAULT *TSCloseSessionReq

func NewTSCloseSessionReq

func NewTSCloseSessionReq() *TSCloseSessionReq

func (*TSCloseSessionReq) Equals added in v0.12.1

func (p *TSCloseSessionReq) Equals(other *TSCloseSessionReq) bool

func (*TSCloseSessionReq) GetSessionId

func (p *TSCloseSessionReq) GetSessionId() int64

func (*TSCloseSessionReq) Read

func (p *TSCloseSessionReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCloseSessionReq) ReadField1

func (p *TSCloseSessionReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCloseSessionReq) String

func (p *TSCloseSessionReq) String() string

func (*TSCloseSessionReq) Write

func (p *TSCloseSessionReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSConnectionInfo added in v1.1.5

type TSConnectionInfo struct {
	UserName     string           `thrift:"userName,1,required" db:"userName" json:"userName"`
	LogInTime    int64            `thrift:"logInTime,2,required" db:"logInTime" json:"logInTime"`
	ConnectionId string           `thrift:"connectionId,3,required" db:"connectionId" json:"connectionId"`
	Type         TSConnectionType `thrift:"type,4,required" db:"type" json:"type"`
}

Attributes:

  • UserName
  • LogInTime
  • ConnectionId
  • Type

func NewTSConnectionInfo added in v1.1.5

func NewTSConnectionInfo() *TSConnectionInfo

func (*TSConnectionInfo) Equals added in v1.1.5

func (p *TSConnectionInfo) Equals(other *TSConnectionInfo) bool

func (*TSConnectionInfo) GetConnectionId added in v1.1.5

func (p *TSConnectionInfo) GetConnectionId() string

func (*TSConnectionInfo) GetLogInTime added in v1.1.5

func (p *TSConnectionInfo) GetLogInTime() int64

func (*TSConnectionInfo) GetType added in v1.1.5

func (p *TSConnectionInfo) GetType() TSConnectionType

func (*TSConnectionInfo) GetUserName added in v1.1.5

func (p *TSConnectionInfo) GetUserName() string

func (*TSConnectionInfo) Read added in v1.1.5

func (p *TSConnectionInfo) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSConnectionInfo) ReadField1 added in v1.1.5

func (p *TSConnectionInfo) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSConnectionInfo) ReadField2 added in v1.1.5

func (p *TSConnectionInfo) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSConnectionInfo) ReadField3 added in v1.1.5

func (p *TSConnectionInfo) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSConnectionInfo) ReadField4 added in v1.1.5

func (p *TSConnectionInfo) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSConnectionInfo) String added in v1.1.5

func (p *TSConnectionInfo) String() string

func (*TSConnectionInfo) Write added in v1.1.5

func (p *TSConnectionInfo) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSConnectionInfoResp added in v1.1.5

type TSConnectionInfoResp struct {
	ConnectionInfoList []*TSConnectionInfo `thrift:"connectionInfoList,1,required" db:"connectionInfoList" json:"connectionInfoList"`
}

Attributes:

  • ConnectionInfoList
var IClientRPCServiceFetchAllConnectionsInfoResult_Success_DEFAULT *TSConnectionInfoResp

func NewTSConnectionInfoResp added in v1.1.5

func NewTSConnectionInfoResp() *TSConnectionInfoResp

func (*TSConnectionInfoResp) Equals added in v1.1.5

func (*TSConnectionInfoResp) GetConnectionInfoList added in v1.1.5

func (p *TSConnectionInfoResp) GetConnectionInfoList() []*TSConnectionInfo

func (*TSConnectionInfoResp) Read added in v1.1.5

func (*TSConnectionInfoResp) ReadField1 added in v1.1.5

func (p *TSConnectionInfoResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSConnectionInfoResp) String added in v1.1.5

func (p *TSConnectionInfoResp) String() string

func (*TSConnectionInfoResp) Write added in v1.1.5

type TSConnectionType added in v1.1.5

type TSConnectionType int64
const (
	TSConnectionType_THRIFT_BASED TSConnectionType = 0
	TSConnectionType_MQTT_BASED   TSConnectionType = 1
	TSConnectionType_INTERNAL     TSConnectionType = 2
)

func TSConnectionTypeFromString added in v1.1.5

func TSConnectionTypeFromString(s string) (TSConnectionType, error)

func TSConnectionTypePtr added in v1.1.5

func TSConnectionTypePtr(v TSConnectionType) *TSConnectionType

func (TSConnectionType) MarshalText added in v1.1.5

func (p TSConnectionType) MarshalText() ([]byte, error)

func (*TSConnectionType) Scan added in v1.1.5

func (p *TSConnectionType) Scan(value interface{}) error

func (TSConnectionType) String added in v1.1.5

func (p TSConnectionType) String() string

func (*TSConnectionType) UnmarshalText added in v1.1.5

func (p *TSConnectionType) UnmarshalText(text []byte) error

func (*TSConnectionType) Value added in v1.1.5

func (p *TSConnectionType) Value() (driver.Value, error)

type TSCreateAlignedTimeseriesReq added in v0.13.0

type TSCreateAlignedTimeseriesReq struct {
	SessionId        int64               `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	PrefixPath       string              `thrift:"prefixPath,2,required" db:"prefixPath" json:"prefixPath"`
	Measurements     []string            `thrift:"measurements,3,required" db:"measurements" json:"measurements"`
	DataTypes        []int32             `thrift:"dataTypes,4,required" db:"dataTypes" json:"dataTypes"`
	Encodings        []int32             `thrift:"encodings,5,required" db:"encodings" json:"encodings"`
	Compressors      []int32             `thrift:"compressors,6,required" db:"compressors" json:"compressors"`
	MeasurementAlias []string            `thrift:"measurementAlias,7" db:"measurementAlias" json:"measurementAlias,omitempty"`
	TagsList         []map[string]string `thrift:"tagsList,8" db:"tagsList" json:"tagsList,omitempty"`
	AttributesList   []map[string]string `thrift:"attributesList,9" db:"attributesList" json:"attributesList,omitempty"`
}

Attributes:

  • SessionId
  • PrefixPath
  • Measurements
  • DataTypes
  • Encodings
  • Compressors
  • MeasurementAlias
  • TagsList
  • AttributesList
var IClientRPCServiceCreateAlignedTimeseriesArgs_Req_DEFAULT *TSCreateAlignedTimeseriesReq

func NewTSCreateAlignedTimeseriesReq added in v0.13.0

func NewTSCreateAlignedTimeseriesReq() *TSCreateAlignedTimeseriesReq

func (*TSCreateAlignedTimeseriesReq) Equals added in v0.13.0

func (*TSCreateAlignedTimeseriesReq) GetAttributesList added in v1.1.5

func (p *TSCreateAlignedTimeseriesReq) GetAttributesList() []map[string]string

func (*TSCreateAlignedTimeseriesReq) GetCompressors added in v0.13.0

func (p *TSCreateAlignedTimeseriesReq) GetCompressors() []int32

func (*TSCreateAlignedTimeseriesReq) GetDataTypes added in v0.13.0

func (p *TSCreateAlignedTimeseriesReq) GetDataTypes() []int32

func (*TSCreateAlignedTimeseriesReq) GetEncodings added in v0.13.0

func (p *TSCreateAlignedTimeseriesReq) GetEncodings() []int32

func (*TSCreateAlignedTimeseriesReq) GetMeasurementAlias added in v0.13.0

func (p *TSCreateAlignedTimeseriesReq) GetMeasurementAlias() []string

func (*TSCreateAlignedTimeseriesReq) GetMeasurements added in v0.13.0

func (p *TSCreateAlignedTimeseriesReq) GetMeasurements() []string

func (*TSCreateAlignedTimeseriesReq) GetPrefixPath added in v0.13.0

func (p *TSCreateAlignedTimeseriesReq) GetPrefixPath() string

func (*TSCreateAlignedTimeseriesReq) GetSessionId added in v0.13.0

func (p *TSCreateAlignedTimeseriesReq) GetSessionId() int64

func (*TSCreateAlignedTimeseriesReq) GetTagsList added in v1.1.5

func (p *TSCreateAlignedTimeseriesReq) GetTagsList() []map[string]string

func (*TSCreateAlignedTimeseriesReq) IsSetAttributesList added in v1.1.5

func (p *TSCreateAlignedTimeseriesReq) IsSetAttributesList() bool

func (*TSCreateAlignedTimeseriesReq) IsSetMeasurementAlias added in v0.13.0

func (p *TSCreateAlignedTimeseriesReq) IsSetMeasurementAlias() bool

func (*TSCreateAlignedTimeseriesReq) IsSetTagsList added in v1.1.5

func (p *TSCreateAlignedTimeseriesReq) IsSetTagsList() bool

func (*TSCreateAlignedTimeseriesReq) Read added in v0.13.0

func (*TSCreateAlignedTimeseriesReq) ReadField1 added in v0.13.0

func (*TSCreateAlignedTimeseriesReq) ReadField2 added in v0.13.0

func (*TSCreateAlignedTimeseriesReq) ReadField3 added in v0.13.0

func (*TSCreateAlignedTimeseriesReq) ReadField4 added in v0.13.0

func (*TSCreateAlignedTimeseriesReq) ReadField5 added in v0.13.0

func (*TSCreateAlignedTimeseriesReq) ReadField6 added in v0.13.0

func (*TSCreateAlignedTimeseriesReq) ReadField7 added in v0.13.0

func (*TSCreateAlignedTimeseriesReq) ReadField8 added in v1.1.5

func (*TSCreateAlignedTimeseriesReq) ReadField9 added in v1.1.5

func (*TSCreateAlignedTimeseriesReq) String added in v0.13.0

func (*TSCreateAlignedTimeseriesReq) Write added in v0.13.0

type TSCreateMultiTimeseriesReq

type TSCreateMultiTimeseriesReq struct {
	SessionId            int64               `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	Paths                []string            `thrift:"paths,2,required" db:"paths" json:"paths"`
	DataTypes            []int32             `thrift:"dataTypes,3,required" db:"dataTypes" json:"dataTypes"`
	Encodings            []int32             `thrift:"encodings,4,required" db:"encodings" json:"encodings"`
	Compressors          []int32             `thrift:"compressors,5,required" db:"compressors" json:"compressors"`
	PropsList            []map[string]string `thrift:"propsList,6" db:"propsList" json:"propsList,omitempty"`
	TagsList             []map[string]string `thrift:"tagsList,7" db:"tagsList" json:"tagsList,omitempty"`
	AttributesList       []map[string]string `thrift:"attributesList,8" db:"attributesList" json:"attributesList,omitempty"`
	MeasurementAliasList []string            `thrift:"measurementAliasList,9" db:"measurementAliasList" json:"measurementAliasList,omitempty"`
}

Attributes:

  • SessionId
  • Paths
  • DataTypes
  • Encodings
  • Compressors
  • PropsList
  • TagsList
  • AttributesList
  • MeasurementAliasList
var IClientRPCServiceCreateMultiTimeseriesArgs_Req_DEFAULT *TSCreateMultiTimeseriesReq

func NewTSCreateMultiTimeseriesReq

func NewTSCreateMultiTimeseriesReq() *TSCreateMultiTimeseriesReq

func (*TSCreateMultiTimeseriesReq) Equals added in v0.12.1

func (*TSCreateMultiTimeseriesReq) GetAttributesList

func (p *TSCreateMultiTimeseriesReq) GetAttributesList() []map[string]string

func (*TSCreateMultiTimeseriesReq) GetCompressors

func (p *TSCreateMultiTimeseriesReq) GetCompressors() []int32

func (*TSCreateMultiTimeseriesReq) GetDataTypes

func (p *TSCreateMultiTimeseriesReq) GetDataTypes() []int32

func (*TSCreateMultiTimeseriesReq) GetEncodings

func (p *TSCreateMultiTimeseriesReq) GetEncodings() []int32

func (*TSCreateMultiTimeseriesReq) GetMeasurementAliasList

func (p *TSCreateMultiTimeseriesReq) GetMeasurementAliasList() []string

func (*TSCreateMultiTimeseriesReq) GetPaths

func (p *TSCreateMultiTimeseriesReq) GetPaths() []string

func (*TSCreateMultiTimeseriesReq) GetPropsList

func (p *TSCreateMultiTimeseriesReq) GetPropsList() []map[string]string

func (*TSCreateMultiTimeseriesReq) GetSessionId

func (p *TSCreateMultiTimeseriesReq) GetSessionId() int64

func (*TSCreateMultiTimeseriesReq) GetTagsList

func (p *TSCreateMultiTimeseriesReq) GetTagsList() []map[string]string

func (*TSCreateMultiTimeseriesReq) IsSetAttributesList

func (p *TSCreateMultiTimeseriesReq) IsSetAttributesList() bool

func (*TSCreateMultiTimeseriesReq) IsSetMeasurementAliasList

func (p *TSCreateMultiTimeseriesReq) IsSetMeasurementAliasList() bool

func (*TSCreateMultiTimeseriesReq) IsSetPropsList

func (p *TSCreateMultiTimeseriesReq) IsSetPropsList() bool

func (*TSCreateMultiTimeseriesReq) IsSetTagsList

func (p *TSCreateMultiTimeseriesReq) IsSetTagsList() bool

func (*TSCreateMultiTimeseriesReq) Read

func (*TSCreateMultiTimeseriesReq) ReadField1

func (p *TSCreateMultiTimeseriesReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateMultiTimeseriesReq) ReadField2

func (p *TSCreateMultiTimeseriesReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateMultiTimeseriesReq) ReadField3

func (p *TSCreateMultiTimeseriesReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateMultiTimeseriesReq) ReadField4

func (p *TSCreateMultiTimeseriesReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateMultiTimeseriesReq) ReadField5

func (p *TSCreateMultiTimeseriesReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateMultiTimeseriesReq) ReadField6

func (p *TSCreateMultiTimeseriesReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateMultiTimeseriesReq) ReadField7

func (p *TSCreateMultiTimeseriesReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateMultiTimeseriesReq) ReadField8

func (p *TSCreateMultiTimeseriesReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateMultiTimeseriesReq) ReadField9

func (p *TSCreateMultiTimeseriesReq) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateMultiTimeseriesReq) String

func (p *TSCreateMultiTimeseriesReq) String() string

func (*TSCreateMultiTimeseriesReq) Write

type TSCreateSchemaTemplateReq added in v0.13.0

type TSCreateSchemaTemplateReq struct {
	SessionId          int64  `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	Name               string `thrift:"name,2,required" db:"name" json:"name"`
	SerializedTemplate []byte `thrift:"serializedTemplate,3,required" db:"serializedTemplate" json:"serializedTemplate"`
}

Attributes:

  • SessionId
  • Name
  • SerializedTemplate
var IClientRPCServiceCreateSchemaTemplateArgs_Req_DEFAULT *TSCreateSchemaTemplateReq

func NewTSCreateSchemaTemplateReq added in v0.13.0

func NewTSCreateSchemaTemplateReq() *TSCreateSchemaTemplateReq

func (*TSCreateSchemaTemplateReq) Equals added in v0.13.0

func (*TSCreateSchemaTemplateReq) GetName added in v0.13.0

func (p *TSCreateSchemaTemplateReq) GetName() string

func (*TSCreateSchemaTemplateReq) GetSerializedTemplate added in v0.13.0

func (p *TSCreateSchemaTemplateReq) GetSerializedTemplate() []byte

func (*TSCreateSchemaTemplateReq) GetSessionId added in v0.13.0

func (p *TSCreateSchemaTemplateReq) GetSessionId() int64

func (*TSCreateSchemaTemplateReq) Read added in v0.13.0

func (*TSCreateSchemaTemplateReq) ReadField1 added in v0.13.0

func (p *TSCreateSchemaTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateSchemaTemplateReq) ReadField2 added in v0.13.0

func (p *TSCreateSchemaTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateSchemaTemplateReq) ReadField3 added in v0.13.0

func (p *TSCreateSchemaTemplateReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateSchemaTemplateReq) String added in v0.13.0

func (p *TSCreateSchemaTemplateReq) String() string

func (*TSCreateSchemaTemplateReq) Write added in v0.13.0

type TSCreateTimeseriesReq

type TSCreateTimeseriesReq struct {
	SessionId        int64             `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	Path             string            `thrift:"path,2,required" db:"path" json:"path"`
	DataType         int32             `thrift:"dataType,3,required" db:"dataType" json:"dataType"`
	Encoding         int32             `thrift:"encoding,4,required" db:"encoding" json:"encoding"`
	Compressor       int32             `thrift:"compressor,5,required" db:"compressor" json:"compressor"`
	Props            map[string]string `thrift:"props,6" db:"props" json:"props,omitempty"`
	Tags             map[string]string `thrift:"tags,7" db:"tags" json:"tags,omitempty"`
	Attributes       map[string]string `thrift:"attributes,8" db:"attributes" json:"attributes,omitempty"`
	MeasurementAlias *string           `thrift:"measurementAlias,9" db:"measurementAlias" json:"measurementAlias,omitempty"`
}

Attributes:

  • SessionId
  • Path
  • DataType
  • Encoding
  • Compressor
  • Props
  • Tags
  • Attributes
  • MeasurementAlias
var IClientRPCServiceCreateTimeseriesArgs_Req_DEFAULT *TSCreateTimeseriesReq

func NewTSCreateTimeseriesReq

func NewTSCreateTimeseriesReq() *TSCreateTimeseriesReq

func (*TSCreateTimeseriesReq) Equals added in v0.12.1

func (*TSCreateTimeseriesReq) GetAttributes

func (p *TSCreateTimeseriesReq) GetAttributes() map[string]string

func (*TSCreateTimeseriesReq) GetCompressor

func (p *TSCreateTimeseriesReq) GetCompressor() int32

func (*TSCreateTimeseriesReq) GetDataType

func (p *TSCreateTimeseriesReq) GetDataType() int32

func (*TSCreateTimeseriesReq) GetEncoding

func (p *TSCreateTimeseriesReq) GetEncoding() int32

func (*TSCreateTimeseriesReq) GetMeasurementAlias

func (p *TSCreateTimeseriesReq) GetMeasurementAlias() string

func (*TSCreateTimeseriesReq) GetPath

func (p *TSCreateTimeseriesReq) GetPath() string

func (*TSCreateTimeseriesReq) GetProps

func (p *TSCreateTimeseriesReq) GetProps() map[string]string

func (*TSCreateTimeseriesReq) GetSessionId

func (p *TSCreateTimeseriesReq) GetSessionId() int64

func (*TSCreateTimeseriesReq) GetTags

func (p *TSCreateTimeseriesReq) GetTags() map[string]string

func (*TSCreateTimeseriesReq) IsSetAttributes

func (p *TSCreateTimeseriesReq) IsSetAttributes() bool

func (*TSCreateTimeseriesReq) IsSetMeasurementAlias

func (p *TSCreateTimeseriesReq) IsSetMeasurementAlias() bool

func (*TSCreateTimeseriesReq) IsSetProps

func (p *TSCreateTimeseriesReq) IsSetProps() bool

func (*TSCreateTimeseriesReq) IsSetTags

func (p *TSCreateTimeseriesReq) IsSetTags() bool

func (*TSCreateTimeseriesReq) Read

func (*TSCreateTimeseriesReq) ReadField1

func (p *TSCreateTimeseriesReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateTimeseriesReq) ReadField2

func (p *TSCreateTimeseriesReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateTimeseriesReq) ReadField3

func (p *TSCreateTimeseriesReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateTimeseriesReq) ReadField4

func (p *TSCreateTimeseriesReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateTimeseriesReq) ReadField5

func (p *TSCreateTimeseriesReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateTimeseriesReq) ReadField6

func (p *TSCreateTimeseriesReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateTimeseriesReq) ReadField7

func (p *TSCreateTimeseriesReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateTimeseriesReq) ReadField8

func (p *TSCreateTimeseriesReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateTimeseriesReq) ReadField9

func (p *TSCreateTimeseriesReq) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*TSCreateTimeseriesReq) String

func (p *TSCreateTimeseriesReq) String() string

func (*TSCreateTimeseriesReq) Write

type TSDeleteDataReq

type TSDeleteDataReq struct {
	SessionId int64    `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	Paths     []string `thrift:"paths,2,required" db:"paths" json:"paths"`
	StartTime int64    `thrift:"startTime,3,required" db:"startTime" json:"startTime"`
	EndTime   int64    `thrift:"endTime,4,required" db:"endTime" json:"endTime"`
}

Attributes:

  • SessionId
  • Paths
  • StartTime
  • EndTime
var IClientRPCServiceDeleteDataArgs_Req_DEFAULT *TSDeleteDataReq

func NewTSDeleteDataReq

func NewTSDeleteDataReq() *TSDeleteDataReq

func (*TSDeleteDataReq) Equals added in v0.12.1

func (p *TSDeleteDataReq) Equals(other *TSDeleteDataReq) bool

func (*TSDeleteDataReq) GetEndTime

func (p *TSDeleteDataReq) GetEndTime() int64

func (*TSDeleteDataReq) GetPaths

func (p *TSDeleteDataReq) GetPaths() []string

func (*TSDeleteDataReq) GetSessionId

func (p *TSDeleteDataReq) GetSessionId() int64

func (*TSDeleteDataReq) GetStartTime

func (p *TSDeleteDataReq) GetStartTime() int64

func (*TSDeleteDataReq) Read

func (p *TSDeleteDataReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSDeleteDataReq) ReadField1

func (p *TSDeleteDataReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSDeleteDataReq) ReadField2

func (p *TSDeleteDataReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSDeleteDataReq) ReadField3

func (p *TSDeleteDataReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSDeleteDataReq) ReadField4

func (p *TSDeleteDataReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSDeleteDataReq) String

func (p *TSDeleteDataReq) String() string

func (*TSDeleteDataReq) Write

func (p *TSDeleteDataReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSDropSchemaTemplateReq added in v0.13.0

type TSDropSchemaTemplateReq struct {
	SessionId    int64  `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	TemplateName string `thrift:"templateName,2,required" db:"templateName" json:"templateName"`
}

Attributes:

  • SessionId
  • TemplateName
var IClientRPCServiceDropSchemaTemplateArgs_Req_DEFAULT *TSDropSchemaTemplateReq

func NewTSDropSchemaTemplateReq added in v0.13.0

func NewTSDropSchemaTemplateReq() *TSDropSchemaTemplateReq

func (*TSDropSchemaTemplateReq) Equals added in v0.13.0

func (*TSDropSchemaTemplateReq) GetSessionId added in v0.13.0

func (p *TSDropSchemaTemplateReq) GetSessionId() int64

func (*TSDropSchemaTemplateReq) GetTemplateName added in v0.13.0

func (p *TSDropSchemaTemplateReq) GetTemplateName() string

func (*TSDropSchemaTemplateReq) Read added in v0.13.0

func (*TSDropSchemaTemplateReq) ReadField1 added in v0.13.0

func (p *TSDropSchemaTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSDropSchemaTemplateReq) ReadField2 added in v0.13.0

func (p *TSDropSchemaTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSDropSchemaTemplateReq) String added in v0.13.0

func (p *TSDropSchemaTemplateReq) String() string

func (*TSDropSchemaTemplateReq) Write added in v0.13.0

type TSExecuteBatchStatementReq

type TSExecuteBatchStatementReq struct {
	SessionId  int64    `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	Statements []string `thrift:"statements,2,required" db:"statements" json:"statements"`
}

Attributes:

  • SessionId
  • Statements
var IClientRPCServiceExecuteBatchStatementArgs_Req_DEFAULT *TSExecuteBatchStatementReq

func NewTSExecuteBatchStatementReq

func NewTSExecuteBatchStatementReq() *TSExecuteBatchStatementReq

func (*TSExecuteBatchStatementReq) Equals added in v0.12.1

func (*TSExecuteBatchStatementReq) GetSessionId

func (p *TSExecuteBatchStatementReq) GetSessionId() int64

func (*TSExecuteBatchStatementReq) GetStatements

func (p *TSExecuteBatchStatementReq) GetStatements() []string

func (*TSExecuteBatchStatementReq) Read

func (*TSExecuteBatchStatementReq) ReadField1

func (p *TSExecuteBatchStatementReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteBatchStatementReq) ReadField2

func (p *TSExecuteBatchStatementReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteBatchStatementReq) String

func (p *TSExecuteBatchStatementReq) String() string

func (*TSExecuteBatchStatementReq) Write

type TSExecuteStatementReq

type TSExecuteStatementReq struct {
	SessionId           int64  `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	Statement           string `thrift:"statement,2,required" db:"statement" json:"statement"`
	StatementId         int64  `thrift:"statementId,3,required" db:"statementId" json:"statementId"`
	FetchSize           *int32 `thrift:"fetchSize,4" db:"fetchSize" json:"fetchSize,omitempty"`
	Timeout             *int64 `thrift:"timeout,5" db:"timeout" json:"timeout,omitempty"`
	EnableRedirectQuery *bool  `thrift:"enableRedirectQuery,6" db:"enableRedirectQuery" json:"enableRedirectQuery,omitempty"`
	JdbcQuery           *bool  `thrift:"jdbcQuery,7" db:"jdbcQuery" json:"jdbcQuery,omitempty"`
}

Attributes:

  • SessionId
  • Statement
  • StatementId
  • FetchSize
  • Timeout
  • EnableRedirectQuery
  • JdbcQuery
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

func NewTSExecuteStatementReq() *TSExecuteStatementReq

func (*TSExecuteStatementReq) Equals added in v0.12.1

func (*TSExecuteStatementReq) GetEnableRedirectQuery added in v0.12.1

func (p *TSExecuteStatementReq) GetEnableRedirectQuery() bool

func (*TSExecuteStatementReq) GetFetchSize

func (p *TSExecuteStatementReq) GetFetchSize() int32

func (*TSExecuteStatementReq) GetJdbcQuery added in v0.13.0

func (p *TSExecuteStatementReq) GetJdbcQuery() bool

func (*TSExecuteStatementReq) GetSessionId

func (p *TSExecuteStatementReq) GetSessionId() int64

func (*TSExecuteStatementReq) GetStatement

func (p *TSExecuteStatementReq) GetStatement() string

func (*TSExecuteStatementReq) GetStatementId

func (p *TSExecuteStatementReq) GetStatementId() int64

func (*TSExecuteStatementReq) GetTimeout

func (p *TSExecuteStatementReq) GetTimeout() int64

func (*TSExecuteStatementReq) IsSetEnableRedirectQuery added in v0.12.1

func (p *TSExecuteStatementReq) IsSetEnableRedirectQuery() bool

func (*TSExecuteStatementReq) IsSetFetchSize

func (p *TSExecuteStatementReq) IsSetFetchSize() bool

func (*TSExecuteStatementReq) IsSetJdbcQuery added in v0.13.0

func (p *TSExecuteStatementReq) IsSetJdbcQuery() bool

func (*TSExecuteStatementReq) IsSetTimeout

func (p *TSExecuteStatementReq) IsSetTimeout() bool

func (*TSExecuteStatementReq) Read

func (*TSExecuteStatementReq) ReadField1

func (p *TSExecuteStatementReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementReq) ReadField2

func (p *TSExecuteStatementReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementReq) ReadField3

func (p *TSExecuteStatementReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementReq) ReadField4

func (p *TSExecuteStatementReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementReq) ReadField5

func (p *TSExecuteStatementReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementReq) ReadField6 added in v0.12.1

func (p *TSExecuteStatementReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementReq) ReadField7 added in v0.13.0

func (p *TSExecuteStatementReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementReq) String

func (p *TSExecuteStatementReq) String() string

func (*TSExecuteStatementReq) Write

type TSExecuteStatementResp

type TSExecuteStatementResp struct {
	Status               *common.TSStatus        `thrift:"status,1,required" db:"status" json:"status"`
	QueryId              *int64                  `thrift:"queryId,2" db:"queryId" json:"queryId,omitempty"`
	Columns              []string                `thrift:"columns,3" db:"columns" json:"columns,omitempty"`
	OperationType        *string                 `thrift:"operationType,4" db:"operationType" json:"operationType,omitempty"`
	IgnoreTimeStamp      *bool                   `thrift:"ignoreTimeStamp,5" db:"ignoreTimeStamp" json:"ignoreTimeStamp,omitempty"`
	DataTypeList         []string                `thrift:"dataTypeList,6" db:"dataTypeList" json:"dataTypeList,omitempty"`
	QueryDataSet         *TSQueryDataSet         `thrift:"queryDataSet,7" db:"queryDataSet" json:"queryDataSet,omitempty"`
	NonAlignQueryDataSet *TSQueryNonAlignDataSet `thrift:"nonAlignQueryDataSet,8" db:"nonAlignQueryDataSet" json:"nonAlignQueryDataSet,omitempty"`
	ColumnNameIndexMap   map[string]int32        `thrift:"columnNameIndexMap,9" db:"columnNameIndexMap" json:"columnNameIndexMap,omitempty"`
	SgColumns            []string                `thrift:"sgColumns,10" db:"sgColumns" json:"sgColumns,omitempty"`
	AliasColumns         []int8                  `thrift:"aliasColumns,11" db:"aliasColumns" json:"aliasColumns,omitempty"`
	TracingInfo          *TSTracingInfo          `thrift:"tracingInfo,12" db:"tracingInfo" json:"tracingInfo,omitempty"`
	QueryResult_         [][]byte                `thrift:"queryResult,13" db:"queryResult" json:"queryResult,omitempty"`
	MoreData             *bool                   `thrift:"moreData,14" db:"moreData" json:"moreData,omitempty"`
}

Attributes:

  • Status
  • QueryId
  • Columns
  • OperationType
  • IgnoreTimeStamp
  • DataTypeList
  • QueryDataSet
  • NonAlignQueryDataSet
  • ColumnNameIndexMap
  • SgColumns
  • AliasColumns
  • TracingInfo
  • QueryResult_
  • MoreData
var IClientRPCServiceExecuteAggregationQueryResult_Success_DEFAULT *TSExecuteStatementResp
var IClientRPCServiceExecuteAggregationQueryV2Result_Success_DEFAULT *TSExecuteStatementResp
var IClientRPCServiceExecuteLastDataQueryResult_Success_DEFAULT *TSExecuteStatementResp
var IClientRPCServiceExecuteLastDataQueryV2Result_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

func NewTSExecuteStatementResp() *TSExecuteStatementResp

func (*TSExecuteStatementResp) Equals added in v0.12.1

func (*TSExecuteStatementResp) GetAliasColumns added in v0.13.0

func (p *TSExecuteStatementResp) GetAliasColumns() []int8

func (*TSExecuteStatementResp) GetColumnNameIndexMap

func (p *TSExecuteStatementResp) GetColumnNameIndexMap() map[string]int32

func (*TSExecuteStatementResp) GetColumns

func (p *TSExecuteStatementResp) GetColumns() []string

func (*TSExecuteStatementResp) GetDataTypeList

func (p *TSExecuteStatementResp) GetDataTypeList() []string

func (*TSExecuteStatementResp) GetIgnoreTimeStamp

func (p *TSExecuteStatementResp) GetIgnoreTimeStamp() bool

func (*TSExecuteStatementResp) GetMoreData added in v1.1.5

func (p *TSExecuteStatementResp) GetMoreData() bool

func (*TSExecuteStatementResp) GetNonAlignQueryDataSet

func (p *TSExecuteStatementResp) GetNonAlignQueryDataSet() *TSQueryNonAlignDataSet

func (*TSExecuteStatementResp) GetOperationType

func (p *TSExecuteStatementResp) GetOperationType() string

func (*TSExecuteStatementResp) GetQueryDataSet

func (p *TSExecuteStatementResp) GetQueryDataSet() *TSQueryDataSet

func (*TSExecuteStatementResp) GetQueryId

func (p *TSExecuteStatementResp) GetQueryId() int64

func (*TSExecuteStatementResp) GetQueryResult_ added in v1.1.5

func (p *TSExecuteStatementResp) GetQueryResult_() [][]byte

func (*TSExecuteStatementResp) GetSgColumns added in v0.13.0

func (p *TSExecuteStatementResp) GetSgColumns() []string

func (*TSExecuteStatementResp) GetStatus

func (p *TSExecuteStatementResp) GetStatus() *common.TSStatus

func (*TSExecuteStatementResp) GetTracingInfo added in v0.13.0

func (p *TSExecuteStatementResp) GetTracingInfo() *TSTracingInfo

func (*TSExecuteStatementResp) IsSetAliasColumns added in v0.13.0

func (p *TSExecuteStatementResp) IsSetAliasColumns() bool

func (*TSExecuteStatementResp) IsSetColumnNameIndexMap

func (p *TSExecuteStatementResp) IsSetColumnNameIndexMap() bool

func (*TSExecuteStatementResp) IsSetColumns

func (p *TSExecuteStatementResp) IsSetColumns() bool

func (*TSExecuteStatementResp) IsSetDataTypeList

func (p *TSExecuteStatementResp) IsSetDataTypeList() bool

func (*TSExecuteStatementResp) IsSetIgnoreTimeStamp

func (p *TSExecuteStatementResp) IsSetIgnoreTimeStamp() bool

func (*TSExecuteStatementResp) IsSetMoreData added in v1.1.5

func (p *TSExecuteStatementResp) IsSetMoreData() bool

func (*TSExecuteStatementResp) IsSetNonAlignQueryDataSet

func (p *TSExecuteStatementResp) IsSetNonAlignQueryDataSet() bool

func (*TSExecuteStatementResp) IsSetOperationType

func (p *TSExecuteStatementResp) IsSetOperationType() bool

func (*TSExecuteStatementResp) IsSetQueryDataSet

func (p *TSExecuteStatementResp) IsSetQueryDataSet() bool

func (*TSExecuteStatementResp) IsSetQueryId

func (p *TSExecuteStatementResp) IsSetQueryId() bool

func (*TSExecuteStatementResp) IsSetQueryResult_ added in v1.1.5

func (p *TSExecuteStatementResp) IsSetQueryResult_() bool

func (*TSExecuteStatementResp) IsSetSgColumns added in v0.13.0

func (p *TSExecuteStatementResp) IsSetSgColumns() bool

func (*TSExecuteStatementResp) IsSetStatus

func (p *TSExecuteStatementResp) IsSetStatus() bool

func (*TSExecuteStatementResp) IsSetTracingInfo added in v0.13.0

func (p *TSExecuteStatementResp) IsSetTracingInfo() bool

func (*TSExecuteStatementResp) Read

func (*TSExecuteStatementResp) ReadField1

func (p *TSExecuteStatementResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementResp) ReadField10 added in v0.13.0

func (p *TSExecuteStatementResp) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementResp) ReadField11 added in v0.13.0

func (p *TSExecuteStatementResp) ReadField11(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementResp) ReadField12 added in v0.13.0

func (p *TSExecuteStatementResp) ReadField12(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementResp) ReadField13 added in v1.1.5

func (p *TSExecuteStatementResp) ReadField13(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementResp) ReadField14 added in v1.1.5

func (p *TSExecuteStatementResp) ReadField14(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementResp) ReadField2

func (p *TSExecuteStatementResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementResp) ReadField3

func (p *TSExecuteStatementResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementResp) ReadField4

func (p *TSExecuteStatementResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementResp) ReadField5

func (p *TSExecuteStatementResp) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementResp) ReadField6

func (p *TSExecuteStatementResp) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementResp) ReadField7

func (p *TSExecuteStatementResp) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementResp) ReadField8

func (p *TSExecuteStatementResp) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementResp) ReadField9

func (p *TSExecuteStatementResp) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*TSExecuteStatementResp) String

func (p *TSExecuteStatementResp) String() string

func (*TSExecuteStatementResp) Write

type TSFastInsertRecordsReq added in v1.1.6

type TSFastInsertRecordsReq struct {
	SessionId   int64    `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	PrefixPaths []string `thrift:"prefixPaths,2,required" db:"prefixPaths" json:"prefixPaths"`
	// unused field # 3
	ValuesList [][]byte `thrift:"valuesList,4,required" db:"valuesList" json:"valuesList"`
	Timestamps []int64  `thrift:"timestamps,5,required" db:"timestamps" json:"timestamps"`
}

Attributes:

  • SessionId
  • PrefixPaths
  • Timestamps
  • ValuesList
var IClientRPCServiceFastInsertRecordsArgs_Req_DEFAULT *TSFastInsertRecordsReq

func NewTSFastInsertRecordsReq added in v1.1.6

func NewTSFastInsertRecordsReq() *TSFastInsertRecordsReq

func (*TSFastInsertRecordsReq) Equals added in v1.1.6

func (*TSFastInsertRecordsReq) GetPrefixPaths added in v1.1.6

func (p *TSFastInsertRecordsReq) GetPrefixPaths() []string

func (*TSFastInsertRecordsReq) GetSessionId added in v1.1.6

func (p *TSFastInsertRecordsReq) GetSessionId() int64

func (*TSFastInsertRecordsReq) GetTimestamps added in v1.1.6

func (p *TSFastInsertRecordsReq) GetTimestamps() []int64

func (*TSFastInsertRecordsReq) GetValuesList added in v1.1.6

func (p *TSFastInsertRecordsReq) GetValuesList() [][]byte

func (*TSFastInsertRecordsReq) Read added in v1.1.6

func (*TSFastInsertRecordsReq) ReadField1 added in v1.1.6

func (p *TSFastInsertRecordsReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFastInsertRecordsReq) ReadField2 added in v1.1.6

func (p *TSFastInsertRecordsReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFastInsertRecordsReq) ReadField4 added in v1.1.6

func (p *TSFastInsertRecordsReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFastInsertRecordsReq) ReadField5 added in v1.1.6

func (p *TSFastInsertRecordsReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFastInsertRecordsReq) String added in v1.1.6

func (p *TSFastInsertRecordsReq) String() string

func (*TSFastInsertRecordsReq) Write added in v1.1.6

type TSFetchMetadataReq

type TSFetchMetadataReq struct {
	SessionId  int64   `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	Type       string  `thrift:"type,2,required" db:"type" json:"type"`
	ColumnPath *string `thrift:"columnPath,3" db:"columnPath" json:"columnPath,omitempty"`
}

Attributes:

  • SessionId
  • Type
  • ColumnPath
var IClientRPCServiceFetchMetadataArgs_Req_DEFAULT *TSFetchMetadataReq

func NewTSFetchMetadataReq

func NewTSFetchMetadataReq() *TSFetchMetadataReq

func (*TSFetchMetadataReq) Equals added in v0.12.1

func (p *TSFetchMetadataReq) Equals(other *TSFetchMetadataReq) bool

func (*TSFetchMetadataReq) GetColumnPath

func (p *TSFetchMetadataReq) GetColumnPath() string

func (*TSFetchMetadataReq) GetSessionId

func (p *TSFetchMetadataReq) GetSessionId() int64

func (*TSFetchMetadataReq) GetType

func (p *TSFetchMetadataReq) GetType() string

func (*TSFetchMetadataReq) IsSetColumnPath

func (p *TSFetchMetadataReq) IsSetColumnPath() bool

func (*TSFetchMetadataReq) Read

func (*TSFetchMetadataReq) ReadField1

func (p *TSFetchMetadataReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchMetadataReq) ReadField2

func (p *TSFetchMetadataReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchMetadataReq) ReadField3

func (p *TSFetchMetadataReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchMetadataReq) String

func (p *TSFetchMetadataReq) String() string

func (*TSFetchMetadataReq) Write

func (p *TSFetchMetadataReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSFetchMetadataResp

type TSFetchMetadataResp struct {
	Status         *common.TSStatus `thrift:"status,1,required" db:"status" json:"status"`
	MetadataInJson *string          `thrift:"metadataInJson,2" db:"metadataInJson" json:"metadataInJson,omitempty"`
	ColumnsList    []string         `thrift:"columnsList,3" db:"columnsList" json:"columnsList,omitempty"`
	DataType       *string          `thrift:"dataType,4" db:"dataType" json:"dataType,omitempty"`
}

Attributes:

  • Status
  • MetadataInJson
  • ColumnsList
  • DataType
var IClientRPCServiceFetchMetadataResult_Success_DEFAULT *TSFetchMetadataResp

func NewTSFetchMetadataResp

func NewTSFetchMetadataResp() *TSFetchMetadataResp

func (*TSFetchMetadataResp) Equals added in v0.12.1

func (p *TSFetchMetadataResp) Equals(other *TSFetchMetadataResp) bool

func (*TSFetchMetadataResp) GetColumnsList

func (p *TSFetchMetadataResp) GetColumnsList() []string

func (*TSFetchMetadataResp) GetDataType

func (p *TSFetchMetadataResp) GetDataType() string

func (*TSFetchMetadataResp) GetMetadataInJson

func (p *TSFetchMetadataResp) GetMetadataInJson() string

func (*TSFetchMetadataResp) GetStatus

func (p *TSFetchMetadataResp) GetStatus() *common.TSStatus

func (*TSFetchMetadataResp) IsSetColumnsList

func (p *TSFetchMetadataResp) IsSetColumnsList() bool

func (*TSFetchMetadataResp) IsSetDataType

func (p *TSFetchMetadataResp) IsSetDataType() bool

func (*TSFetchMetadataResp) IsSetMetadataInJson

func (p *TSFetchMetadataResp) IsSetMetadataInJson() bool

func (*TSFetchMetadataResp) IsSetStatus

func (p *TSFetchMetadataResp) IsSetStatus() bool

func (*TSFetchMetadataResp) Read

func (*TSFetchMetadataResp) ReadField1

func (p *TSFetchMetadataResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchMetadataResp) ReadField2

func (p *TSFetchMetadataResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchMetadataResp) ReadField3

func (p *TSFetchMetadataResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchMetadataResp) ReadField4

func (p *TSFetchMetadataResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchMetadataResp) String

func (p *TSFetchMetadataResp) String() string

func (*TSFetchMetadataResp) Write

type TSFetchResultsReq

type TSFetchResultsReq struct {
	SessionId int64  `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	Statement string `thrift:"statement,2,required" db:"statement" json:"statement"`
	FetchSize int32  `thrift:"fetchSize,3,required" db:"fetchSize" json:"fetchSize"`
	QueryId   int64  `thrift:"queryId,4,required" db:"queryId" json:"queryId"`
	IsAlign   bool   `thrift:"isAlign,5,required" db:"isAlign" json:"isAlign"`
	Timeout   *int64 `thrift:"timeout,6" db:"timeout" json:"timeout,omitempty"`
}

Attributes:

  • SessionId
  • Statement
  • FetchSize
  • QueryId
  • IsAlign
  • Timeout
var IClientRPCServiceFetchResultsArgs_Req_DEFAULT *TSFetchResultsReq
var IClientRPCServiceFetchResultsV2Args_Req_DEFAULT *TSFetchResultsReq

func NewTSFetchResultsReq

func NewTSFetchResultsReq() *TSFetchResultsReq

func (*TSFetchResultsReq) Equals added in v0.12.1

func (p *TSFetchResultsReq) Equals(other *TSFetchResultsReq) bool

func (*TSFetchResultsReq) GetFetchSize

func (p *TSFetchResultsReq) GetFetchSize() int32

func (*TSFetchResultsReq) GetIsAlign

func (p *TSFetchResultsReq) GetIsAlign() bool

func (*TSFetchResultsReq) GetQueryId

func (p *TSFetchResultsReq) GetQueryId() int64

func (*TSFetchResultsReq) GetSessionId

func (p *TSFetchResultsReq) GetSessionId() int64

func (*TSFetchResultsReq) GetStatement

func (p *TSFetchResultsReq) GetStatement() string

func (*TSFetchResultsReq) GetTimeout

func (p *TSFetchResultsReq) GetTimeout() int64

func (*TSFetchResultsReq) IsSetTimeout added in v0.12.1

func (p *TSFetchResultsReq) IsSetTimeout() bool

func (*TSFetchResultsReq) Read

func (p *TSFetchResultsReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchResultsReq) ReadField1

func (p *TSFetchResultsReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchResultsReq) ReadField2

func (p *TSFetchResultsReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchResultsReq) ReadField3

func (p *TSFetchResultsReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchResultsReq) ReadField4

func (p *TSFetchResultsReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchResultsReq) ReadField5

func (p *TSFetchResultsReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchResultsReq) ReadField6

func (p *TSFetchResultsReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchResultsReq) String

func (p *TSFetchResultsReq) String() string

func (*TSFetchResultsReq) Write

func (p *TSFetchResultsReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSFetchResultsResp

type TSFetchResultsResp struct {
	Status               *common.TSStatus        `thrift:"status,1,required" db:"status" json:"status"`
	HasResultSet         bool                    `thrift:"hasResultSet,2,required" db:"hasResultSet" json:"hasResultSet"`
	IsAlign              bool                    `thrift:"isAlign,3,required" db:"isAlign" json:"isAlign"`
	QueryDataSet         *TSQueryDataSet         `thrift:"queryDataSet,4" db:"queryDataSet" json:"queryDataSet,omitempty"`
	NonAlignQueryDataSet *TSQueryNonAlignDataSet `thrift:"nonAlignQueryDataSet,5" db:"nonAlignQueryDataSet" json:"nonAlignQueryDataSet,omitempty"`
	QueryResult_         [][]byte                `thrift:"queryResult,6" db:"queryResult" json:"queryResult,omitempty"`
	MoreData             *bool                   `thrift:"moreData,7" db:"moreData" json:"moreData,omitempty"`
}

Attributes:

  • Status
  • HasResultSet
  • IsAlign
  • QueryDataSet
  • NonAlignQueryDataSet
  • QueryResult_
  • MoreData
var IClientRPCServiceFetchResultsResult_Success_DEFAULT *TSFetchResultsResp
var IClientRPCServiceFetchResultsV2Result_Success_DEFAULT *TSFetchResultsResp

func NewTSFetchResultsResp

func NewTSFetchResultsResp() *TSFetchResultsResp

func (*TSFetchResultsResp) Equals added in v0.12.1

func (p *TSFetchResultsResp) Equals(other *TSFetchResultsResp) bool

func (*TSFetchResultsResp) GetHasResultSet

func (p *TSFetchResultsResp) GetHasResultSet() bool

func (*TSFetchResultsResp) GetIsAlign

func (p *TSFetchResultsResp) GetIsAlign() bool

func (*TSFetchResultsResp) GetMoreData added in v1.1.5

func (p *TSFetchResultsResp) GetMoreData() bool

func (*TSFetchResultsResp) GetNonAlignQueryDataSet

func (p *TSFetchResultsResp) GetNonAlignQueryDataSet() *TSQueryNonAlignDataSet

func (*TSFetchResultsResp) GetQueryDataSet

func (p *TSFetchResultsResp) GetQueryDataSet() *TSQueryDataSet

func (*TSFetchResultsResp) GetQueryResult_ added in v1.1.5

func (p *TSFetchResultsResp) GetQueryResult_() [][]byte

func (*TSFetchResultsResp) GetStatus

func (p *TSFetchResultsResp) GetStatus() *common.TSStatus

func (*TSFetchResultsResp) IsSetMoreData added in v1.1.5

func (p *TSFetchResultsResp) IsSetMoreData() bool

func (*TSFetchResultsResp) IsSetNonAlignQueryDataSet

func (p *TSFetchResultsResp) IsSetNonAlignQueryDataSet() bool

func (*TSFetchResultsResp) IsSetQueryDataSet

func (p *TSFetchResultsResp) IsSetQueryDataSet() bool

func (*TSFetchResultsResp) IsSetQueryResult_ added in v1.1.5

func (p *TSFetchResultsResp) IsSetQueryResult_() bool

func (*TSFetchResultsResp) IsSetStatus

func (p *TSFetchResultsResp) IsSetStatus() bool

func (*TSFetchResultsResp) Read

func (*TSFetchResultsResp) ReadField1

func (p *TSFetchResultsResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchResultsResp) ReadField2

func (p *TSFetchResultsResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchResultsResp) ReadField3

func (p *TSFetchResultsResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchResultsResp) ReadField4

func (p *TSFetchResultsResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchResultsResp) ReadField5

func (p *TSFetchResultsResp) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchResultsResp) ReadField6 added in v1.1.5

func (p *TSFetchResultsResp) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchResultsResp) ReadField7 added in v1.1.5

func (p *TSFetchResultsResp) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TSFetchResultsResp) String

func (p *TSFetchResultsResp) String() string

func (*TSFetchResultsResp) Write

func (p *TSFetchResultsResp) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSGetOperationStatusReq

type TSGetOperationStatusReq struct {
	SessionId int64 `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	QueryId   int64 `thrift:"queryId,2,required" db:"queryId" json:"queryId"`
}

Attributes:

  • SessionId
  • QueryId

func NewTSGetOperationStatusReq

func NewTSGetOperationStatusReq() *TSGetOperationStatusReq

func (*TSGetOperationStatusReq) Equals added in v0.12.1

func (*TSGetOperationStatusReq) GetQueryId

func (p *TSGetOperationStatusReq) GetQueryId() int64

func (*TSGetOperationStatusReq) GetSessionId

func (p *TSGetOperationStatusReq) GetSessionId() int64

func (*TSGetOperationStatusReq) Read

func (*TSGetOperationStatusReq) ReadField1

func (p *TSGetOperationStatusReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSGetOperationStatusReq) ReadField2

func (p *TSGetOperationStatusReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSGetOperationStatusReq) String

func (p *TSGetOperationStatusReq) String() string

func (*TSGetOperationStatusReq) Write

type TSGetTimeZoneResp

type TSGetTimeZoneResp struct {
	Status   *common.TSStatus `thrift:"status,1,required" db:"status" json:"status"`
	TimeZone string           `thrift:"timeZone,2,required" db:"timeZone" json:"timeZone"`
}

Attributes:

  • Status
  • TimeZone
var IClientRPCServiceGetTimeZoneResult_Success_DEFAULT *TSGetTimeZoneResp

func NewTSGetTimeZoneResp

func NewTSGetTimeZoneResp() *TSGetTimeZoneResp

func (*TSGetTimeZoneResp) Equals added in v0.12.1

func (p *TSGetTimeZoneResp) Equals(other *TSGetTimeZoneResp) bool

func (*TSGetTimeZoneResp) GetStatus

func (p *TSGetTimeZoneResp) GetStatus() *common.TSStatus

func (*TSGetTimeZoneResp) GetTimeZone

func (p *TSGetTimeZoneResp) GetTimeZone() string

func (*TSGetTimeZoneResp) IsSetStatus

func (p *TSGetTimeZoneResp) IsSetStatus() bool

func (*TSGetTimeZoneResp) Read

func (p *TSGetTimeZoneResp) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSGetTimeZoneResp) ReadField1

func (p *TSGetTimeZoneResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSGetTimeZoneResp) ReadField2

func (p *TSGetTimeZoneResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSGetTimeZoneResp) String

func (p *TSGetTimeZoneResp) String() string

func (*TSGetTimeZoneResp) Write

func (p *TSGetTimeZoneResp) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSInsertRecordReq

type TSInsertRecordReq struct {
	SessionId    int64    `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	PrefixPath   string   `thrift:"prefixPath,2,required" db:"prefixPath" json:"prefixPath"`
	Measurements []string `thrift:"measurements,3,required" db:"measurements" json:"measurements"`
	Values       []byte   `thrift:"values,4,required" db:"values" json:"values"`
	Timestamp    int64    `thrift:"timestamp,5,required" db:"timestamp" json:"timestamp"`
	IsAligned    *bool    `thrift:"isAligned,6" db:"isAligned" json:"isAligned,omitempty"`
}

Attributes:

  • SessionId
  • PrefixPath
  • Measurements
  • Values
  • Timestamp
  • IsAligned
var IClientRPCServiceInsertRecordArgs_Req_DEFAULT *TSInsertRecordReq
var IClientRPCServiceTestInsertRecordArgs_Req_DEFAULT *TSInsertRecordReq

func NewTSInsertRecordReq

func NewTSInsertRecordReq() *TSInsertRecordReq

func (*TSInsertRecordReq) Equals added in v0.12.1

func (p *TSInsertRecordReq) Equals(other *TSInsertRecordReq) bool

func (*TSInsertRecordReq) GetIsAligned added in v0.13.0

func (p *TSInsertRecordReq) GetIsAligned() bool

func (*TSInsertRecordReq) GetMeasurements

func (p *TSInsertRecordReq) GetMeasurements() []string

func (*TSInsertRecordReq) GetPrefixPath added in v0.13.0

func (p *TSInsertRecordReq) GetPrefixPath() string

func (*TSInsertRecordReq) GetSessionId

func (p *TSInsertRecordReq) GetSessionId() int64

func (*TSInsertRecordReq) GetTimestamp

func (p *TSInsertRecordReq) GetTimestamp() int64

func (*TSInsertRecordReq) GetValues

func (p *TSInsertRecordReq) GetValues() []byte

func (*TSInsertRecordReq) IsSetIsAligned added in v0.13.0

func (p *TSInsertRecordReq) IsSetIsAligned() bool

func (*TSInsertRecordReq) Read

func (p *TSInsertRecordReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertRecordReq) ReadField1

func (p *TSInsertRecordReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertRecordReq) ReadField2

func (p *TSInsertRecordReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertRecordReq) ReadField3

func (p *TSInsertRecordReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertRecordReq) ReadField4

func (p *TSInsertRecordReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertRecordReq) ReadField5

func (p *TSInsertRecordReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertRecordReq) ReadField6 added in v0.13.0

func (p *TSInsertRecordReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertRecordReq) String

func (p *TSInsertRecordReq) String() string

func (*TSInsertRecordReq) Write

func (p *TSInsertRecordReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSInsertRecordsOfOneDeviceReq

type TSInsertRecordsOfOneDeviceReq struct {
	SessionId        int64      `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	PrefixPath       string     `thrift:"prefixPath,2,required" db:"prefixPath" json:"prefixPath"`
	MeasurementsList [][]string `thrift:"measurementsList,3,required" db:"measurementsList" json:"measurementsList"`
	ValuesList       [][]byte   `thrift:"valuesList,4,required" db:"valuesList" json:"valuesList"`
	Timestamps       []int64    `thrift:"timestamps,5,required" db:"timestamps" json:"timestamps"`
	IsAligned        *bool      `thrift:"isAligned,6" db:"isAligned" json:"isAligned,omitempty"`
}

Attributes:

  • SessionId
  • PrefixPath
  • MeasurementsList
  • ValuesList
  • Timestamps
  • IsAligned
var IClientRPCServiceInsertRecordsOfOneDeviceArgs_Req_DEFAULT *TSInsertRecordsOfOneDeviceReq
var IClientRPCServiceTestInsertRecordsOfOneDeviceArgs_Req_DEFAULT *TSInsertRecordsOfOneDeviceReq

func NewTSInsertRecordsOfOneDeviceReq

func NewTSInsertRecordsOfOneDeviceReq() *TSInsertRecordsOfOneDeviceReq

func (*TSInsertRecordsOfOneDeviceReq) Equals added in v0.12.1

func (*TSInsertRecordsOfOneDeviceReq) GetIsAligned added in v0.13.0

func (p *TSInsertRecordsOfOneDeviceReq) GetIsAligned() bool

func (*TSInsertRecordsOfOneDeviceReq) GetMeasurementsList

func (p *TSInsertRecordsOfOneDeviceReq) GetMeasurementsList() [][]string

func (*TSInsertRecordsOfOneDeviceReq) GetPrefixPath added in v0.13.0

func (p *TSInsertRecordsOfOneDeviceReq) GetPrefixPath() string

func (*TSInsertRecordsOfOneDeviceReq) GetSessionId

func (p *TSInsertRecordsOfOneDeviceReq) GetSessionId() int64

func (*TSInsertRecordsOfOneDeviceReq) GetTimestamps

func (p *TSInsertRecordsOfOneDeviceReq) GetTimestamps() []int64

func (*TSInsertRecordsOfOneDeviceReq) GetValuesList

func (p *TSInsertRecordsOfOneDeviceReq) GetValuesList() [][]byte

func (*TSInsertRecordsOfOneDeviceReq) IsSetIsAligned added in v0.13.0

func (p *TSInsertRecordsOfOneDeviceReq) IsSetIsAligned() bool

func (*TSInsertRecordsOfOneDeviceReq) Read

func (*TSInsertRecordsOfOneDeviceReq) ReadField1

func (*TSInsertRecordsOfOneDeviceReq) ReadField2

func (*TSInsertRecordsOfOneDeviceReq) ReadField3

func (*TSInsertRecordsOfOneDeviceReq) ReadField4

func (*TSInsertRecordsOfOneDeviceReq) ReadField5

func (*TSInsertRecordsOfOneDeviceReq) ReadField6 added in v0.13.0

func (*TSInsertRecordsOfOneDeviceReq) String

func (*TSInsertRecordsOfOneDeviceReq) Write

type TSInsertRecordsReq

type TSInsertRecordsReq struct {
	SessionId        int64      `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	PrefixPaths      []string   `thrift:"prefixPaths,2,required" db:"prefixPaths" json:"prefixPaths"`
	MeasurementsList [][]string `thrift:"measurementsList,3,required" db:"measurementsList" json:"measurementsList"`
	ValuesList       [][]byte   `thrift:"valuesList,4,required" db:"valuesList" json:"valuesList"`
	Timestamps       []int64    `thrift:"timestamps,5,required" db:"timestamps" json:"timestamps"`
	IsAligned        *bool      `thrift:"isAligned,6" db:"isAligned" json:"isAligned,omitempty"`
}

Attributes:

  • SessionId
  • PrefixPaths
  • MeasurementsList
  • ValuesList
  • Timestamps
  • IsAligned
var IClientRPCServiceInsertRecordsArgs_Req_DEFAULT *TSInsertRecordsReq
var IClientRPCServiceTestInsertRecordsArgs_Req_DEFAULT *TSInsertRecordsReq

func NewTSInsertRecordsReq

func NewTSInsertRecordsReq() *TSInsertRecordsReq

func (*TSInsertRecordsReq) Equals added in v0.12.1

func (p *TSInsertRecordsReq) Equals(other *TSInsertRecordsReq) bool

func (*TSInsertRecordsReq) GetIsAligned added in v0.13.0

func (p *TSInsertRecordsReq) GetIsAligned() bool

func (*TSInsertRecordsReq) GetMeasurementsList

func (p *TSInsertRecordsReq) GetMeasurementsList() [][]string

func (*TSInsertRecordsReq) GetPrefixPaths added in v0.13.0

func (p *TSInsertRecordsReq) GetPrefixPaths() []string

func (*TSInsertRecordsReq) GetSessionId

func (p *TSInsertRecordsReq) GetSessionId() int64

func (*TSInsertRecordsReq) GetTimestamps

func (p *TSInsertRecordsReq) GetTimestamps() []int64

func (*TSInsertRecordsReq) GetValuesList

func (p *TSInsertRecordsReq) GetValuesList() [][]byte

func (*TSInsertRecordsReq) IsSetIsAligned added in v0.13.0

func (p *TSInsertRecordsReq) IsSetIsAligned() bool

func (*TSInsertRecordsReq) Read

func (*TSInsertRecordsReq) ReadField1

func (p *TSInsertRecordsReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertRecordsReq) ReadField2

func (p *TSInsertRecordsReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertRecordsReq) ReadField3

func (p *TSInsertRecordsReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertRecordsReq) ReadField4

func (p *TSInsertRecordsReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertRecordsReq) ReadField5

func (p *TSInsertRecordsReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertRecordsReq) ReadField6 added in v0.13.0

func (p *TSInsertRecordsReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertRecordsReq) String

func (p *TSInsertRecordsReq) String() string

func (*TSInsertRecordsReq) Write

func (p *TSInsertRecordsReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSInsertStringRecordReq

type TSInsertStringRecordReq struct {
	SessionId    int64    `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	PrefixPath   string   `thrift:"prefixPath,2,required" db:"prefixPath" json:"prefixPath"`
	Measurements []string `thrift:"measurements,3,required" db:"measurements" json:"measurements"`
	Values       []string `thrift:"values,4,required" db:"values" json:"values"`
	Timestamp    int64    `thrift:"timestamp,5,required" db:"timestamp" json:"timestamp"`
	IsAligned    *bool    `thrift:"isAligned,6" db:"isAligned" json:"isAligned,omitempty"`
	Timeout      *int64   `thrift:"timeout,7" db:"timeout" json:"timeout,omitempty"`
}

Attributes:

  • SessionId
  • PrefixPath
  • Measurements
  • Values
  • Timestamp
  • IsAligned
  • Timeout
var IClientRPCServiceInsertStringRecordArgs_Req_DEFAULT *TSInsertStringRecordReq
var IClientRPCServiceTestInsertStringRecordArgs_Req_DEFAULT *TSInsertStringRecordReq

func NewTSInsertStringRecordReq

func NewTSInsertStringRecordReq() *TSInsertStringRecordReq

func (*TSInsertStringRecordReq) Equals added in v0.12.1

func (*TSInsertStringRecordReq) GetIsAligned added in v0.13.0

func (p *TSInsertStringRecordReq) GetIsAligned() bool

func (*TSInsertStringRecordReq) GetMeasurements

func (p *TSInsertStringRecordReq) GetMeasurements() []string

func (*TSInsertStringRecordReq) GetPrefixPath added in v0.13.0

func (p *TSInsertStringRecordReq) GetPrefixPath() string

func (*TSInsertStringRecordReq) GetSessionId

func (p *TSInsertStringRecordReq) GetSessionId() int64

func (*TSInsertStringRecordReq) GetTimeout added in v1.1.5

func (p *TSInsertStringRecordReq) GetTimeout() int64

func (*TSInsertStringRecordReq) GetTimestamp

func (p *TSInsertStringRecordReq) GetTimestamp() int64

func (*TSInsertStringRecordReq) GetValues

func (p *TSInsertStringRecordReq) GetValues() []string

func (*TSInsertStringRecordReq) IsSetIsAligned added in v0.13.0

func (p *TSInsertStringRecordReq) IsSetIsAligned() bool

func (*TSInsertStringRecordReq) IsSetTimeout added in v1.1.5

func (p *TSInsertStringRecordReq) IsSetTimeout() bool

func (*TSInsertStringRecordReq) Read

func (*TSInsertStringRecordReq) ReadField1

func (p *TSInsertStringRecordReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertStringRecordReq) ReadField2

func (p *TSInsertStringRecordReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertStringRecordReq) ReadField3

func (p *TSInsertStringRecordReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertStringRecordReq) ReadField4

func (p *TSInsertStringRecordReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertStringRecordReq) ReadField5

func (p *TSInsertStringRecordReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertStringRecordReq) ReadField6 added in v0.13.0

func (p *TSInsertStringRecordReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertStringRecordReq) ReadField7 added in v1.1.5

func (p *TSInsertStringRecordReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertStringRecordReq) String

func (p *TSInsertStringRecordReq) String() string

func (*TSInsertStringRecordReq) Write

type TSInsertStringRecordsOfOneDeviceReq added in v0.13.0

type TSInsertStringRecordsOfOneDeviceReq struct {
	SessionId        int64      `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	PrefixPath       string     `thrift:"prefixPath,2,required" db:"prefixPath" json:"prefixPath"`
	MeasurementsList [][]string `thrift:"measurementsList,3,required" db:"measurementsList" json:"measurementsList"`
	ValuesList       [][]string `thrift:"valuesList,4,required" db:"valuesList" json:"valuesList"`
	Timestamps       []int64    `thrift:"timestamps,5,required" db:"timestamps" json:"timestamps"`
	IsAligned        *bool      `thrift:"isAligned,6" db:"isAligned" json:"isAligned,omitempty"`
}

Attributes:

  • SessionId
  • PrefixPath
  • MeasurementsList
  • ValuesList
  • Timestamps
  • IsAligned
var IClientRPCServiceInsertStringRecordsOfOneDeviceArgs_Req_DEFAULT *TSInsertStringRecordsOfOneDeviceReq

func NewTSInsertStringRecordsOfOneDeviceReq added in v0.13.0

func NewTSInsertStringRecordsOfOneDeviceReq() *TSInsertStringRecordsOfOneDeviceReq

func (*TSInsertStringRecordsOfOneDeviceReq) Equals added in v0.13.0

func (*TSInsertStringRecordsOfOneDeviceReq) GetIsAligned added in v0.13.0

func (p *TSInsertStringRecordsOfOneDeviceReq) GetIsAligned() bool

func (*TSInsertStringRecordsOfOneDeviceReq) GetMeasurementsList added in v0.13.0

func (p *TSInsertStringRecordsOfOneDeviceReq) GetMeasurementsList() [][]string

func (*TSInsertStringRecordsOfOneDeviceReq) GetPrefixPath added in v0.13.0

func (p *TSInsertStringRecordsOfOneDeviceReq) GetPrefixPath() string

func (*TSInsertStringRecordsOfOneDeviceReq) GetSessionId added in v0.13.0

func (p *TSInsertStringRecordsOfOneDeviceReq) GetSessionId() int64

func (*TSInsertStringRecordsOfOneDeviceReq) GetTimestamps added in v0.13.0

func (p *TSInsertStringRecordsOfOneDeviceReq) GetTimestamps() []int64

func (*TSInsertStringRecordsOfOneDeviceReq) GetValuesList added in v0.13.0

func (p *TSInsertStringRecordsOfOneDeviceReq) GetValuesList() [][]string

func (*TSInsertStringRecordsOfOneDeviceReq) IsSetIsAligned added in v0.13.0

func (p *TSInsertStringRecordsOfOneDeviceReq) IsSetIsAligned() bool

func (*TSInsertStringRecordsOfOneDeviceReq) Read added in v0.13.0

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField1 added in v0.13.0

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField2 added in v0.13.0

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField3 added in v0.13.0

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField4 added in v0.13.0

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField5 added in v0.13.0

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField6 added in v0.13.0

func (*TSInsertStringRecordsOfOneDeviceReq) String added in v0.13.0

func (*TSInsertStringRecordsOfOneDeviceReq) Write added in v0.13.0

type TSInsertStringRecordsReq

type TSInsertStringRecordsReq struct {
	SessionId        int64      `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	PrefixPaths      []string   `thrift:"prefixPaths,2,required" db:"prefixPaths" json:"prefixPaths"`
	MeasurementsList [][]string `thrift:"measurementsList,3,required" db:"measurementsList" json:"measurementsList"`
	ValuesList       [][]string `thrift:"valuesList,4,required" db:"valuesList" json:"valuesList"`
	Timestamps       []int64    `thrift:"timestamps,5,required" db:"timestamps" json:"timestamps"`
	IsAligned        *bool      `thrift:"isAligned,6" db:"isAligned" json:"isAligned,omitempty"`
}

Attributes:

  • SessionId
  • PrefixPaths
  • MeasurementsList
  • ValuesList
  • Timestamps
  • IsAligned
var IClientRPCServiceInsertStringRecordsArgs_Req_DEFAULT *TSInsertStringRecordsReq
var IClientRPCServiceTestInsertStringRecordsArgs_Req_DEFAULT *TSInsertStringRecordsReq

func NewTSInsertStringRecordsReq

func NewTSInsertStringRecordsReq() *TSInsertStringRecordsReq

func (*TSInsertStringRecordsReq) Equals added in v0.12.1

func (*TSInsertStringRecordsReq) GetIsAligned added in v0.13.0

func (p *TSInsertStringRecordsReq) GetIsAligned() bool

func (*TSInsertStringRecordsReq) GetMeasurementsList

func (p *TSInsertStringRecordsReq) GetMeasurementsList() [][]string

func (*TSInsertStringRecordsReq) GetPrefixPaths added in v0.13.0

func (p *TSInsertStringRecordsReq) GetPrefixPaths() []string

func (*TSInsertStringRecordsReq) GetSessionId

func (p *TSInsertStringRecordsReq) GetSessionId() int64

func (*TSInsertStringRecordsReq) GetTimestamps

func (p *TSInsertStringRecordsReq) GetTimestamps() []int64

func (*TSInsertStringRecordsReq) GetValuesList

func (p *TSInsertStringRecordsReq) GetValuesList() [][]string

func (*TSInsertStringRecordsReq) IsSetIsAligned added in v0.13.0

func (p *TSInsertStringRecordsReq) IsSetIsAligned() bool

func (*TSInsertStringRecordsReq) Read

func (*TSInsertStringRecordsReq) ReadField1

func (p *TSInsertStringRecordsReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertStringRecordsReq) ReadField2

func (p *TSInsertStringRecordsReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertStringRecordsReq) ReadField3

func (p *TSInsertStringRecordsReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertStringRecordsReq) ReadField4

func (p *TSInsertStringRecordsReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertStringRecordsReq) ReadField5

func (p *TSInsertStringRecordsReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertStringRecordsReq) ReadField6 added in v0.13.0

func (p *TSInsertStringRecordsReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertStringRecordsReq) String

func (p *TSInsertStringRecordsReq) String() string

func (*TSInsertStringRecordsReq) Write

type TSInsertTabletReq

type TSInsertTabletReq struct {
	SessionId    int64    `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	PrefixPath   string   `thrift:"prefixPath,2,required" db:"prefixPath" json:"prefixPath"`
	Measurements []string `thrift:"measurements,3,required" db:"measurements" json:"measurements"`
	Values       []byte   `thrift:"values,4,required" db:"values" json:"values"`
	Timestamps   []byte   `thrift:"timestamps,5,required" db:"timestamps" json:"timestamps"`
	Types        []int32  `thrift:"types,6,required" db:"types" json:"types"`
	Size         int32    `thrift:"size,7,required" db:"size" json:"size"`
	IsAligned    *bool    `thrift:"isAligned,8" db:"isAligned" json:"isAligned,omitempty"`
}

Attributes:

  • SessionId
  • PrefixPath
  • Measurements
  • Values
  • Timestamps
  • Types
  • Size
  • IsAligned
var IClientRPCServiceInsertTabletArgs_Req_DEFAULT *TSInsertTabletReq
var IClientRPCServiceTestInsertTabletArgs_Req_DEFAULT *TSInsertTabletReq

func NewTSInsertTabletReq

func NewTSInsertTabletReq() *TSInsertTabletReq

func (*TSInsertTabletReq) Equals added in v0.12.1

func (p *TSInsertTabletReq) Equals(other *TSInsertTabletReq) bool

func (*TSInsertTabletReq) GetIsAligned added in v0.13.0

func (p *TSInsertTabletReq) GetIsAligned() bool

func (*TSInsertTabletReq) GetMeasurements

func (p *TSInsertTabletReq) GetMeasurements() []string

func (*TSInsertTabletReq) GetPrefixPath added in v0.13.0

func (p *TSInsertTabletReq) GetPrefixPath() string

func (*TSInsertTabletReq) GetSessionId

func (p *TSInsertTabletReq) GetSessionId() int64

func (*TSInsertTabletReq) GetSize

func (p *TSInsertTabletReq) GetSize() int32

func (*TSInsertTabletReq) GetTimestamps

func (p *TSInsertTabletReq) GetTimestamps() []byte

func (*TSInsertTabletReq) GetTypes

func (p *TSInsertTabletReq) GetTypes() []int32

func (*TSInsertTabletReq) GetValues

func (p *TSInsertTabletReq) GetValues() []byte

func (*TSInsertTabletReq) IsSetIsAligned added in v0.13.0

func (p *TSInsertTabletReq) IsSetIsAligned() bool

func (*TSInsertTabletReq) Read

func (p *TSInsertTabletReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletReq) ReadField1

func (p *TSInsertTabletReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletReq) ReadField2

func (p *TSInsertTabletReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletReq) ReadField3

func (p *TSInsertTabletReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletReq) ReadField4

func (p *TSInsertTabletReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletReq) ReadField5

func (p *TSInsertTabletReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletReq) ReadField6

func (p *TSInsertTabletReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletReq) ReadField7

func (p *TSInsertTabletReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletReq) ReadField8 added in v0.13.0

func (p *TSInsertTabletReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletReq) String

func (p *TSInsertTabletReq) String() string

func (*TSInsertTabletReq) Write

func (p *TSInsertTabletReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSInsertTabletsReq

type TSInsertTabletsReq struct {
	SessionId        int64      `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	PrefixPaths      []string   `thrift:"prefixPaths,2,required" db:"prefixPaths" json:"prefixPaths"`
	MeasurementsList [][]string `thrift:"measurementsList,3,required" db:"measurementsList" json:"measurementsList"`
	ValuesList       [][]byte   `thrift:"valuesList,4,required" db:"valuesList" json:"valuesList"`
	TimestampsList   [][]byte   `thrift:"timestampsList,5,required" db:"timestampsList" json:"timestampsList"`
	TypesList        [][]int32  `thrift:"typesList,6,required" db:"typesList" json:"typesList"`
	SizeList         []int32    `thrift:"sizeList,7,required" db:"sizeList" json:"sizeList"`
	IsAligned        *bool      `thrift:"isAligned,8" db:"isAligned" json:"isAligned,omitempty"`
}

Attributes:

  • SessionId
  • PrefixPaths
  • MeasurementsList
  • ValuesList
  • TimestampsList
  • TypesList
  • SizeList
  • IsAligned
var IClientRPCServiceInsertTabletsArgs_Req_DEFAULT *TSInsertTabletsReq
var IClientRPCServiceTestInsertTabletsArgs_Req_DEFAULT *TSInsertTabletsReq

func NewTSInsertTabletsReq

func NewTSInsertTabletsReq() *TSInsertTabletsReq

func (*TSInsertTabletsReq) Equals added in v0.12.1

func (p *TSInsertTabletsReq) Equals(other *TSInsertTabletsReq) bool

func (*TSInsertTabletsReq) GetIsAligned added in v0.13.0

func (p *TSInsertTabletsReq) GetIsAligned() bool

func (*TSInsertTabletsReq) GetMeasurementsList

func (p *TSInsertTabletsReq) GetMeasurementsList() [][]string

func (*TSInsertTabletsReq) GetPrefixPaths added in v0.13.0

func (p *TSInsertTabletsReq) GetPrefixPaths() []string

func (*TSInsertTabletsReq) GetSessionId

func (p *TSInsertTabletsReq) GetSessionId() int64

func (*TSInsertTabletsReq) GetSizeList

func (p *TSInsertTabletsReq) GetSizeList() []int32

func (*TSInsertTabletsReq) GetTimestampsList

func (p *TSInsertTabletsReq) GetTimestampsList() [][]byte

func (*TSInsertTabletsReq) GetTypesList

func (p *TSInsertTabletsReq) GetTypesList() [][]int32

func (*TSInsertTabletsReq) GetValuesList

func (p *TSInsertTabletsReq) GetValuesList() [][]byte

func (*TSInsertTabletsReq) IsSetIsAligned added in v0.13.0

func (p *TSInsertTabletsReq) IsSetIsAligned() bool

func (*TSInsertTabletsReq) Read

func (*TSInsertTabletsReq) ReadField1

func (p *TSInsertTabletsReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletsReq) ReadField2

func (p *TSInsertTabletsReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletsReq) ReadField3

func (p *TSInsertTabletsReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletsReq) ReadField4

func (p *TSInsertTabletsReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletsReq) ReadField5

func (p *TSInsertTabletsReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletsReq) ReadField6

func (p *TSInsertTabletsReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletsReq) ReadField7

func (p *TSInsertTabletsReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletsReq) ReadField8 added in v0.13.0

func (p *TSInsertTabletsReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertTabletsReq) String

func (p *TSInsertTabletsReq) String() string

func (*TSInsertTabletsReq) Write

func (p *TSInsertTabletsReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSLastDataQueryReq added in v0.13.0

type TSLastDataQueryReq struct {
	SessionId           int64    `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	Paths               []string `thrift:"paths,2,required" db:"paths" json:"paths"`
	FetchSize           *int32   `thrift:"fetchSize,3" db:"fetchSize" json:"fetchSize,omitempty"`
	Time                int64    `thrift:"time,4,required" db:"time" json:"time"`
	StatementId         int64    `thrift:"statementId,5,required" db:"statementId" json:"statementId"`
	EnableRedirectQuery *bool    `thrift:"enableRedirectQuery,6" db:"enableRedirectQuery" json:"enableRedirectQuery,omitempty"`
	JdbcQuery           *bool    `thrift:"jdbcQuery,7" db:"jdbcQuery" json:"jdbcQuery,omitempty"`
	Timeout             *int64   `thrift:"timeout,8" db:"timeout" json:"timeout,omitempty"`
}

Attributes:

  • SessionId
  • Paths
  • FetchSize
  • Time
  • StatementId
  • EnableRedirectQuery
  • JdbcQuery
  • Timeout
var IClientRPCServiceExecuteLastDataQueryArgs_Req_DEFAULT *TSLastDataQueryReq
var IClientRPCServiceExecuteLastDataQueryV2Args_Req_DEFAULT *TSLastDataQueryReq

func NewTSLastDataQueryReq added in v0.13.0

func NewTSLastDataQueryReq() *TSLastDataQueryReq

func (*TSLastDataQueryReq) Equals added in v0.13.0

func (p *TSLastDataQueryReq) Equals(other *TSLastDataQueryReq) bool

func (*TSLastDataQueryReq) GetEnableRedirectQuery added in v0.13.0

func (p *TSLastDataQueryReq) GetEnableRedirectQuery() bool

func (*TSLastDataQueryReq) GetFetchSize added in v0.13.0

func (p *TSLastDataQueryReq) GetFetchSize() int32

func (*TSLastDataQueryReq) GetJdbcQuery added in v0.13.0

func (p *TSLastDataQueryReq) GetJdbcQuery() bool

func (*TSLastDataQueryReq) GetPaths added in v0.13.0

func (p *TSLastDataQueryReq) GetPaths() []string

func (*TSLastDataQueryReq) GetSessionId added in v0.13.0

func (p *TSLastDataQueryReq) GetSessionId() int64

func (*TSLastDataQueryReq) GetStatementId added in v0.13.0

func (p *TSLastDataQueryReq) GetStatementId() int64

func (*TSLastDataQueryReq) GetTime added in v0.13.0

func (p *TSLastDataQueryReq) GetTime() int64

func (*TSLastDataQueryReq) GetTimeout added in v1.1.5

func (p *TSLastDataQueryReq) GetTimeout() int64

func (*TSLastDataQueryReq) IsSetEnableRedirectQuery added in v0.13.0

func (p *TSLastDataQueryReq) IsSetEnableRedirectQuery() bool

func (*TSLastDataQueryReq) IsSetFetchSize added in v0.13.0

func (p *TSLastDataQueryReq) IsSetFetchSize() bool

func (*TSLastDataQueryReq) IsSetJdbcQuery added in v0.13.0

func (p *TSLastDataQueryReq) IsSetJdbcQuery() bool

func (*TSLastDataQueryReq) IsSetTimeout added in v1.1.5

func (p *TSLastDataQueryReq) IsSetTimeout() bool

func (*TSLastDataQueryReq) Read added in v0.13.0

func (*TSLastDataQueryReq) ReadField1 added in v0.13.0

func (p *TSLastDataQueryReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSLastDataQueryReq) ReadField2 added in v0.13.0

func (p *TSLastDataQueryReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSLastDataQueryReq) ReadField3 added in v0.13.0

func (p *TSLastDataQueryReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSLastDataQueryReq) ReadField4 added in v0.13.0

func (p *TSLastDataQueryReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSLastDataQueryReq) ReadField5 added in v0.13.0

func (p *TSLastDataQueryReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSLastDataQueryReq) ReadField6 added in v0.13.0

func (p *TSLastDataQueryReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSLastDataQueryReq) ReadField7 added in v0.13.0

func (p *TSLastDataQueryReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TSLastDataQueryReq) ReadField8 added in v1.1.5

func (p *TSLastDataQueryReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TSLastDataQueryReq) String added in v0.13.0

func (p *TSLastDataQueryReq) String() string

func (*TSLastDataQueryReq) Write added in v0.13.0

func (p *TSLastDataQueryReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSOpenSessionReq

type TSOpenSessionReq struct {
	ClientProtocol TSProtocolVersion `thrift:"client_protocol,1,required" db:"client_protocol" json:"client_protocol"`
	ZoneId         string            `thrift:"zoneId,2,required" db:"zoneId" json:"zoneId"`
	Username       string            `thrift:"username,3,required" db:"username" json:"username"`
	Password       *string           `thrift:"password,4" db:"password" json:"password,omitempty"`
	Configuration  map[string]string `thrift:"configuration,5" db:"configuration" json:"configuration,omitempty"`
}

Attributes:

  • ClientProtocol
  • ZoneId
  • Username
  • Password
  • Configuration
var IClientRPCServiceOpenSessionArgs_Req_DEFAULT *TSOpenSessionReq

func NewTSOpenSessionReq

func NewTSOpenSessionReq() *TSOpenSessionReq

func (*TSOpenSessionReq) Equals added in v0.12.1

func (p *TSOpenSessionReq) Equals(other *TSOpenSessionReq) bool

func (*TSOpenSessionReq) GetClientProtocol

func (p *TSOpenSessionReq) GetClientProtocol() TSProtocolVersion

func (*TSOpenSessionReq) GetConfiguration

func (p *TSOpenSessionReq) GetConfiguration() map[string]string

func (*TSOpenSessionReq) GetPassword

func (p *TSOpenSessionReq) GetPassword() string

func (*TSOpenSessionReq) GetUsername

func (p *TSOpenSessionReq) GetUsername() string

func (*TSOpenSessionReq) GetZoneId

func (p *TSOpenSessionReq) GetZoneId() string

func (*TSOpenSessionReq) IsSetConfiguration

func (p *TSOpenSessionReq) IsSetConfiguration() bool

func (*TSOpenSessionReq) IsSetPassword

func (p *TSOpenSessionReq) IsSetPassword() bool

func (*TSOpenSessionReq) Read

func (p *TSOpenSessionReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSOpenSessionReq) ReadField1

func (p *TSOpenSessionReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSOpenSessionReq) ReadField2

func (p *TSOpenSessionReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSOpenSessionReq) ReadField3

func (p *TSOpenSessionReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSOpenSessionReq) ReadField4

func (p *TSOpenSessionReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSOpenSessionReq) ReadField5

func (p *TSOpenSessionReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSOpenSessionReq) String

func (p *TSOpenSessionReq) String() string

func (*TSOpenSessionReq) Write

func (p *TSOpenSessionReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSOpenSessionResp

type TSOpenSessionResp struct {
	Status                *common.TSStatus  `thrift:"status,1,required" db:"status" json:"status"`
	ServerProtocolVersion TSProtocolVersion `thrift:"serverProtocolVersion,2,required" db:"serverProtocolVersion" json:"serverProtocolVersion"`
	SessionId             *int64            `thrift:"sessionId,3" db:"sessionId" json:"sessionId,omitempty"`
	Configuration         map[string]string `thrift:"configuration,4" db:"configuration" json:"configuration,omitempty"`
}

Attributes:

  • Status
  • ServerProtocolVersion
  • SessionId
  • Configuration
var IClientRPCServiceOpenSessionResult_Success_DEFAULT *TSOpenSessionResp

func NewTSOpenSessionResp

func NewTSOpenSessionResp() *TSOpenSessionResp

func (*TSOpenSessionResp) Equals added in v0.12.1

func (p *TSOpenSessionResp) Equals(other *TSOpenSessionResp) bool

func (*TSOpenSessionResp) GetConfiguration

func (p *TSOpenSessionResp) GetConfiguration() map[string]string

func (*TSOpenSessionResp) GetServerProtocolVersion

func (p *TSOpenSessionResp) GetServerProtocolVersion() TSProtocolVersion

func (*TSOpenSessionResp) GetSessionId

func (p *TSOpenSessionResp) GetSessionId() int64

func (*TSOpenSessionResp) GetStatus

func (p *TSOpenSessionResp) GetStatus() *common.TSStatus

func (*TSOpenSessionResp) IsSetConfiguration

func (p *TSOpenSessionResp) IsSetConfiguration() bool

func (*TSOpenSessionResp) IsSetSessionId

func (p *TSOpenSessionResp) IsSetSessionId() bool

func (*TSOpenSessionResp) IsSetStatus

func (p *TSOpenSessionResp) IsSetStatus() bool

func (*TSOpenSessionResp) Read

func (p *TSOpenSessionResp) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSOpenSessionResp) ReadField1

func (p *TSOpenSessionResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSOpenSessionResp) ReadField2

func (p *TSOpenSessionResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSOpenSessionResp) ReadField3

func (p *TSOpenSessionResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSOpenSessionResp) ReadField4

func (p *TSOpenSessionResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSOpenSessionResp) String

func (p *TSOpenSessionResp) String() string

func (*TSOpenSessionResp) Write

func (p *TSOpenSessionResp) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSProtocolVersion

type TSProtocolVersion int64
const (
	TSProtocolVersion_IOTDB_SERVICE_PROTOCOL_V1 TSProtocolVersion = 0
	TSProtocolVersion_IOTDB_SERVICE_PROTOCOL_V2 TSProtocolVersion = 1
	TSProtocolVersion_IOTDB_SERVICE_PROTOCOL_V3 TSProtocolVersion = 2
)

func TSProtocolVersionFromString

func TSProtocolVersionFromString(s string) (TSProtocolVersion, error)

func TSProtocolVersionPtr

func TSProtocolVersionPtr(v TSProtocolVersion) *TSProtocolVersion

func (TSProtocolVersion) MarshalText

func (p TSProtocolVersion) MarshalText() ([]byte, error)

func (*TSProtocolVersion) Scan

func (p *TSProtocolVersion) Scan(value interface{}) error

func (TSProtocolVersion) String

func (p TSProtocolVersion) String() string

func (*TSProtocolVersion) UnmarshalText

func (p *TSProtocolVersion) UnmarshalText(text []byte) error

func (*TSProtocolVersion) Value

func (p *TSProtocolVersion) Value() (driver.Value, error)

type TSPruneSchemaTemplateReq added in v0.13.0

type TSPruneSchemaTemplateReq struct {
	SessionId int64  `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	Name      string `thrift:"name,2,required" db:"name" json:"name"`
	Path      string `thrift:"path,3,required" db:"path" json:"path"`
}

Attributes:

  • SessionId
  • Name
  • Path
var IClientRPCServicePruneSchemaTemplateArgs_Req_DEFAULT *TSPruneSchemaTemplateReq

func NewTSPruneSchemaTemplateReq added in v0.13.0

func NewTSPruneSchemaTemplateReq() *TSPruneSchemaTemplateReq

func (*TSPruneSchemaTemplateReq) Equals added in v0.13.0

func (*TSPruneSchemaTemplateReq) GetName added in v0.13.0

func (p *TSPruneSchemaTemplateReq) GetName() string

func (*TSPruneSchemaTemplateReq) GetPath added in v0.13.0

func (p *TSPruneSchemaTemplateReq) GetPath() string

func (*TSPruneSchemaTemplateReq) GetSessionId added in v0.13.0

func (p *TSPruneSchemaTemplateReq) GetSessionId() int64

func (*TSPruneSchemaTemplateReq) Read added in v0.13.0

func (*TSPruneSchemaTemplateReq) ReadField1 added in v0.13.0

func (p *TSPruneSchemaTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSPruneSchemaTemplateReq) ReadField2 added in v0.13.0

func (p *TSPruneSchemaTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSPruneSchemaTemplateReq) ReadField3 added in v0.13.0

func (p *TSPruneSchemaTemplateReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSPruneSchemaTemplateReq) String added in v0.13.0

func (p *TSPruneSchemaTemplateReq) String() string

func (*TSPruneSchemaTemplateReq) Write added in v0.13.0

type TSQueryDataSet

type TSQueryDataSet struct {
	Time       []byte   `thrift:"time,1,required" db:"time" json:"time"`
	ValueList  [][]byte `thrift:"valueList,2,required" db:"valueList" json:"valueList"`
	BitmapList [][]byte `thrift:"bitmapList,3,required" db:"bitmapList" json:"bitmapList"`
}

Attributes:

  • Time
  • ValueList
  • BitmapList
var TSExecuteStatementResp_QueryDataSet_DEFAULT *TSQueryDataSet
var TSFetchResultsResp_QueryDataSet_DEFAULT *TSQueryDataSet

func NewTSQueryDataSet

func NewTSQueryDataSet() *TSQueryDataSet

func (*TSQueryDataSet) Equals added in v0.12.1

func (p *TSQueryDataSet) Equals(other *TSQueryDataSet) bool

func (*TSQueryDataSet) GetBitmapList

func (p *TSQueryDataSet) GetBitmapList() [][]byte

func (*TSQueryDataSet) GetTime

func (p *TSQueryDataSet) GetTime() []byte

func (*TSQueryDataSet) GetValueList

func (p *TSQueryDataSet) GetValueList() [][]byte

func (*TSQueryDataSet) Read

func (p *TSQueryDataSet) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryDataSet) ReadField1

func (p *TSQueryDataSet) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryDataSet) ReadField2

func (p *TSQueryDataSet) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryDataSet) ReadField3

func (p *TSQueryDataSet) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryDataSet) String

func (p *TSQueryDataSet) String() string

func (*TSQueryDataSet) Write

func (p *TSQueryDataSet) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSQueryNonAlignDataSet

type TSQueryNonAlignDataSet struct {
	TimeList  [][]byte `thrift:"timeList,1,required" db:"timeList" json:"timeList"`
	ValueList [][]byte `thrift:"valueList,2,required" db:"valueList" json:"valueList"`
}

Attributes:

  • TimeList
  • ValueList
var TSExecuteStatementResp_NonAlignQueryDataSet_DEFAULT *TSQueryNonAlignDataSet
var TSFetchResultsResp_NonAlignQueryDataSet_DEFAULT *TSQueryNonAlignDataSet

func NewTSQueryNonAlignDataSet

func NewTSQueryNonAlignDataSet() *TSQueryNonAlignDataSet

func (*TSQueryNonAlignDataSet) Equals added in v0.12.1

func (*TSQueryNonAlignDataSet) GetTimeList

func (p *TSQueryNonAlignDataSet) GetTimeList() [][]byte

func (*TSQueryNonAlignDataSet) GetValueList

func (p *TSQueryNonAlignDataSet) GetValueList() [][]byte

func (*TSQueryNonAlignDataSet) Read

func (*TSQueryNonAlignDataSet) ReadField1

func (p *TSQueryNonAlignDataSet) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryNonAlignDataSet) ReadField2

func (p *TSQueryNonAlignDataSet) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryNonAlignDataSet) String

func (p *TSQueryNonAlignDataSet) String() string

func (*TSQueryNonAlignDataSet) Write

type TSQueryTemplateReq added in v0.13.0

type TSQueryTemplateReq struct {
	SessionId   int64   `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	Name        string  `thrift:"name,2,required" db:"name" json:"name"`
	QueryType   int32   `thrift:"queryType,3,required" db:"queryType" json:"queryType"`
	Measurement *string `thrift:"measurement,4" db:"measurement" json:"measurement,omitempty"`
}

Attributes:

  • SessionId
  • Name
  • QueryType
  • Measurement
var IClientRPCServiceQuerySchemaTemplateArgs_Req_DEFAULT *TSQueryTemplateReq

func NewTSQueryTemplateReq added in v0.13.0

func NewTSQueryTemplateReq() *TSQueryTemplateReq

func (*TSQueryTemplateReq) Equals added in v0.13.0

func (p *TSQueryTemplateReq) Equals(other *TSQueryTemplateReq) bool

func (*TSQueryTemplateReq) GetMeasurement added in v0.13.0

func (p *TSQueryTemplateReq) GetMeasurement() string

func (*TSQueryTemplateReq) GetName added in v0.13.0

func (p *TSQueryTemplateReq) GetName() string

func (*TSQueryTemplateReq) GetQueryType added in v0.13.0

func (p *TSQueryTemplateReq) GetQueryType() int32

func (*TSQueryTemplateReq) GetSessionId added in v0.13.0

func (p *TSQueryTemplateReq) GetSessionId() int64

func (*TSQueryTemplateReq) IsSetMeasurement added in v0.13.0

func (p *TSQueryTemplateReq) IsSetMeasurement() bool

func (*TSQueryTemplateReq) Read added in v0.13.0

func (*TSQueryTemplateReq) ReadField1 added in v0.13.0

func (p *TSQueryTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryTemplateReq) ReadField2 added in v0.13.0

func (p *TSQueryTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryTemplateReq) ReadField3 added in v0.13.0

func (p *TSQueryTemplateReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryTemplateReq) ReadField4 added in v0.13.0

func (p *TSQueryTemplateReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryTemplateReq) String added in v0.13.0

func (p *TSQueryTemplateReq) String() string

func (*TSQueryTemplateReq) Write added in v0.13.0

func (p *TSQueryTemplateReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSQueryTemplateResp added in v0.13.0

type TSQueryTemplateResp struct {
	Status       *common.TSStatus `thrift:"status,1,required" db:"status" json:"status"`
	QueryType    int32            `thrift:"queryType,2,required" db:"queryType" json:"queryType"`
	Result_      *bool            `thrift:"result,3" db:"result" json:"result,omitempty"`
	Count        *int32           `thrift:"count,4" db:"count" json:"count,omitempty"`
	Measurements []string         `thrift:"measurements,5" db:"measurements" json:"measurements,omitempty"`
}

Attributes:

  • Status
  • QueryType
  • Result_
  • Count
  • Measurements
var IClientRPCServiceQuerySchemaTemplateResult_Success_DEFAULT *TSQueryTemplateResp

func NewTSQueryTemplateResp added in v0.13.0

func NewTSQueryTemplateResp() *TSQueryTemplateResp

func (*TSQueryTemplateResp) Equals added in v0.13.0

func (p *TSQueryTemplateResp) Equals(other *TSQueryTemplateResp) bool

func (*TSQueryTemplateResp) GetCount added in v0.13.0

func (p *TSQueryTemplateResp) GetCount() int32

func (*TSQueryTemplateResp) GetMeasurements added in v0.13.0

func (p *TSQueryTemplateResp) GetMeasurements() []string

func (*TSQueryTemplateResp) GetQueryType added in v0.13.0

func (p *TSQueryTemplateResp) GetQueryType() int32

func (*TSQueryTemplateResp) GetResult_ added in v0.13.0

func (p *TSQueryTemplateResp) GetResult_() bool

func (*TSQueryTemplateResp) GetStatus added in v0.13.0

func (p *TSQueryTemplateResp) GetStatus() *common.TSStatus

func (*TSQueryTemplateResp) IsSetCount added in v0.13.0

func (p *TSQueryTemplateResp) IsSetCount() bool

func (*TSQueryTemplateResp) IsSetMeasurements added in v0.13.0

func (p *TSQueryTemplateResp) IsSetMeasurements() bool

func (*TSQueryTemplateResp) IsSetResult_ added in v0.13.0

func (p *TSQueryTemplateResp) IsSetResult_() bool

func (*TSQueryTemplateResp) IsSetStatus added in v0.13.0

func (p *TSQueryTemplateResp) IsSetStatus() bool

func (*TSQueryTemplateResp) Read added in v0.13.0

func (*TSQueryTemplateResp) ReadField1 added in v0.13.0

func (p *TSQueryTemplateResp) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryTemplateResp) ReadField2 added in v0.13.0

func (p *TSQueryTemplateResp) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryTemplateResp) ReadField3 added in v0.13.0

func (p *TSQueryTemplateResp) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryTemplateResp) ReadField4 added in v0.13.0

func (p *TSQueryTemplateResp) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryTemplateResp) ReadField5 added in v0.13.0

func (p *TSQueryTemplateResp) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSQueryTemplateResp) String added in v0.13.0

func (p *TSQueryTemplateResp) String() string

func (*TSQueryTemplateResp) Write added in v0.13.0

type TSRawDataQueryReq

type TSRawDataQueryReq struct {
	SessionId           int64    `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	Paths               []string `thrift:"paths,2,required" db:"paths" json:"paths"`
	FetchSize           *int32   `thrift:"fetchSize,3" db:"fetchSize" json:"fetchSize,omitempty"`
	StartTime           int64    `thrift:"startTime,4,required" db:"startTime" json:"startTime"`
	EndTime             int64    `thrift:"endTime,5,required" db:"endTime" json:"endTime"`
	StatementId         int64    `thrift:"statementId,6,required" db:"statementId" json:"statementId"`
	EnableRedirectQuery *bool    `thrift:"enableRedirectQuery,7" db:"enableRedirectQuery" json:"enableRedirectQuery,omitempty"`
	JdbcQuery           *bool    `thrift:"jdbcQuery,8" db:"jdbcQuery" json:"jdbcQuery,omitempty"`
	Timeout             *int64   `thrift:"timeout,9" db:"timeout" json:"timeout,omitempty"`
}

Attributes:

  • SessionId
  • Paths
  • FetchSize
  • StartTime
  • EndTime
  • StatementId
  • EnableRedirectQuery
  • JdbcQuery
  • Timeout
var IClientRPCServiceExecuteRawDataQueryArgs_Req_DEFAULT *TSRawDataQueryReq
var IClientRPCServiceExecuteRawDataQueryV2Args_Req_DEFAULT *TSRawDataQueryReq

func NewTSRawDataQueryReq

func NewTSRawDataQueryReq() *TSRawDataQueryReq

func (*TSRawDataQueryReq) Equals added in v0.12.1

func (p *TSRawDataQueryReq) Equals(other *TSRawDataQueryReq) bool

func (*TSRawDataQueryReq) GetEnableRedirectQuery added in v0.12.1

func (p *TSRawDataQueryReq) GetEnableRedirectQuery() bool

func (*TSRawDataQueryReq) GetEndTime

func (p *TSRawDataQueryReq) GetEndTime() int64

func (*TSRawDataQueryReq) GetFetchSize

func (p *TSRawDataQueryReq) GetFetchSize() int32

func (*TSRawDataQueryReq) GetJdbcQuery added in v0.13.0

func (p *TSRawDataQueryReq) GetJdbcQuery() bool

func (*TSRawDataQueryReq) GetPaths

func (p *TSRawDataQueryReq) GetPaths() []string

func (*TSRawDataQueryReq) GetSessionId

func (p *TSRawDataQueryReq) GetSessionId() int64

func (*TSRawDataQueryReq) GetStartTime

func (p *TSRawDataQueryReq) GetStartTime() int64

func (*TSRawDataQueryReq) GetStatementId

func (p *TSRawDataQueryReq) GetStatementId() int64

func (*TSRawDataQueryReq) GetTimeout added in v1.1.5

func (p *TSRawDataQueryReq) GetTimeout() int64

func (*TSRawDataQueryReq) IsSetEnableRedirectQuery added in v0.12.1

func (p *TSRawDataQueryReq) IsSetEnableRedirectQuery() bool

func (*TSRawDataQueryReq) IsSetFetchSize

func (p *TSRawDataQueryReq) IsSetFetchSize() bool

func (*TSRawDataQueryReq) IsSetJdbcQuery added in v0.13.0

func (p *TSRawDataQueryReq) IsSetJdbcQuery() bool

func (*TSRawDataQueryReq) IsSetTimeout added in v1.1.5

func (p *TSRawDataQueryReq) IsSetTimeout() bool

func (*TSRawDataQueryReq) Read

func (p *TSRawDataQueryReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSRawDataQueryReq) ReadField1

func (p *TSRawDataQueryReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSRawDataQueryReq) ReadField2

func (p *TSRawDataQueryReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSRawDataQueryReq) ReadField3

func (p *TSRawDataQueryReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSRawDataQueryReq) ReadField4

func (p *TSRawDataQueryReq) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSRawDataQueryReq) ReadField5

func (p *TSRawDataQueryReq) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSRawDataQueryReq) ReadField6

func (p *TSRawDataQueryReq) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSRawDataQueryReq) ReadField7 added in v0.12.1

func (p *TSRawDataQueryReq) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TSRawDataQueryReq) ReadField8 added in v0.13.0

func (p *TSRawDataQueryReq) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TSRawDataQueryReq) ReadField9 added in v1.1.5

func (p *TSRawDataQueryReq) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*TSRawDataQueryReq) String

func (p *TSRawDataQueryReq) String() string

func (*TSRawDataQueryReq) Write

func (p *TSRawDataQueryReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSSetSchemaTemplateReq added in v0.13.0

type TSSetSchemaTemplateReq struct {
	SessionId    int64  `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	TemplateName string `thrift:"templateName,2,required" db:"templateName" json:"templateName"`
	PrefixPath   string `thrift:"prefixPath,3,required" db:"prefixPath" json:"prefixPath"`
}

Attributes:

  • SessionId
  • TemplateName
  • PrefixPath
var IClientRPCServiceSetSchemaTemplateArgs_Req_DEFAULT *TSSetSchemaTemplateReq

func NewTSSetSchemaTemplateReq added in v0.13.0

func NewTSSetSchemaTemplateReq() *TSSetSchemaTemplateReq

func (*TSSetSchemaTemplateReq) Equals added in v0.13.0

func (*TSSetSchemaTemplateReq) GetPrefixPath added in v0.13.0

func (p *TSSetSchemaTemplateReq) GetPrefixPath() string

func (*TSSetSchemaTemplateReq) GetSessionId added in v0.13.0

func (p *TSSetSchemaTemplateReq) GetSessionId() int64

func (*TSSetSchemaTemplateReq) GetTemplateName added in v0.13.0

func (p *TSSetSchemaTemplateReq) GetTemplateName() string

func (*TSSetSchemaTemplateReq) Read added in v0.13.0

func (*TSSetSchemaTemplateReq) ReadField1 added in v0.13.0

func (p *TSSetSchemaTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSSetSchemaTemplateReq) ReadField2 added in v0.13.0

func (p *TSSetSchemaTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSSetSchemaTemplateReq) ReadField3 added in v0.13.0

func (p *TSSetSchemaTemplateReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSSetSchemaTemplateReq) String added in v0.13.0

func (p *TSSetSchemaTemplateReq) String() string

func (*TSSetSchemaTemplateReq) Write added in v0.13.0

type TSSetTimeZoneReq

type TSSetTimeZoneReq struct {
	SessionId int64  `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	TimeZone  string `thrift:"timeZone,2,required" db:"timeZone" json:"timeZone"`
}

Attributes:

  • SessionId
  • TimeZone
var IClientRPCServiceSetTimeZoneArgs_Req_DEFAULT *TSSetTimeZoneReq

func NewTSSetTimeZoneReq

func NewTSSetTimeZoneReq() *TSSetTimeZoneReq

func (*TSSetTimeZoneReq) Equals added in v0.12.1

func (p *TSSetTimeZoneReq) Equals(other *TSSetTimeZoneReq) bool

func (*TSSetTimeZoneReq) GetSessionId

func (p *TSSetTimeZoneReq) GetSessionId() int64

func (*TSSetTimeZoneReq) GetTimeZone

func (p *TSSetTimeZoneReq) GetTimeZone() string

func (*TSSetTimeZoneReq) Read

func (p *TSSetTimeZoneReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSSetTimeZoneReq) ReadField1

func (p *TSSetTimeZoneReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSSetTimeZoneReq) ReadField2

func (p *TSSetTimeZoneReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSSetTimeZoneReq) String

func (p *TSSetTimeZoneReq) String() string

func (*TSSetTimeZoneReq) Write

func (p *TSSetTimeZoneReq) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSTracingInfo added in v0.13.0

type TSTracingInfo struct {
	ActivityList            []string `thrift:"activityList,1,required" db:"activityList" json:"activityList"`
	ElapsedTimeList         []int64  `thrift:"elapsedTimeList,2,required" db:"elapsedTimeList" json:"elapsedTimeList"`
	SeriesPathNum           *int32   `thrift:"seriesPathNum,3" db:"seriesPathNum" json:"seriesPathNum,omitempty"`
	SeqFileNum              *int32   `thrift:"seqFileNum,4" db:"seqFileNum" json:"seqFileNum,omitempty"`
	UnSeqFileNum            *int32   `thrift:"unSeqFileNum,5" db:"unSeqFileNum" json:"unSeqFileNum,omitempty"`
	SequenceChunkNum        *int32   `thrift:"sequenceChunkNum,6" db:"sequenceChunkNum" json:"sequenceChunkNum,omitempty"`
	SequenceChunkPointNum   *int64   `thrift:"sequenceChunkPointNum,7" db:"sequenceChunkPointNum" json:"sequenceChunkPointNum,omitempty"`
	UnsequenceChunkNum      *int32   `thrift:"unsequenceChunkNum,8" db:"unsequenceChunkNum" json:"unsequenceChunkNum,omitempty"`
	UnsequenceChunkPointNum *int64   `thrift:"unsequenceChunkPointNum,9" db:"unsequenceChunkPointNum" json:"unsequenceChunkPointNum,omitempty"`
	TotalPageNum            *int32   `thrift:"totalPageNum,10" db:"totalPageNum" json:"totalPageNum,omitempty"`
	OverlappedPageNum       *int32   `thrift:"overlappedPageNum,11" db:"overlappedPageNum" json:"overlappedPageNum,omitempty"`
}

Attributes:

  • ActivityList
  • ElapsedTimeList
  • SeriesPathNum
  • SeqFileNum
  • UnSeqFileNum
  • SequenceChunkNum
  • SequenceChunkPointNum
  • UnsequenceChunkNum
  • UnsequenceChunkPointNum
  • TotalPageNum
  • OverlappedPageNum
var TSExecuteStatementResp_TracingInfo_DEFAULT *TSTracingInfo

func NewTSTracingInfo added in v0.13.0

func NewTSTracingInfo() *TSTracingInfo

func (*TSTracingInfo) Equals added in v0.13.0

func (p *TSTracingInfo) Equals(other *TSTracingInfo) bool

func (*TSTracingInfo) GetActivityList added in v0.13.0

func (p *TSTracingInfo) GetActivityList() []string

func (*TSTracingInfo) GetElapsedTimeList added in v0.13.0

func (p *TSTracingInfo) GetElapsedTimeList() []int64

func (*TSTracingInfo) GetOverlappedPageNum added in v0.13.0

func (p *TSTracingInfo) GetOverlappedPageNum() int32

func (*TSTracingInfo) GetSeqFileNum added in v0.13.0

func (p *TSTracingInfo) GetSeqFileNum() int32

func (*TSTracingInfo) GetSequenceChunkNum added in v0.13.0

func (p *TSTracingInfo) GetSequenceChunkNum() int32

func (*TSTracingInfo) GetSequenceChunkPointNum added in v0.13.0

func (p *TSTracingInfo) GetSequenceChunkPointNum() int64

func (*TSTracingInfo) GetSeriesPathNum added in v0.13.0

func (p *TSTracingInfo) GetSeriesPathNum() int32

func (*TSTracingInfo) GetTotalPageNum added in v0.13.0

func (p *TSTracingInfo) GetTotalPageNum() int32

func (*TSTracingInfo) GetUnSeqFileNum added in v0.13.0

func (p *TSTracingInfo) GetUnSeqFileNum() int32

func (*TSTracingInfo) GetUnsequenceChunkNum added in v0.13.0

func (p *TSTracingInfo) GetUnsequenceChunkNum() int32

func (*TSTracingInfo) GetUnsequenceChunkPointNum added in v0.13.0

func (p *TSTracingInfo) GetUnsequenceChunkPointNum() int64

func (*TSTracingInfo) IsSetOverlappedPageNum added in v0.13.0

func (p *TSTracingInfo) IsSetOverlappedPageNum() bool

func (*TSTracingInfo) IsSetSeqFileNum added in v0.13.0

func (p *TSTracingInfo) IsSetSeqFileNum() bool

func (*TSTracingInfo) IsSetSequenceChunkNum added in v0.13.0

func (p *TSTracingInfo) IsSetSequenceChunkNum() bool

func (*TSTracingInfo) IsSetSequenceChunkPointNum added in v0.13.0

func (p *TSTracingInfo) IsSetSequenceChunkPointNum() bool

func (*TSTracingInfo) IsSetSeriesPathNum added in v0.13.0

func (p *TSTracingInfo) IsSetSeriesPathNum() bool

func (*TSTracingInfo) IsSetTotalPageNum added in v0.13.0

func (p *TSTracingInfo) IsSetTotalPageNum() bool

func (*TSTracingInfo) IsSetUnSeqFileNum added in v0.13.0

func (p *TSTracingInfo) IsSetUnSeqFileNum() bool

func (*TSTracingInfo) IsSetUnsequenceChunkNum added in v0.13.0

func (p *TSTracingInfo) IsSetUnsequenceChunkNum() bool

func (*TSTracingInfo) IsSetUnsequenceChunkPointNum added in v0.13.0

func (p *TSTracingInfo) IsSetUnsequenceChunkPointNum() bool

func (*TSTracingInfo) Read added in v0.13.0

func (p *TSTracingInfo) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSTracingInfo) ReadField1 added in v0.13.0

func (p *TSTracingInfo) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSTracingInfo) ReadField10 added in v0.13.0

func (p *TSTracingInfo) ReadField10(ctx context.Context, iprot thrift.TProtocol) error

func (*TSTracingInfo) ReadField11 added in v0.13.0

func (p *TSTracingInfo) ReadField11(ctx context.Context, iprot thrift.TProtocol) error

func (*TSTracingInfo) ReadField2 added in v0.13.0

func (p *TSTracingInfo) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSTracingInfo) ReadField3 added in v0.13.0

func (p *TSTracingInfo) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSTracingInfo) ReadField4 added in v0.13.0

func (p *TSTracingInfo) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSTracingInfo) ReadField5 added in v0.13.0

func (p *TSTracingInfo) ReadField5(ctx context.Context, iprot thrift.TProtocol) error

func (*TSTracingInfo) ReadField6 added in v0.13.0

func (p *TSTracingInfo) ReadField6(ctx context.Context, iprot thrift.TProtocol) error

func (*TSTracingInfo) ReadField7 added in v0.13.0

func (p *TSTracingInfo) ReadField7(ctx context.Context, iprot thrift.TProtocol) error

func (*TSTracingInfo) ReadField8 added in v0.13.0

func (p *TSTracingInfo) ReadField8(ctx context.Context, iprot thrift.TProtocol) error

func (*TSTracingInfo) ReadField9 added in v0.13.0

func (p *TSTracingInfo) ReadField9(ctx context.Context, iprot thrift.TProtocol) error

func (*TSTracingInfo) String added in v0.13.0

func (p *TSTracingInfo) String() string

func (*TSTracingInfo) Write added in v0.13.0

func (p *TSTracingInfo) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSUnsetSchemaTemplateReq added in v0.13.0

type TSUnsetSchemaTemplateReq struct {
	SessionId    int64  `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	PrefixPath   string `thrift:"prefixPath,2,required" db:"prefixPath" json:"prefixPath"`
	TemplateName string `thrift:"templateName,3,required" db:"templateName" json:"templateName"`
}

Attributes:

  • SessionId
  • PrefixPath
  • TemplateName
var IClientRPCServiceUnsetSchemaTemplateArgs_Req_DEFAULT *TSUnsetSchemaTemplateReq

func NewTSUnsetSchemaTemplateReq added in v0.13.0

func NewTSUnsetSchemaTemplateReq() *TSUnsetSchemaTemplateReq

func (*TSUnsetSchemaTemplateReq) Equals added in v0.13.0

func (*TSUnsetSchemaTemplateReq) GetPrefixPath added in v0.13.0

func (p *TSUnsetSchemaTemplateReq) GetPrefixPath() string

func (*TSUnsetSchemaTemplateReq) GetSessionId added in v0.13.0

func (p *TSUnsetSchemaTemplateReq) GetSessionId() int64

func (*TSUnsetSchemaTemplateReq) GetTemplateName added in v0.13.0

func (p *TSUnsetSchemaTemplateReq) GetTemplateName() string

func (*TSUnsetSchemaTemplateReq) Read added in v0.13.0

func (*TSUnsetSchemaTemplateReq) ReadField1 added in v0.13.0

func (p *TSUnsetSchemaTemplateReq) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSUnsetSchemaTemplateReq) ReadField2 added in v0.13.0

func (p *TSUnsetSchemaTemplateReq) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSUnsetSchemaTemplateReq) ReadField3 added in v0.13.0

func (p *TSUnsetSchemaTemplateReq) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSUnsetSchemaTemplateReq) String added in v0.13.0

func (p *TSUnsetSchemaTemplateReq) String() string

func (*TSUnsetSchemaTemplateReq) Write added in v0.13.0

type TSyncIdentityInfo added in v1.1.5

type TSyncIdentityInfo struct {
	PipeName   string `thrift:"pipeName,1,required" db:"pipeName" json:"pipeName"`
	CreateTime int64  `thrift:"createTime,2,required" db:"createTime" json:"createTime"`
	Version    string `thrift:"version,3,required" db:"version" json:"version"`
	Database   string `thrift:"database,4,required" db:"database" json:"database"`
}

Attributes:

  • PipeName
  • CreateTime
  • Version
  • Database
var IClientRPCServiceHandshakeArgs_Info_DEFAULT *TSyncIdentityInfo

func NewTSyncIdentityInfo added in v1.1.5

func NewTSyncIdentityInfo() *TSyncIdentityInfo

func (*TSyncIdentityInfo) Equals added in v1.1.5

func (p *TSyncIdentityInfo) Equals(other *TSyncIdentityInfo) bool

func (*TSyncIdentityInfo) GetCreateTime added in v1.1.5

func (p *TSyncIdentityInfo) GetCreateTime() int64

func (*TSyncIdentityInfo) GetDatabase added in v1.1.5

func (p *TSyncIdentityInfo) GetDatabase() string

func (*TSyncIdentityInfo) GetPipeName added in v1.1.5

func (p *TSyncIdentityInfo) GetPipeName() string

func (*TSyncIdentityInfo) GetVersion added in v1.1.5

func (p *TSyncIdentityInfo) GetVersion() string

func (*TSyncIdentityInfo) Read added in v1.1.5

func (p *TSyncIdentityInfo) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSyncIdentityInfo) ReadField1 added in v1.1.5

func (p *TSyncIdentityInfo) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSyncIdentityInfo) ReadField2 added in v1.1.5

func (p *TSyncIdentityInfo) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSyncIdentityInfo) ReadField3 added in v1.1.5

func (p *TSyncIdentityInfo) ReadField3(ctx context.Context, iprot thrift.TProtocol) error

func (*TSyncIdentityInfo) ReadField4 added in v1.1.5

func (p *TSyncIdentityInfo) ReadField4(ctx context.Context, iprot thrift.TProtocol) error

func (*TSyncIdentityInfo) String added in v1.1.5

func (p *TSyncIdentityInfo) String() string

func (*TSyncIdentityInfo) Write added in v1.1.5

func (p *TSyncIdentityInfo) Write(ctx context.Context, oprot thrift.TProtocol) error

type TSyncTransportMetaInfo added in v1.1.5

type TSyncTransportMetaInfo struct {
	FileName   string `thrift:"fileName,1,required" db:"fileName" json:"fileName"`
	StartIndex int64  `thrift:"startIndex,2,required" db:"startIndex" json:"startIndex"`
}

Attributes:

  • FileName
  • StartIndex
var IClientRPCServiceSendFileArgs_MetaInfo_DEFAULT *TSyncTransportMetaInfo

func NewTSyncTransportMetaInfo added in v1.1.5

func NewTSyncTransportMetaInfo() *TSyncTransportMetaInfo

func (*TSyncTransportMetaInfo) Equals added in v1.1.5

func (*TSyncTransportMetaInfo) GetFileName added in v1.1.5

func (p *TSyncTransportMetaInfo) GetFileName() string

func (*TSyncTransportMetaInfo) GetStartIndex added in v1.1.5

func (p *TSyncTransportMetaInfo) GetStartIndex() int64

func (*TSyncTransportMetaInfo) Read added in v1.1.5

func (*TSyncTransportMetaInfo) ReadField1 added in v1.1.5

func (p *TSyncTransportMetaInfo) ReadField1(ctx context.Context, iprot thrift.TProtocol) error

func (*TSyncTransportMetaInfo) ReadField2 added in v1.1.5

func (p *TSyncTransportMetaInfo) ReadField2(ctx context.Context, iprot thrift.TProtocol) error

func (*TSyncTransportMetaInfo) String added in v1.1.5

func (p *TSyncTransportMetaInfo) String() string

func (*TSyncTransportMetaInfo) Write added in v1.1.5

Jump to

Keyboard shortcuts

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