rpc

package
v0.14.0-preview1 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2022 License: Apache-2.0 Imports: 7 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var GoUnusedProtection__ int
View Source 
var ServerProperties_IsReadOnly_DEFAULT bool
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 TSCloseOperationReq_QueryId_DEFAULT int64
View Source 
var TSCloseOperationReq_StatementId_DEFAULT int64
View Source 
var TSCreateAlignedTimeseriesReq_MeasurementAlias_DEFAULT []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_OperationType_DEFAULT string
View Source 
var TSExecuteStatementResp_QueryId_DEFAULT int64
View Source 
var TSExecuteStatementResp_SgColumns_DEFAULT []string
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 TSFetchResultsReq_Timeout_DEFAULT int64
View Source 
var TSIServiceRequestStatementIdResult_Success_DEFAULT int64
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 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 TSOpenSessionReq_Configuration_DEFAULT map[string]string
View Source 
var TSOpenSessionReq_Password_DEFAULT string
View Source 
var TSOpenSessionReq_Username_DEFAULT string
View Source 
var TSOpenSessionResp_Configuration_DEFAULT map[string]string
View Source 
var TSOpenSessionResp_SessionId_DEFAULT int64
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 TSRawDataQueryReq_EnableRedirectQuery_DEFAULT bool
View Source 
var TSRawDataQueryReq_FetchSize_DEFAULT int32
View Source 
var TSRawDataQueryReq_JdbcQuery_DEFAULT bool
View Source 
var TSStatus_Message_DEFAULT string
View Source 
var TSStatus_SubStatus_DEFAULT []*TSStatus
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 EndPoint 

type EndPoint struct {
	IP   string `thrift:"ip,1,required" db:"ip" json:"ip"`
	Port int32  `thrift:"port,2,required" db:"port" json:"port"`
}

Attributes:

  • IP
  • Port
var TSStatus_RedirectNode_DEFAULT *EndPoint

func NewEndPoint 

func NewEndPoint() *EndPoint

func (*EndPoint) Equals added in v0.12.1 

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

func (*EndPoint) GetIP 

func (p *EndPoint) GetIP() string

func (*EndPoint) GetPort 

func (p *EndPoint) GetPort() int32

func (*EndPoint) Read 

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

func (*EndPoint) ReadField1 

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

func (*EndPoint) ReadField2 

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

func (*EndPoint) String 

func (p *EndPoint) String() string

func (*EndPoint) Write 

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

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"`
}

Attributes:

  • Version
  • SupportedTimeAggregationOperations
  • TimestampPrecision
  • MaxConcurrentClientNum
  • WatermarkSecretKey
  • WatermarkBitString
  • WatermarkParamMarkRate
  • WatermarkParamMaxRightBit
  • ThriftMaxFrameSize
  • IsReadOnly
var TSIServiceGetPropertiesResult_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) GetIsReadOnly added in v0.13.0 

func (p *ServerProperties) GetIsReadOnly() bool

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) IsSetIsReadOnly added in v0.13.0 

func (p *ServerProperties) IsSetIsReadOnly() 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) 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 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 TSIServiceAppendSchemaTemplateArgs_Req_DEFAULT *TSAppendSchemaTemplateReq

func NewTSAppendSchemaTemplateReq added in v0.13.0 

func NewTSAppendSchemaTemplateReq() *TSAppendSchemaTemplateReq

func (*TSAppendSchemaTemplateReq) Equals added in v0.13.0 

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

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 (p *TSAppendSchemaTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 TSIServiceCancelOperationArgs_Req_DEFAULT *TSCancelOperationReq

func NewTSCancelOperationReq 

func NewTSCancelOperationReq() *TSCancelOperationReq

func (*TSCancelOperationReq) Equals added in v0.12.1 

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

func (*TSCancelOperationReq) GetQueryId 

func (p *TSCancelOperationReq) GetQueryId() int64

func (*TSCancelOperationReq) GetSessionId 

func (p *TSCancelOperationReq) GetSessionId() int64

func (*TSCancelOperationReq) Read 

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

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 

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

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 TSIServiceCloseOperationArgs_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 (p *TSCloseOperationReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

type TSCloseSessionReq 

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

Attributes:

  • SessionId
var TSIServiceCloseSessionArgs_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 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"`
}

Attributes:

  • SessionId
  • PrefixPath
  • Measurements
  • DataTypes
  • Encodings
  • Compressors
  • MeasurementAlias
var TSIServiceCreateAlignedTimeseriesArgs_Req_DEFAULT *TSCreateAlignedTimeseriesReq

func NewTSCreateAlignedTimeseriesReq added in v0.13.0 

func NewTSCreateAlignedTimeseriesReq() *TSCreateAlignedTimeseriesReq

func (*TSCreateAlignedTimeseriesReq) Equals added in v0.13.0 

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

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) IsSetMeasurementAlias added in v0.13.0 

func (p *TSCreateAlignedTimeseriesReq) IsSetMeasurementAlias() bool

func (*TSCreateAlignedTimeseriesReq) Read added in v0.13.0 

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

func (*TSCreateAlignedTimeseriesReq) ReadField1 added in v0.13.0 

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

func (*TSCreateAlignedTimeseriesReq) ReadField2 added in v0.13.0 

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

func (*TSCreateAlignedTimeseriesReq) ReadField3 added in v0.13.0 

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

func (*TSCreateAlignedTimeseriesReq) ReadField4 added in v0.13.0 

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

func (*TSCreateAlignedTimeseriesReq) ReadField5 added in v0.13.0 

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

func (*TSCreateAlignedTimeseriesReq) ReadField6 added in v0.13.0 

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

func (*TSCreateAlignedTimeseriesReq) ReadField7 added in v0.13.0 

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

func (*TSCreateAlignedTimeseriesReq) String added in v0.13.0 

func (p *TSCreateAlignedTimeseriesReq) String() string

func (*TSCreateAlignedTimeseriesReq) Write added in v0.13.0 

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

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 TSIServiceCreateMultiTimeseriesArgs_Req_DEFAULT *TSCreateMultiTimeseriesReq

func NewTSCreateMultiTimeseriesReq 

func NewTSCreateMultiTimeseriesReq() *TSCreateMultiTimeseriesReq

func (*TSCreateMultiTimeseriesReq) Equals added in v0.12.1 

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

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 (p *TSCreateMultiTimeseriesReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 TSIServiceCreateSchemaTemplateArgs_Req_DEFAULT *TSCreateSchemaTemplateReq

func NewTSCreateSchemaTemplateReq added in v0.13.0 

func NewTSCreateSchemaTemplateReq() *TSCreateSchemaTemplateReq

func (*TSCreateSchemaTemplateReq) Equals added in v0.13.0 

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

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 (p *TSCreateSchemaTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 TSIServiceCreateTimeseriesArgs_Req_DEFAULT *TSCreateTimeseriesReq

func NewTSCreateTimeseriesReq 

func NewTSCreateTimeseriesReq() *TSCreateTimeseriesReq

func (*TSCreateTimeseriesReq) Equals added in v0.12.1 

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

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 (p *TSCreateTimeseriesReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 TSIServiceDeleteDataArgs_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 TSIServiceDropSchemaTemplateArgs_Req_DEFAULT *TSDropSchemaTemplateReq

func NewTSDropSchemaTemplateReq added in v0.13.0 

func NewTSDropSchemaTemplateReq() *TSDropSchemaTemplateReq

func (*TSDropSchemaTemplateReq) Equals added in v0.13.0 

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

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 (p *TSDropSchemaTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 TSIServiceExecuteBatchStatementArgs_Req_DEFAULT *TSExecuteBatchStatementReq

func NewTSExecuteBatchStatementReq 

func NewTSExecuteBatchStatementReq() *TSExecuteBatchStatementReq

func (*TSExecuteBatchStatementReq) Equals added in v0.12.1 

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

func (*TSExecuteBatchStatementReq) GetSessionId 

func (p *TSExecuteBatchStatementReq) GetSessionId() int64

func (*TSExecuteBatchStatementReq) GetStatements 

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

func (*TSExecuteBatchStatementReq) Read 

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

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 

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

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 TSIServiceExecuteQueryStatementArgs_Req_DEFAULT *TSExecuteStatementReq
var TSIServiceExecuteStatementArgs_Req_DEFAULT *TSExecuteStatementReq
var TSIServiceExecuteUpdateStatementArgs_Req_DEFAULT *TSExecuteStatementReq

func NewTSExecuteStatementReq 

func NewTSExecuteStatementReq() *TSExecuteStatementReq

func (*TSExecuteStatementReq) Equals added in v0.12.1 

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

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 (p *TSExecuteStatementReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

type TSExecuteStatementResp 

type TSExecuteStatementResp struct {
	Status               *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"`
}

Attributes:

  • Status
  • QueryId
  • Columns
  • OperationType
  • IgnoreTimeStamp
  • DataTypeList
  • QueryDataSet
  • NonAlignQueryDataSet
  • ColumnNameIndexMap
  • SgColumns
  • AliasColumns
  • TracingInfo
var TSIServiceExecuteLastDataQueryResult_Success_DEFAULT *TSExecuteStatementResp
var TSIServiceExecuteQueryStatementResult_Success_DEFAULT *TSExecuteStatementResp
var TSIServiceExecuteRawDataQueryResult_Success_DEFAULT *TSExecuteStatementResp
var TSIServiceExecuteStatementResult_Success_DEFAULT *TSExecuteStatementResp
var TSIServiceExecuteUpdateStatementResult_Success_DEFAULT *TSExecuteStatementResp

func NewTSExecuteStatementResp 

func NewTSExecuteStatementResp() *TSExecuteStatementResp

func (*TSExecuteStatementResp) Equals added in v0.12.1 

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

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) 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) GetSgColumns added in v0.13.0 

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

func (*TSExecuteStatementResp) GetStatus 

func (p *TSExecuteStatementResp) GetStatus() *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) 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) 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 (p *TSExecuteStatementResp) Read(ctx context.Context, iprot thrift.TProtocol) error

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) 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 

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

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 TSIServiceFetchMetadataArgs_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 (p *TSFetchMetadataReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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         *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 TSIServiceFetchMetadataResult_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() *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 (p *TSFetchMetadataResp) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 TSIServiceFetchResultsArgs_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               *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"`
}

Attributes:

  • Status
  • HasResultSet
  • IsAlign
  • QueryDataSet
  • NonAlignQueryDataSet
var TSIServiceFetchResultsResult_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) GetNonAlignQueryDataSet 

func (p *TSFetchResultsResp) GetNonAlignQueryDataSet() *TSQueryNonAlignDataSet

func (*TSFetchResultsResp) GetQueryDataSet 

func (p *TSFetchResultsResp) GetQueryDataSet() *TSQueryDataSet

func (*TSFetchResultsResp) GetStatus 

func (p *TSFetchResultsResp) GetStatus() *TSStatus

func (*TSFetchResultsResp) IsSetNonAlignQueryDataSet 

func (p *TSFetchResultsResp) IsSetNonAlignQueryDataSet() bool

func (*TSFetchResultsResp) IsSetQueryDataSet 

func (p *TSFetchResultsResp) IsSetQueryDataSet() bool

func (*TSFetchResultsResp) IsSetStatus 

func (p *TSFetchResultsResp) IsSetStatus() bool

func (*TSFetchResultsResp) Read 

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

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) 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 (p *TSGetOperationStatusReq) Equals(other *TSGetOperationStatusReq) bool

func (*TSGetOperationStatusReq) GetQueryId 

func (p *TSGetOperationStatusReq) GetQueryId() int64

func (*TSGetOperationStatusReq) GetSessionId 

func (p *TSGetOperationStatusReq) GetSessionId() int64

func (*TSGetOperationStatusReq) Read 

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

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 

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

type TSGetTimeZoneResp 

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

Attributes:

  • Status
  • TimeZone
var TSIServiceGetTimeZoneResult_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() *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 TSIService 

type TSIService interface {
	// Parameters:
	//  - Req
	OpenSession(ctx context.Context, req *TSOpenSessionReq) (_r *TSOpenSessionResp, _err error)
	// Parameters:
	//  - Req
	CloseSession(ctx context.Context, req *TSCloseSessionReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	ExecuteStatement(ctx context.Context, req *TSExecuteStatementReq) (_r *TSExecuteStatementResp, _err error)
	// Parameters:
	//  - Req
	ExecuteBatchStatement(ctx context.Context, req *TSExecuteBatchStatementReq) (_r *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 *TSStatus, _err error)
	// Parameters:
	//  - Req
	CloseOperation(ctx context.Context, req *TSCloseOperationReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - SessionId
	GetTimeZone(ctx context.Context, sessionId int64) (_r *TSGetTimeZoneResp, _err error)
	// Parameters:
	//  - Req
	SetTimeZone(ctx context.Context, req *TSSetTimeZoneReq) (_r *TSStatus, _err error)
	GetProperties(ctx context.Context) (_r *ServerProperties, _err error)
	// Parameters:
	//  - SessionId
	//  - StorageGroup
	SetStorageGroup(ctx context.Context, sessionId int64, storageGroup string) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	CreateTimeseries(ctx context.Context, req *TSCreateTimeseriesReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	CreateAlignedTimeseries(ctx context.Context, req *TSCreateAlignedTimeseriesReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	CreateMultiTimeseries(ctx context.Context, req *TSCreateMultiTimeseriesReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - SessionId
	//  - Path
	DeleteTimeseries(ctx context.Context, sessionId int64, path []string) (_r *TSStatus, _err error)
	// Parameters:
	//  - SessionId
	//  - StorageGroup
	DeleteStorageGroups(ctx context.Context, sessionId int64, storageGroup []string) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertRecord(ctx context.Context, req *TSInsertRecordReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertStringRecord(ctx context.Context, req *TSInsertStringRecordReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertTablet(ctx context.Context, req *TSInsertTabletReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertTablets(ctx context.Context, req *TSInsertTabletsReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertRecords(ctx context.Context, req *TSInsertRecordsReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertRecordsOfOneDevice(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertStringRecordsOfOneDevice(ctx context.Context, req *TSInsertStringRecordsOfOneDeviceReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	InsertStringRecords(ctx context.Context, req *TSInsertStringRecordsReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	TestInsertTablet(ctx context.Context, req *TSInsertTabletReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	TestInsertTablets(ctx context.Context, req *TSInsertTabletsReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	TestInsertRecord(ctx context.Context, req *TSInsertRecordReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	TestInsertStringRecord(ctx context.Context, req *TSInsertStringRecordReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	TestInsertRecords(ctx context.Context, req *TSInsertRecordsReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	TestInsertRecordsOfOneDevice(ctx context.Context, req *TSInsertRecordsOfOneDeviceReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	TestInsertStringRecords(ctx context.Context, req *TSInsertStringRecordsReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	DeleteData(ctx context.Context, req *TSDeleteDataReq) (_r *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:
	//  - SessionId
	RequestStatementId(ctx context.Context, sessionId int64) (_r int64, _err error)
	// Parameters:
	//  - Req
	CreateSchemaTemplate(ctx context.Context, req *TSCreateSchemaTemplateReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	AppendSchemaTemplate(ctx context.Context, req *TSAppendSchemaTemplateReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	PruneSchemaTemplate(ctx context.Context, req *TSPruneSchemaTemplateReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	QuerySchemaTemplate(ctx context.Context, req *TSQueryTemplateReq) (_r *TSQueryTemplateResp, _err error)
	// Parameters:
	//  - Req
	SetSchemaTemplate(ctx context.Context, req *TSSetSchemaTemplateReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	UnsetSchemaTemplate(ctx context.Context, req *TSUnsetSchemaTemplateReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	SetUsingTemplate(ctx context.Context, req *TSSetUsingTemplateReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - SessionId
	//  - TemplateName
	//  - PrefixPath
	UnsetUsingTemplate(ctx context.Context, sessionId int64, templateName string, prefixPath string) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	DropSchemaTemplate(ctx context.Context, req *TSDropSchemaTemplateReq) (_r *TSStatus, _err error)
	// Parameters:
	//  - Req
	ExecuteOperationSync(ctx context.Context, req *TSOperationSyncWriteReq) (_r *TSStatus, _err error)
}

type TSIServiceAppendSchemaTemplateArgs added in v0.13.0 

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

Attributes:

  • Req

func NewTSIServiceAppendSchemaTemplateArgs added in v0.13.0 

func NewTSIServiceAppendSchemaTemplateArgs() *TSIServiceAppendSchemaTemplateArgs

func (*TSIServiceAppendSchemaTemplateArgs) GetReq added in v0.13.0 

func (p *TSIServiceAppendSchemaTemplateArgs) GetReq() *TSAppendSchemaTemplateReq

func (*TSIServiceAppendSchemaTemplateArgs) IsSetReq added in v0.13.0 

func (p *TSIServiceAppendSchemaTemplateArgs) IsSetReq() bool

func (*TSIServiceAppendSchemaTemplateArgs) Read added in v0.13.0 

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

func (*TSIServiceAppendSchemaTemplateArgs) ReadField1 added in v0.13.0 

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

func (*TSIServiceAppendSchemaTemplateArgs) String added in v0.13.0 

func (p *TSIServiceAppendSchemaTemplateArgs) String() string

func (*TSIServiceAppendSchemaTemplateArgs) Write added in v0.13.0 

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

type TSIServiceAppendSchemaTemplateResult added in v0.13.0 

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

Attributes:

  • Success

func NewTSIServiceAppendSchemaTemplateResult added in v0.13.0 

func NewTSIServiceAppendSchemaTemplateResult() *TSIServiceAppendSchemaTemplateResult

func (*TSIServiceAppendSchemaTemplateResult) GetSuccess added in v0.13.0 

func (p *TSIServiceAppendSchemaTemplateResult) GetSuccess() *TSStatus

func (*TSIServiceAppendSchemaTemplateResult) IsSetSuccess added in v0.13.0 

func (p *TSIServiceAppendSchemaTemplateResult) IsSetSuccess() bool

func (*TSIServiceAppendSchemaTemplateResult) Read added in v0.13.0 

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

func (*TSIServiceAppendSchemaTemplateResult) ReadField0 added in v0.13.0 

func (p *TSIServiceAppendSchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceAppendSchemaTemplateResult) String added in v0.13.0 

func (p *TSIServiceAppendSchemaTemplateResult) String() string

func (*TSIServiceAppendSchemaTemplateResult) Write added in v0.13.0 

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

type TSIServiceCancelOperationArgs 

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

Attributes:

  • Req

func NewTSIServiceCancelOperationArgs 

func NewTSIServiceCancelOperationArgs() *TSIServiceCancelOperationArgs

func (*TSIServiceCancelOperationArgs) GetReq 

func (p *TSIServiceCancelOperationArgs) GetReq() *TSCancelOperationReq

func (*TSIServiceCancelOperationArgs) IsSetReq 

func (p *TSIServiceCancelOperationArgs) IsSetReq() bool

func (*TSIServiceCancelOperationArgs) Read 

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

func (*TSIServiceCancelOperationArgs) ReadField1 

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

func (*TSIServiceCancelOperationArgs) String 

func (p *TSIServiceCancelOperationArgs) String() string

func (*TSIServiceCancelOperationArgs) Write 

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

type TSIServiceCancelOperationResult 

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

Attributes:

  • Success

func NewTSIServiceCancelOperationResult 

func NewTSIServiceCancelOperationResult() *TSIServiceCancelOperationResult

func (*TSIServiceCancelOperationResult) GetSuccess 

func (p *TSIServiceCancelOperationResult) GetSuccess() *TSStatus

func (*TSIServiceCancelOperationResult) IsSetSuccess 

func (p *TSIServiceCancelOperationResult) IsSetSuccess() bool

func (*TSIServiceCancelOperationResult) Read 

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

func (*TSIServiceCancelOperationResult) ReadField0 

func (p *TSIServiceCancelOperationResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceCancelOperationResult) String 

func (p *TSIServiceCancelOperationResult) String() string

func (*TSIServiceCancelOperationResult) Write 

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

type TSIServiceClient 

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

func NewTSIServiceClient 

func NewTSIServiceClient(c thrift.TClient) *TSIServiceClient

func NewTSIServiceClientFactory 

func NewTSIServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *TSIServiceClient

func NewTSIServiceClientProtocol 

func NewTSIServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *TSIServiceClient

func (*TSIServiceClient) AppendSchemaTemplate added in v0.13.0 

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

Parameters:

  • Req

func (*TSIServiceClient) CancelOperation 

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

Parameters:

  • Req

func (*TSIServiceClient) Client_ 

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

func (*TSIServiceClient) CloseOperation 

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

Parameters:

  • Req

func (*TSIServiceClient) CloseSession 

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

Parameters:

  • Req

func (*TSIServiceClient) CreateAlignedTimeseries added in v0.13.0 

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

Parameters:

  • Req

func (*TSIServiceClient) CreateMultiTimeseries 

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

Parameters:

  • Req

func (*TSIServiceClient) CreateSchemaTemplate added in v0.13.0 

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

Parameters:

  • Req

func (*TSIServiceClient) CreateTimeseries 

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

Parameters:

  • Req

func (*TSIServiceClient) DeleteData 

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

Parameters:

  • Req

func (*TSIServiceClient) DeleteStorageGroups 

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

Parameters:

  • SessionId
  • StorageGroup

func (*TSIServiceClient) DeleteTimeseries 

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

Parameters:

  • SessionId
  • Path

func (*TSIServiceClient) DropSchemaTemplate added in v0.13.0 

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

Parameters:

  • Req

func (*TSIServiceClient) ExecuteBatchStatement 

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

Parameters:

  • Req

func (*TSIServiceClient) ExecuteLastDataQuery added in v0.13.0 

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

Parameters:

  • Req

func (*TSIServiceClient) ExecuteOperationSync added in v0.13.0 

func (p *TSIServiceClient) ExecuteOperationSync(ctx context.Context, req *TSOperationSyncWriteReq) (_r *TSStatus, _err error)

Parameters:

  • Req

func (*TSIServiceClient) ExecuteQueryStatement 

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

Parameters:

  • Req

func (*TSIServiceClient) ExecuteRawDataQuery 

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

Parameters:

  • Req

func (*TSIServiceClient) ExecuteStatement 

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

Parameters:

  • Req

func (*TSIServiceClient) ExecuteUpdateStatement 

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

Parameters:

  • Req

func (*TSIServiceClient) FetchMetadata 

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

Parameters:

  • Req

func (*TSIServiceClient) FetchResults 

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

Parameters:

  • Req

func (*TSIServiceClient) GetProperties 

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

func (*TSIServiceClient) GetTimeZone 

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

Parameters:

  • SessionId

func (*TSIServiceClient) InsertRecord 

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

Parameters:

  • Req

func (*TSIServiceClient) InsertRecords 

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

Parameters:

  • Req

func (*TSIServiceClient) InsertRecordsOfOneDevice 

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

Parameters:

  • Req

func (*TSIServiceClient) InsertStringRecord 

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

Parameters:

  • Req

func (*TSIServiceClient) InsertStringRecords 

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

Parameters:

  • Req

func (*TSIServiceClient) InsertStringRecordsOfOneDevice added in v0.13.0 

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

Parameters:

  • Req

func (*TSIServiceClient) InsertTablet 

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

Parameters:

  • Req

func (*TSIServiceClient) InsertTablets 

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

Parameters:

  • Req

func (*TSIServiceClient) LastResponseMeta_ added in v0.12.1 

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

func (*TSIServiceClient) OpenSession 

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

Parameters:

  • Req

func (*TSIServiceClient) PruneSchemaTemplate added in v0.13.0 

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

Parameters:

  • Req

func (*TSIServiceClient) QuerySchemaTemplate added in v0.13.0 

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

Parameters:

  • Req

func (*TSIServiceClient) RequestStatementId 

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

Parameters:

  • SessionId

func (*TSIServiceClient) SetLastResponseMeta_ added in v0.12.1 

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

func (*TSIServiceClient) SetSchemaTemplate added in v0.13.0 

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

Parameters:

  • Req

func (*TSIServiceClient) SetStorageGroup 

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

Parameters:

  • SessionId
  • StorageGroup

func (*TSIServiceClient) SetTimeZone 

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

Parameters:

  • Req

func (*TSIServiceClient) SetUsingTemplate added in v0.13.0 

func (p *TSIServiceClient) SetUsingTemplate(ctx context.Context, req *TSSetUsingTemplateReq) (_r *TSStatus, _err error)

Parameters:

  • Req

func (*TSIServiceClient) TestInsertRecord 

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

Parameters:

  • Req

func (*TSIServiceClient) TestInsertRecords 

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

Parameters:

  • Req

func (*TSIServiceClient) TestInsertRecordsOfOneDevice 

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

Parameters:

  • Req

func (*TSIServiceClient) TestInsertStringRecord 

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

Parameters:

  • Req

func (*TSIServiceClient) TestInsertStringRecords 

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

Parameters:

  • Req

func (*TSIServiceClient) TestInsertTablet 

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

Parameters:

  • Req

func (*TSIServiceClient) TestInsertTablets 

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

Parameters:

  • Req

func (*TSIServiceClient) UnsetSchemaTemplate added in v0.13.0 

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

Parameters:

  • Req

func (*TSIServiceClient) UnsetUsingTemplate added in v0.13.0 

func (p *TSIServiceClient) UnsetUsingTemplate(ctx context.Context, sessionId int64, templateName string, prefixPath string) (_r *TSStatus, _err error)

Parameters:

  • SessionId
  • TemplateName
  • PrefixPath

type TSIServiceCloseOperationArgs 

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

Attributes:

  • Req

func NewTSIServiceCloseOperationArgs 

func NewTSIServiceCloseOperationArgs() *TSIServiceCloseOperationArgs

func (*TSIServiceCloseOperationArgs) GetReq 

func (p *TSIServiceCloseOperationArgs) GetReq() *TSCloseOperationReq

func (*TSIServiceCloseOperationArgs) IsSetReq 

func (p *TSIServiceCloseOperationArgs) IsSetReq() bool

func (*TSIServiceCloseOperationArgs) Read 

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

func (*TSIServiceCloseOperationArgs) ReadField1 

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

func (*TSIServiceCloseOperationArgs) String 

func (p *TSIServiceCloseOperationArgs) String() string

func (*TSIServiceCloseOperationArgs) Write 

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

type TSIServiceCloseOperationResult 

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

Attributes:

  • Success

func NewTSIServiceCloseOperationResult 

func NewTSIServiceCloseOperationResult() *TSIServiceCloseOperationResult

func (*TSIServiceCloseOperationResult) GetSuccess 

func (p *TSIServiceCloseOperationResult) GetSuccess() *TSStatus

func (*TSIServiceCloseOperationResult) IsSetSuccess 

func (p *TSIServiceCloseOperationResult) IsSetSuccess() bool

func (*TSIServiceCloseOperationResult) Read 

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

func (*TSIServiceCloseOperationResult) ReadField0 

func (p *TSIServiceCloseOperationResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceCloseOperationResult) String 

func (p *TSIServiceCloseOperationResult) String() string

func (*TSIServiceCloseOperationResult) Write 

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

type TSIServiceCloseSessionArgs 

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

Attributes:

  • Req

func NewTSIServiceCloseSessionArgs 

func NewTSIServiceCloseSessionArgs() *TSIServiceCloseSessionArgs

func (*TSIServiceCloseSessionArgs) GetReq 

func (p *TSIServiceCloseSessionArgs) GetReq() *TSCloseSessionReq

func (*TSIServiceCloseSessionArgs) IsSetReq 

func (p *TSIServiceCloseSessionArgs) IsSetReq() bool

func (*TSIServiceCloseSessionArgs) Read 

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

func (*TSIServiceCloseSessionArgs) ReadField1 

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

func (*TSIServiceCloseSessionArgs) String 

func (p *TSIServiceCloseSessionArgs) String() string

func (*TSIServiceCloseSessionArgs) Write 

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

type TSIServiceCloseSessionResult 

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

Attributes:

  • Success

func NewTSIServiceCloseSessionResult 

func NewTSIServiceCloseSessionResult() *TSIServiceCloseSessionResult

func (*TSIServiceCloseSessionResult) GetSuccess 

func (p *TSIServiceCloseSessionResult) GetSuccess() *TSStatus

func (*TSIServiceCloseSessionResult) IsSetSuccess 

func (p *TSIServiceCloseSessionResult) IsSetSuccess() bool

func (*TSIServiceCloseSessionResult) Read 

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

func (*TSIServiceCloseSessionResult) ReadField0 

func (p *TSIServiceCloseSessionResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceCloseSessionResult) String 

func (p *TSIServiceCloseSessionResult) String() string

func (*TSIServiceCloseSessionResult) Write 

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

type TSIServiceCreateAlignedTimeseriesArgs added in v0.13.0 

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

Attributes:

  • Req

func NewTSIServiceCreateAlignedTimeseriesArgs added in v0.13.0 

func NewTSIServiceCreateAlignedTimeseriesArgs() *TSIServiceCreateAlignedTimeseriesArgs

func (*TSIServiceCreateAlignedTimeseriesArgs) GetReq added in v0.13.0 

func (p *TSIServiceCreateAlignedTimeseriesArgs) GetReq() *TSCreateAlignedTimeseriesReq

func (*TSIServiceCreateAlignedTimeseriesArgs) IsSetReq added in v0.13.0 

func (p *TSIServiceCreateAlignedTimeseriesArgs) IsSetReq() bool

func (*TSIServiceCreateAlignedTimeseriesArgs) Read added in v0.13.0 

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

func (*TSIServiceCreateAlignedTimeseriesArgs) ReadField1 added in v0.13.0 

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

func (*TSIServiceCreateAlignedTimeseriesArgs) String added in v0.13.0 

func (p *TSIServiceCreateAlignedTimeseriesArgs) String() string

func (*TSIServiceCreateAlignedTimeseriesArgs) Write added in v0.13.0 

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

type TSIServiceCreateAlignedTimeseriesResult added in v0.13.0 

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

Attributes:

  • Success

func NewTSIServiceCreateAlignedTimeseriesResult added in v0.13.0 

func NewTSIServiceCreateAlignedTimeseriesResult() *TSIServiceCreateAlignedTimeseriesResult

func (*TSIServiceCreateAlignedTimeseriesResult) GetSuccess added in v0.13.0 

func (p *TSIServiceCreateAlignedTimeseriesResult) GetSuccess() *TSStatus

func (*TSIServiceCreateAlignedTimeseriesResult) IsSetSuccess added in v0.13.0 

func (p *TSIServiceCreateAlignedTimeseriesResult) IsSetSuccess() bool

func (*TSIServiceCreateAlignedTimeseriesResult) Read added in v0.13.0 

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

func (*TSIServiceCreateAlignedTimeseriesResult) ReadField0 added in v0.13.0 

func (p *TSIServiceCreateAlignedTimeseriesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceCreateAlignedTimeseriesResult) String added in v0.13.0 

func (p *TSIServiceCreateAlignedTimeseriesResult) String() string

func (*TSIServiceCreateAlignedTimeseriesResult) Write added in v0.13.0 

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

type TSIServiceCreateMultiTimeseriesArgs 

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

Attributes:

  • Req

func NewTSIServiceCreateMultiTimeseriesArgs 

func NewTSIServiceCreateMultiTimeseriesArgs() *TSIServiceCreateMultiTimeseriesArgs

func (*TSIServiceCreateMultiTimeseriesArgs) GetReq 

func (p *TSIServiceCreateMultiTimeseriesArgs) GetReq() *TSCreateMultiTimeseriesReq

func (*TSIServiceCreateMultiTimeseriesArgs) IsSetReq 

func (p *TSIServiceCreateMultiTimeseriesArgs) IsSetReq() bool

func (*TSIServiceCreateMultiTimeseriesArgs) Read 

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

func (*TSIServiceCreateMultiTimeseriesArgs) ReadField1 

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

func (*TSIServiceCreateMultiTimeseriesArgs) String 

func (p *TSIServiceCreateMultiTimeseriesArgs) String() string

func (*TSIServiceCreateMultiTimeseriesArgs) Write 

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

type TSIServiceCreateMultiTimeseriesResult 

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

Attributes:

  • Success

func NewTSIServiceCreateMultiTimeseriesResult 

func NewTSIServiceCreateMultiTimeseriesResult() *TSIServiceCreateMultiTimeseriesResult

func (*TSIServiceCreateMultiTimeseriesResult) GetSuccess 

func (p *TSIServiceCreateMultiTimeseriesResult) GetSuccess() *TSStatus

func (*TSIServiceCreateMultiTimeseriesResult) IsSetSuccess 

func (p *TSIServiceCreateMultiTimeseriesResult) IsSetSuccess() bool

func (*TSIServiceCreateMultiTimeseriesResult) Read 

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

func (*TSIServiceCreateMultiTimeseriesResult) ReadField0 

func (p *TSIServiceCreateMultiTimeseriesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceCreateMultiTimeseriesResult) String 

func (p *TSIServiceCreateMultiTimeseriesResult) String() string

func (*TSIServiceCreateMultiTimeseriesResult) Write 

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

type TSIServiceCreateSchemaTemplateArgs added in v0.13.0 

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

Attributes:

  • Req

func NewTSIServiceCreateSchemaTemplateArgs added in v0.13.0 

func NewTSIServiceCreateSchemaTemplateArgs() *TSIServiceCreateSchemaTemplateArgs

func (*TSIServiceCreateSchemaTemplateArgs) GetReq added in v0.13.0 

func (p *TSIServiceCreateSchemaTemplateArgs) GetReq() *TSCreateSchemaTemplateReq

func (*TSIServiceCreateSchemaTemplateArgs) IsSetReq added in v0.13.0 

func (p *TSIServiceCreateSchemaTemplateArgs) IsSetReq() bool

func (*TSIServiceCreateSchemaTemplateArgs) Read added in v0.13.0 

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

func (*TSIServiceCreateSchemaTemplateArgs) ReadField1 added in v0.13.0 

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

func (*TSIServiceCreateSchemaTemplateArgs) String added in v0.13.0 

func (p *TSIServiceCreateSchemaTemplateArgs) String() string

func (*TSIServiceCreateSchemaTemplateArgs) Write added in v0.13.0 

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

type TSIServiceCreateSchemaTemplateResult added in v0.13.0 

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

Attributes:

  • Success

func NewTSIServiceCreateSchemaTemplateResult added in v0.13.0 

func NewTSIServiceCreateSchemaTemplateResult() *TSIServiceCreateSchemaTemplateResult

func (*TSIServiceCreateSchemaTemplateResult) GetSuccess added in v0.13.0 

func (p *TSIServiceCreateSchemaTemplateResult) GetSuccess() *TSStatus

func (*TSIServiceCreateSchemaTemplateResult) IsSetSuccess added in v0.13.0 

func (p *TSIServiceCreateSchemaTemplateResult) IsSetSuccess() bool

func (*TSIServiceCreateSchemaTemplateResult) Read added in v0.13.0 

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

func (*TSIServiceCreateSchemaTemplateResult) ReadField0 added in v0.13.0 

func (p *TSIServiceCreateSchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceCreateSchemaTemplateResult) String added in v0.13.0 

func (p *TSIServiceCreateSchemaTemplateResult) String() string

func (*TSIServiceCreateSchemaTemplateResult) Write added in v0.13.0 

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

type TSIServiceCreateTimeseriesArgs 

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

Attributes:

  • Req

func NewTSIServiceCreateTimeseriesArgs 

func NewTSIServiceCreateTimeseriesArgs() *TSIServiceCreateTimeseriesArgs

func (*TSIServiceCreateTimeseriesArgs) GetReq 

func (p *TSIServiceCreateTimeseriesArgs) GetReq() *TSCreateTimeseriesReq

func (*TSIServiceCreateTimeseriesArgs) IsSetReq 

func (p *TSIServiceCreateTimeseriesArgs) IsSetReq() bool

func (*TSIServiceCreateTimeseriesArgs) Read 

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

func (*TSIServiceCreateTimeseriesArgs) ReadField1 

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

func (*TSIServiceCreateTimeseriesArgs) String 

func (p *TSIServiceCreateTimeseriesArgs) String() string

func (*TSIServiceCreateTimeseriesArgs) Write 

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

type TSIServiceCreateTimeseriesResult 

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

Attributes:

  • Success

func NewTSIServiceCreateTimeseriesResult 

func NewTSIServiceCreateTimeseriesResult() *TSIServiceCreateTimeseriesResult

func (*TSIServiceCreateTimeseriesResult) GetSuccess 

func (p *TSIServiceCreateTimeseriesResult) GetSuccess() *TSStatus

func (*TSIServiceCreateTimeseriesResult) IsSetSuccess 

func (p *TSIServiceCreateTimeseriesResult) IsSetSuccess() bool

func (*TSIServiceCreateTimeseriesResult) Read 

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

func (*TSIServiceCreateTimeseriesResult) ReadField0 

func (p *TSIServiceCreateTimeseriesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceCreateTimeseriesResult) String 

func (p *TSIServiceCreateTimeseriesResult) String() string

func (*TSIServiceCreateTimeseriesResult) Write 

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

type TSIServiceDeleteDataArgs 

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

Attributes:

  • Req

func NewTSIServiceDeleteDataArgs 

func NewTSIServiceDeleteDataArgs() *TSIServiceDeleteDataArgs

func (*TSIServiceDeleteDataArgs) GetReq 

func (p *TSIServiceDeleteDataArgs) GetReq() *TSDeleteDataReq

func (*TSIServiceDeleteDataArgs) IsSetReq 

func (p *TSIServiceDeleteDataArgs) IsSetReq() bool

func (*TSIServiceDeleteDataArgs) Read 

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

func (*TSIServiceDeleteDataArgs) ReadField1 

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

func (*TSIServiceDeleteDataArgs) String 

func (p *TSIServiceDeleteDataArgs) String() string

func (*TSIServiceDeleteDataArgs) Write 

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

type TSIServiceDeleteDataResult 

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

Attributes:

  • Success

func NewTSIServiceDeleteDataResult 

func NewTSIServiceDeleteDataResult() *TSIServiceDeleteDataResult

func (*TSIServiceDeleteDataResult) GetSuccess 

func (p *TSIServiceDeleteDataResult) GetSuccess() *TSStatus

func (*TSIServiceDeleteDataResult) IsSetSuccess 

func (p *TSIServiceDeleteDataResult) IsSetSuccess() bool

func (*TSIServiceDeleteDataResult) Read 

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

func (*TSIServiceDeleteDataResult) ReadField0 

func (p *TSIServiceDeleteDataResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceDeleteDataResult) String 

func (p *TSIServiceDeleteDataResult) String() string

func (*TSIServiceDeleteDataResult) Write 

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

type TSIServiceDeleteStorageGroupsArgs 

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

Attributes:

  • SessionId
  • StorageGroup

func NewTSIServiceDeleteStorageGroupsArgs 

func NewTSIServiceDeleteStorageGroupsArgs() *TSIServiceDeleteStorageGroupsArgs

func (*TSIServiceDeleteStorageGroupsArgs) GetSessionId 

func (p *TSIServiceDeleteStorageGroupsArgs) GetSessionId() int64

func (*TSIServiceDeleteStorageGroupsArgs) GetStorageGroup 

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

func (*TSIServiceDeleteStorageGroupsArgs) Read 

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

func (*TSIServiceDeleteStorageGroupsArgs) ReadField1 

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

func (*TSIServiceDeleteStorageGroupsArgs) ReadField2 

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

func (*TSIServiceDeleteStorageGroupsArgs) String 

func (p *TSIServiceDeleteStorageGroupsArgs) String() string

func (*TSIServiceDeleteStorageGroupsArgs) Write 

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

type TSIServiceDeleteStorageGroupsResult 

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

Attributes:

  • Success

func NewTSIServiceDeleteStorageGroupsResult 

func NewTSIServiceDeleteStorageGroupsResult() *TSIServiceDeleteStorageGroupsResult

func (*TSIServiceDeleteStorageGroupsResult) GetSuccess 

func (p *TSIServiceDeleteStorageGroupsResult) GetSuccess() *TSStatus

func (*TSIServiceDeleteStorageGroupsResult) IsSetSuccess 

func (p *TSIServiceDeleteStorageGroupsResult) IsSetSuccess() bool

func (*TSIServiceDeleteStorageGroupsResult) Read 

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

func (*TSIServiceDeleteStorageGroupsResult) ReadField0 

func (p *TSIServiceDeleteStorageGroupsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceDeleteStorageGroupsResult) String 

func (p *TSIServiceDeleteStorageGroupsResult) String() string

func (*TSIServiceDeleteStorageGroupsResult) Write 

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

type TSIServiceDeleteTimeseriesArgs 

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

Attributes:

  • SessionId
  • Path

func NewTSIServiceDeleteTimeseriesArgs 

func NewTSIServiceDeleteTimeseriesArgs() *TSIServiceDeleteTimeseriesArgs

func (*TSIServiceDeleteTimeseriesArgs) GetPath 

func (p *TSIServiceDeleteTimeseriesArgs) GetPath() []string

func (*TSIServiceDeleteTimeseriesArgs) GetSessionId 

func (p *TSIServiceDeleteTimeseriesArgs) GetSessionId() int64

func (*TSIServiceDeleteTimeseriesArgs) Read 

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

func (*TSIServiceDeleteTimeseriesArgs) ReadField1 

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

func (*TSIServiceDeleteTimeseriesArgs) ReadField2 

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

func (*TSIServiceDeleteTimeseriesArgs) String 

func (p *TSIServiceDeleteTimeseriesArgs) String() string

func (*TSIServiceDeleteTimeseriesArgs) Write 

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

type TSIServiceDeleteTimeseriesResult 

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

Attributes:

  • Success

func NewTSIServiceDeleteTimeseriesResult 

func NewTSIServiceDeleteTimeseriesResult() *TSIServiceDeleteTimeseriesResult

func (*TSIServiceDeleteTimeseriesResult) GetSuccess 

func (p *TSIServiceDeleteTimeseriesResult) GetSuccess() *TSStatus

func (*TSIServiceDeleteTimeseriesResult) IsSetSuccess 

func (p *TSIServiceDeleteTimeseriesResult) IsSetSuccess() bool

func (*TSIServiceDeleteTimeseriesResult) Read 

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

func (*TSIServiceDeleteTimeseriesResult) ReadField0 

func (p *TSIServiceDeleteTimeseriesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceDeleteTimeseriesResult) String 

func (p *TSIServiceDeleteTimeseriesResult) String() string

func (*TSIServiceDeleteTimeseriesResult) Write 

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

type TSIServiceDropSchemaTemplateArgs added in v0.13.0 

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

Attributes:

  • Req

func NewTSIServiceDropSchemaTemplateArgs added in v0.13.0 

func NewTSIServiceDropSchemaTemplateArgs() *TSIServiceDropSchemaTemplateArgs

func (*TSIServiceDropSchemaTemplateArgs) GetReq added in v0.13.0 

func (p *TSIServiceDropSchemaTemplateArgs) GetReq() *TSDropSchemaTemplateReq

func (*TSIServiceDropSchemaTemplateArgs) IsSetReq added in v0.13.0 

func (p *TSIServiceDropSchemaTemplateArgs) IsSetReq() bool

func (*TSIServiceDropSchemaTemplateArgs) Read added in v0.13.0 

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

func (*TSIServiceDropSchemaTemplateArgs) ReadField1 added in v0.13.0 

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

func (*TSIServiceDropSchemaTemplateArgs) String added in v0.13.0 

func (p *TSIServiceDropSchemaTemplateArgs) String() string

func (*TSIServiceDropSchemaTemplateArgs) Write added in v0.13.0 

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

type TSIServiceDropSchemaTemplateResult added in v0.13.0 

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

Attributes:

  • Success

func NewTSIServiceDropSchemaTemplateResult added in v0.13.0 

func NewTSIServiceDropSchemaTemplateResult() *TSIServiceDropSchemaTemplateResult

func (*TSIServiceDropSchemaTemplateResult) GetSuccess added in v0.13.0 

func (p *TSIServiceDropSchemaTemplateResult) GetSuccess() *TSStatus

func (*TSIServiceDropSchemaTemplateResult) IsSetSuccess added in v0.13.0 

func (p *TSIServiceDropSchemaTemplateResult) IsSetSuccess() bool

func (*TSIServiceDropSchemaTemplateResult) Read added in v0.13.0 

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

func (*TSIServiceDropSchemaTemplateResult) ReadField0 added in v0.13.0 

func (p *TSIServiceDropSchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceDropSchemaTemplateResult) String added in v0.13.0 

func (p *TSIServiceDropSchemaTemplateResult) String() string

func (*TSIServiceDropSchemaTemplateResult) Write added in v0.13.0 

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

type TSIServiceExecuteBatchStatementArgs 

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

Attributes:

  • Req

func NewTSIServiceExecuteBatchStatementArgs 

func NewTSIServiceExecuteBatchStatementArgs() *TSIServiceExecuteBatchStatementArgs

func (*TSIServiceExecuteBatchStatementArgs) GetReq 

func (p *TSIServiceExecuteBatchStatementArgs) GetReq() *TSExecuteBatchStatementReq

func (*TSIServiceExecuteBatchStatementArgs) IsSetReq 

func (p *TSIServiceExecuteBatchStatementArgs) IsSetReq() bool

func (*TSIServiceExecuteBatchStatementArgs) Read 

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

func (*TSIServiceExecuteBatchStatementArgs) ReadField1 

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

func (*TSIServiceExecuteBatchStatementArgs) String 

func (p *TSIServiceExecuteBatchStatementArgs) String() string

func (*TSIServiceExecuteBatchStatementArgs) Write 

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

type TSIServiceExecuteBatchStatementResult 

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

Attributes:

  • Success

func NewTSIServiceExecuteBatchStatementResult 

func NewTSIServiceExecuteBatchStatementResult() *TSIServiceExecuteBatchStatementResult

func (*TSIServiceExecuteBatchStatementResult) GetSuccess 

func (p *TSIServiceExecuteBatchStatementResult) GetSuccess() *TSStatus

func (*TSIServiceExecuteBatchStatementResult) IsSetSuccess 

func (p *TSIServiceExecuteBatchStatementResult) IsSetSuccess() bool

func (*TSIServiceExecuteBatchStatementResult) Read 

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

func (*TSIServiceExecuteBatchStatementResult) ReadField0 

func (p *TSIServiceExecuteBatchStatementResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceExecuteBatchStatementResult) String 

func (p *TSIServiceExecuteBatchStatementResult) String() string

func (*TSIServiceExecuteBatchStatementResult) Write 

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

type TSIServiceExecuteLastDataQueryArgs added in v0.13.0 

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

Attributes:

  • Req

func NewTSIServiceExecuteLastDataQueryArgs added in v0.13.0 

func NewTSIServiceExecuteLastDataQueryArgs() *TSIServiceExecuteLastDataQueryArgs

func (*TSIServiceExecuteLastDataQueryArgs) GetReq added in v0.13.0 

func (p *TSIServiceExecuteLastDataQueryArgs) GetReq() *TSLastDataQueryReq

func (*TSIServiceExecuteLastDataQueryArgs) IsSetReq added in v0.13.0 

func (p *TSIServiceExecuteLastDataQueryArgs) IsSetReq() bool

func (*TSIServiceExecuteLastDataQueryArgs) Read added in v0.13.0 

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

func (*TSIServiceExecuteLastDataQueryArgs) ReadField1 added in v0.13.0 

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

func (*TSIServiceExecuteLastDataQueryArgs) String added in v0.13.0 

func (p *TSIServiceExecuteLastDataQueryArgs) String() string

func (*TSIServiceExecuteLastDataQueryArgs) Write added in v0.13.0 

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

type TSIServiceExecuteLastDataQueryResult added in v0.13.0 

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

Attributes:

  • Success

func NewTSIServiceExecuteLastDataQueryResult added in v0.13.0 

func NewTSIServiceExecuteLastDataQueryResult() *TSIServiceExecuteLastDataQueryResult

func (*TSIServiceExecuteLastDataQueryResult) GetSuccess added in v0.13.0 

func (p *TSIServiceExecuteLastDataQueryResult) GetSuccess() *TSExecuteStatementResp

func (*TSIServiceExecuteLastDataQueryResult) IsSetSuccess added in v0.13.0 

func (p *TSIServiceExecuteLastDataQueryResult) IsSetSuccess() bool

func (*TSIServiceExecuteLastDataQueryResult) Read added in v0.13.0 

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

func (*TSIServiceExecuteLastDataQueryResult) ReadField0 added in v0.13.0 

func (p *TSIServiceExecuteLastDataQueryResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceExecuteLastDataQueryResult) String added in v0.13.0 

func (p *TSIServiceExecuteLastDataQueryResult) String() string

func (*TSIServiceExecuteLastDataQueryResult) Write added in v0.13.0 

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

type TSIServiceExecuteOperationSyncArgs added in v0.13.0 

type TSIServiceExecuteOperationSyncArgs struct {
	Req *TSOperationSyncWriteReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTSIServiceExecuteOperationSyncArgs added in v0.13.0 

func NewTSIServiceExecuteOperationSyncArgs() *TSIServiceExecuteOperationSyncArgs

func (*TSIServiceExecuteOperationSyncArgs) GetReq added in v0.13.0 

func (p *TSIServiceExecuteOperationSyncArgs) GetReq() *TSOperationSyncWriteReq

func (*TSIServiceExecuteOperationSyncArgs) IsSetReq added in v0.13.0 

func (p *TSIServiceExecuteOperationSyncArgs) IsSetReq() bool

func (*TSIServiceExecuteOperationSyncArgs) Read added in v0.13.0 

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

func (*TSIServiceExecuteOperationSyncArgs) ReadField1 added in v0.13.0 

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

func (*TSIServiceExecuteOperationSyncArgs) String added in v0.13.0 

func (p *TSIServiceExecuteOperationSyncArgs) String() string

func (*TSIServiceExecuteOperationSyncArgs) Write added in v0.13.0 

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

type TSIServiceExecuteOperationSyncResult added in v0.13.0 

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

Attributes:

  • Success

func NewTSIServiceExecuteOperationSyncResult added in v0.13.0 

func NewTSIServiceExecuteOperationSyncResult() *TSIServiceExecuteOperationSyncResult

func (*TSIServiceExecuteOperationSyncResult) GetSuccess added in v0.13.0 

func (p *TSIServiceExecuteOperationSyncResult) GetSuccess() *TSStatus

func (*TSIServiceExecuteOperationSyncResult) IsSetSuccess added in v0.13.0 

func (p *TSIServiceExecuteOperationSyncResult) IsSetSuccess() bool

func (*TSIServiceExecuteOperationSyncResult) Read added in v0.13.0 

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

func (*TSIServiceExecuteOperationSyncResult) ReadField0 added in v0.13.0 

func (p *TSIServiceExecuteOperationSyncResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceExecuteOperationSyncResult) String added in v0.13.0 

func (p *TSIServiceExecuteOperationSyncResult) String() string

func (*TSIServiceExecuteOperationSyncResult) Write added in v0.13.0 

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

type TSIServiceExecuteQueryStatementArgs 

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

Attributes:

  • Req

func NewTSIServiceExecuteQueryStatementArgs 

func NewTSIServiceExecuteQueryStatementArgs() *TSIServiceExecuteQueryStatementArgs

func (*TSIServiceExecuteQueryStatementArgs) GetReq 

func (p *TSIServiceExecuteQueryStatementArgs) GetReq() *TSExecuteStatementReq

func (*TSIServiceExecuteQueryStatementArgs) IsSetReq 

func (p *TSIServiceExecuteQueryStatementArgs) IsSetReq() bool

func (*TSIServiceExecuteQueryStatementArgs) Read 

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

func (*TSIServiceExecuteQueryStatementArgs) ReadField1 

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

func (*TSIServiceExecuteQueryStatementArgs) String 

func (p *TSIServiceExecuteQueryStatementArgs) String() string

func (*TSIServiceExecuteQueryStatementArgs) Write 

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

type TSIServiceExecuteQueryStatementResult 

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

Attributes:

  • Success

func NewTSIServiceExecuteQueryStatementResult 

func NewTSIServiceExecuteQueryStatementResult() *TSIServiceExecuteQueryStatementResult

func (*TSIServiceExecuteQueryStatementResult) GetSuccess 

func (p *TSIServiceExecuteQueryStatementResult) GetSuccess() *TSExecuteStatementResp

func (*TSIServiceExecuteQueryStatementResult) IsSetSuccess 

func (p *TSIServiceExecuteQueryStatementResult) IsSetSuccess() bool

func (*TSIServiceExecuteQueryStatementResult) Read 

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

func (*TSIServiceExecuteQueryStatementResult) ReadField0 

func (p *TSIServiceExecuteQueryStatementResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceExecuteQueryStatementResult) String 

func (p *TSIServiceExecuteQueryStatementResult) String() string

func (*TSIServiceExecuteQueryStatementResult) Write 

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

type TSIServiceExecuteRawDataQueryArgs 

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

Attributes:

  • Req

func NewTSIServiceExecuteRawDataQueryArgs 

func NewTSIServiceExecuteRawDataQueryArgs() *TSIServiceExecuteRawDataQueryArgs

func (*TSIServiceExecuteRawDataQueryArgs) GetReq 

func (p *TSIServiceExecuteRawDataQueryArgs) GetReq() *TSRawDataQueryReq

func (*TSIServiceExecuteRawDataQueryArgs) IsSetReq 

func (p *TSIServiceExecuteRawDataQueryArgs) IsSetReq() bool

func (*TSIServiceExecuteRawDataQueryArgs) Read 

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

func (*TSIServiceExecuteRawDataQueryArgs) ReadField1 

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

func (*TSIServiceExecuteRawDataQueryArgs) String 

func (p *TSIServiceExecuteRawDataQueryArgs) String() string

func (*TSIServiceExecuteRawDataQueryArgs) Write 

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

type TSIServiceExecuteRawDataQueryResult 

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

Attributes:

  • Success

func NewTSIServiceExecuteRawDataQueryResult 

func NewTSIServiceExecuteRawDataQueryResult() *TSIServiceExecuteRawDataQueryResult

func (*TSIServiceExecuteRawDataQueryResult) GetSuccess 

func (p *TSIServiceExecuteRawDataQueryResult) GetSuccess() *TSExecuteStatementResp

func (*TSIServiceExecuteRawDataQueryResult) IsSetSuccess 

func (p *TSIServiceExecuteRawDataQueryResult) IsSetSuccess() bool

func (*TSIServiceExecuteRawDataQueryResult) Read 

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

func (*TSIServiceExecuteRawDataQueryResult) ReadField0 

func (p *TSIServiceExecuteRawDataQueryResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceExecuteRawDataQueryResult) String 

func (p *TSIServiceExecuteRawDataQueryResult) String() string

func (*TSIServiceExecuteRawDataQueryResult) Write 

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

type TSIServiceExecuteStatementArgs 

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

Attributes:

  • Req

func NewTSIServiceExecuteStatementArgs 

func NewTSIServiceExecuteStatementArgs() *TSIServiceExecuteStatementArgs

func (*TSIServiceExecuteStatementArgs) GetReq 

func (p *TSIServiceExecuteStatementArgs) GetReq() *TSExecuteStatementReq

func (*TSIServiceExecuteStatementArgs) IsSetReq 

func (p *TSIServiceExecuteStatementArgs) IsSetReq() bool

func (*TSIServiceExecuteStatementArgs) Read 

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

func (*TSIServiceExecuteStatementArgs) ReadField1 

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

func (*TSIServiceExecuteStatementArgs) String 

func (p *TSIServiceExecuteStatementArgs) String() string

func (*TSIServiceExecuteStatementArgs) Write 

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

type TSIServiceExecuteStatementResult 

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

Attributes:

  • Success

func NewTSIServiceExecuteStatementResult 

func NewTSIServiceExecuteStatementResult() *TSIServiceExecuteStatementResult

func (*TSIServiceExecuteStatementResult) GetSuccess 

func (p *TSIServiceExecuteStatementResult) GetSuccess() *TSExecuteStatementResp

func (*TSIServiceExecuteStatementResult) IsSetSuccess 

func (p *TSIServiceExecuteStatementResult) IsSetSuccess() bool

func (*TSIServiceExecuteStatementResult) Read 

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

func (*TSIServiceExecuteStatementResult) ReadField0 

func (p *TSIServiceExecuteStatementResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceExecuteStatementResult) String 

func (p *TSIServiceExecuteStatementResult) String() string

func (*TSIServiceExecuteStatementResult) Write 

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

type TSIServiceExecuteUpdateStatementArgs 

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

Attributes:

  • Req

func NewTSIServiceExecuteUpdateStatementArgs 

func NewTSIServiceExecuteUpdateStatementArgs() *TSIServiceExecuteUpdateStatementArgs

func (*TSIServiceExecuteUpdateStatementArgs) GetReq 

func (p *TSIServiceExecuteUpdateStatementArgs) GetReq() *TSExecuteStatementReq

func (*TSIServiceExecuteUpdateStatementArgs) IsSetReq 

func (p *TSIServiceExecuteUpdateStatementArgs) IsSetReq() bool

func (*TSIServiceExecuteUpdateStatementArgs) Read 

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

func (*TSIServiceExecuteUpdateStatementArgs) ReadField1 

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

func (*TSIServiceExecuteUpdateStatementArgs) String 

func (p *TSIServiceExecuteUpdateStatementArgs) String() string

func (*TSIServiceExecuteUpdateStatementArgs) Write 

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

type TSIServiceExecuteUpdateStatementResult 

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

Attributes:

  • Success

func NewTSIServiceExecuteUpdateStatementResult 

func NewTSIServiceExecuteUpdateStatementResult() *TSIServiceExecuteUpdateStatementResult

func (*TSIServiceExecuteUpdateStatementResult) GetSuccess 

func (p *TSIServiceExecuteUpdateStatementResult) GetSuccess() *TSExecuteStatementResp

func (*TSIServiceExecuteUpdateStatementResult) IsSetSuccess 

func (p *TSIServiceExecuteUpdateStatementResult) IsSetSuccess() bool

func (*TSIServiceExecuteUpdateStatementResult) Read 

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

func (*TSIServiceExecuteUpdateStatementResult) ReadField0 

func (p *TSIServiceExecuteUpdateStatementResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceExecuteUpdateStatementResult) String 

func (p *TSIServiceExecuteUpdateStatementResult) String() string

func (*TSIServiceExecuteUpdateStatementResult) Write 

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

type TSIServiceFetchMetadataArgs 

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

Attributes:

  • Req

func NewTSIServiceFetchMetadataArgs 

func NewTSIServiceFetchMetadataArgs() *TSIServiceFetchMetadataArgs

func (*TSIServiceFetchMetadataArgs) GetReq 

func (p *TSIServiceFetchMetadataArgs) GetReq() *TSFetchMetadataReq

func (*TSIServiceFetchMetadataArgs) IsSetReq 

func (p *TSIServiceFetchMetadataArgs) IsSetReq() bool

func (*TSIServiceFetchMetadataArgs) Read 

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

func (*TSIServiceFetchMetadataArgs) ReadField1 

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

func (*TSIServiceFetchMetadataArgs) String 

func (p *TSIServiceFetchMetadataArgs) String() string

func (*TSIServiceFetchMetadataArgs) Write 

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

type TSIServiceFetchMetadataResult 

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

Attributes:

  • Success

func NewTSIServiceFetchMetadataResult 

func NewTSIServiceFetchMetadataResult() *TSIServiceFetchMetadataResult

func (*TSIServiceFetchMetadataResult) GetSuccess 

func (p *TSIServiceFetchMetadataResult) GetSuccess() *TSFetchMetadataResp

func (*TSIServiceFetchMetadataResult) IsSetSuccess 

func (p *TSIServiceFetchMetadataResult) IsSetSuccess() bool

func (*TSIServiceFetchMetadataResult) Read 

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

func (*TSIServiceFetchMetadataResult) ReadField0 

func (p *TSIServiceFetchMetadataResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceFetchMetadataResult) String 

func (p *TSIServiceFetchMetadataResult) String() string

func (*TSIServiceFetchMetadataResult) Write 

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

type TSIServiceFetchResultsArgs 

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

Attributes:

  • Req

func NewTSIServiceFetchResultsArgs 

func NewTSIServiceFetchResultsArgs() *TSIServiceFetchResultsArgs

func (*TSIServiceFetchResultsArgs) GetReq 

func (p *TSIServiceFetchResultsArgs) GetReq() *TSFetchResultsReq

func (*TSIServiceFetchResultsArgs) IsSetReq 

func (p *TSIServiceFetchResultsArgs) IsSetReq() bool

func (*TSIServiceFetchResultsArgs) Read 

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

func (*TSIServiceFetchResultsArgs) ReadField1 

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

func (*TSIServiceFetchResultsArgs) String 

func (p *TSIServiceFetchResultsArgs) String() string

func (*TSIServiceFetchResultsArgs) Write 

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

type TSIServiceFetchResultsResult 

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

Attributes:

  • Success

func NewTSIServiceFetchResultsResult 

func NewTSIServiceFetchResultsResult() *TSIServiceFetchResultsResult

func (*TSIServiceFetchResultsResult) GetSuccess 

func (p *TSIServiceFetchResultsResult) GetSuccess() *TSFetchResultsResp

func (*TSIServiceFetchResultsResult) IsSetSuccess 

func (p *TSIServiceFetchResultsResult) IsSetSuccess() bool

func (*TSIServiceFetchResultsResult) Read 

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

func (*TSIServiceFetchResultsResult) ReadField0 

func (p *TSIServiceFetchResultsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceFetchResultsResult) String 

func (p *TSIServiceFetchResultsResult) String() string

func (*TSIServiceFetchResultsResult) Write 

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

type TSIServiceGetPropertiesArgs 

type TSIServiceGetPropertiesArgs struct {
}

func NewTSIServiceGetPropertiesArgs 

func NewTSIServiceGetPropertiesArgs() *TSIServiceGetPropertiesArgs

func (*TSIServiceGetPropertiesArgs) Read 

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

func (*TSIServiceGetPropertiesArgs) String 

func (p *TSIServiceGetPropertiesArgs) String() string

func (*TSIServiceGetPropertiesArgs) Write 

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

type TSIServiceGetPropertiesResult 

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

Attributes:

  • Success

func NewTSIServiceGetPropertiesResult 

func NewTSIServiceGetPropertiesResult() *TSIServiceGetPropertiesResult

func (*TSIServiceGetPropertiesResult) GetSuccess 

func (p *TSIServiceGetPropertiesResult) GetSuccess() *ServerProperties

func (*TSIServiceGetPropertiesResult) IsSetSuccess 

func (p *TSIServiceGetPropertiesResult) IsSetSuccess() bool

func (*TSIServiceGetPropertiesResult) Read 

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

func (*TSIServiceGetPropertiesResult) ReadField0 

func (p *TSIServiceGetPropertiesResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceGetPropertiesResult) String 

func (p *TSIServiceGetPropertiesResult) String() string

func (*TSIServiceGetPropertiesResult) Write 

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

type TSIServiceGetTimeZoneArgs 

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

Attributes:

  • SessionId

func NewTSIServiceGetTimeZoneArgs 

func NewTSIServiceGetTimeZoneArgs() *TSIServiceGetTimeZoneArgs

func (*TSIServiceGetTimeZoneArgs) GetSessionId 

func (p *TSIServiceGetTimeZoneArgs) GetSessionId() int64

func (*TSIServiceGetTimeZoneArgs) Read 

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

func (*TSIServiceGetTimeZoneArgs) ReadField1 

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

func (*TSIServiceGetTimeZoneArgs) String 

func (p *TSIServiceGetTimeZoneArgs) String() string

func (*TSIServiceGetTimeZoneArgs) Write 

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

type TSIServiceGetTimeZoneResult 

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

Attributes:

  • Success

func NewTSIServiceGetTimeZoneResult 

func NewTSIServiceGetTimeZoneResult() *TSIServiceGetTimeZoneResult

func (*TSIServiceGetTimeZoneResult) GetSuccess 

func (p *TSIServiceGetTimeZoneResult) GetSuccess() *TSGetTimeZoneResp

func (*TSIServiceGetTimeZoneResult) IsSetSuccess 

func (p *TSIServiceGetTimeZoneResult) IsSetSuccess() bool

func (*TSIServiceGetTimeZoneResult) Read 

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

func (*TSIServiceGetTimeZoneResult) ReadField0 

func (p *TSIServiceGetTimeZoneResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceGetTimeZoneResult) String 

func (p *TSIServiceGetTimeZoneResult) String() string

func (*TSIServiceGetTimeZoneResult) Write 

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

type TSIServiceInsertRecordArgs 

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

Attributes:

  • Req

func NewTSIServiceInsertRecordArgs 

func NewTSIServiceInsertRecordArgs() *TSIServiceInsertRecordArgs

func (*TSIServiceInsertRecordArgs) GetReq 

func (p *TSIServiceInsertRecordArgs) GetReq() *TSInsertRecordReq

func (*TSIServiceInsertRecordArgs) IsSetReq 

func (p *TSIServiceInsertRecordArgs) IsSetReq() bool

func (*TSIServiceInsertRecordArgs) Read 

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

func (*TSIServiceInsertRecordArgs) ReadField1 

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

func (*TSIServiceInsertRecordArgs) String 

func (p *TSIServiceInsertRecordArgs) String() string

func (*TSIServiceInsertRecordArgs) Write 

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

type TSIServiceInsertRecordResult 

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

Attributes:

  • Success

func NewTSIServiceInsertRecordResult 

func NewTSIServiceInsertRecordResult() *TSIServiceInsertRecordResult

func (*TSIServiceInsertRecordResult) GetSuccess 

func (p *TSIServiceInsertRecordResult) GetSuccess() *TSStatus

func (*TSIServiceInsertRecordResult) IsSetSuccess 

func (p *TSIServiceInsertRecordResult) IsSetSuccess() bool

func (*TSIServiceInsertRecordResult) Read 

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

func (*TSIServiceInsertRecordResult) ReadField0 

func (p *TSIServiceInsertRecordResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceInsertRecordResult) String 

func (p *TSIServiceInsertRecordResult) String() string

func (*TSIServiceInsertRecordResult) Write 

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

type TSIServiceInsertRecordsArgs 

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

Attributes:

  • Req

func NewTSIServiceInsertRecordsArgs 

func NewTSIServiceInsertRecordsArgs() *TSIServiceInsertRecordsArgs

func (*TSIServiceInsertRecordsArgs) GetReq 

func (p *TSIServiceInsertRecordsArgs) GetReq() *TSInsertRecordsReq

func (*TSIServiceInsertRecordsArgs) IsSetReq 

func (p *TSIServiceInsertRecordsArgs) IsSetReq() bool

func (*TSIServiceInsertRecordsArgs) Read 

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

func (*TSIServiceInsertRecordsArgs) ReadField1 

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

func (*TSIServiceInsertRecordsArgs) String 

func (p *TSIServiceInsertRecordsArgs) String() string

func (*TSIServiceInsertRecordsArgs) Write 

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

type TSIServiceInsertRecordsOfOneDeviceArgs 

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

Attributes:

  • Req

func NewTSIServiceInsertRecordsOfOneDeviceArgs 

func NewTSIServiceInsertRecordsOfOneDeviceArgs() *TSIServiceInsertRecordsOfOneDeviceArgs

func (*TSIServiceInsertRecordsOfOneDeviceArgs) GetReq 

func (p *TSIServiceInsertRecordsOfOneDeviceArgs) GetReq() *TSInsertRecordsOfOneDeviceReq

func (*TSIServiceInsertRecordsOfOneDeviceArgs) IsSetReq 

func (p *TSIServiceInsertRecordsOfOneDeviceArgs) IsSetReq() bool

func (*TSIServiceInsertRecordsOfOneDeviceArgs) Read 

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

func (*TSIServiceInsertRecordsOfOneDeviceArgs) ReadField1 

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

func (*TSIServiceInsertRecordsOfOneDeviceArgs) String 

func (p *TSIServiceInsertRecordsOfOneDeviceArgs) String() string

func (*TSIServiceInsertRecordsOfOneDeviceArgs) Write 

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

type TSIServiceInsertRecordsOfOneDeviceResult 

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

Attributes:

  • Success

func NewTSIServiceInsertRecordsOfOneDeviceResult 

func NewTSIServiceInsertRecordsOfOneDeviceResult() *TSIServiceInsertRecordsOfOneDeviceResult

func (*TSIServiceInsertRecordsOfOneDeviceResult) GetSuccess 

func (p *TSIServiceInsertRecordsOfOneDeviceResult) GetSuccess() *TSStatus

func (*TSIServiceInsertRecordsOfOneDeviceResult) IsSetSuccess 

func (p *TSIServiceInsertRecordsOfOneDeviceResult) IsSetSuccess() bool

func (*TSIServiceInsertRecordsOfOneDeviceResult) Read 

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

func (*TSIServiceInsertRecordsOfOneDeviceResult) ReadField0 

func (p *TSIServiceInsertRecordsOfOneDeviceResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceInsertRecordsOfOneDeviceResult) String 

func (p *TSIServiceInsertRecordsOfOneDeviceResult) String() string

func (*TSIServiceInsertRecordsOfOneDeviceResult) Write 

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

type TSIServiceInsertRecordsResult 

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

Attributes:

  • Success

func NewTSIServiceInsertRecordsResult 

func NewTSIServiceInsertRecordsResult() *TSIServiceInsertRecordsResult

func (*TSIServiceInsertRecordsResult) GetSuccess 

func (p *TSIServiceInsertRecordsResult) GetSuccess() *TSStatus

func (*TSIServiceInsertRecordsResult) IsSetSuccess 

func (p *TSIServiceInsertRecordsResult) IsSetSuccess() bool

func (*TSIServiceInsertRecordsResult) Read 

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

func (*TSIServiceInsertRecordsResult) ReadField0 

func (p *TSIServiceInsertRecordsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceInsertRecordsResult) String 

func (p *TSIServiceInsertRecordsResult) String() string

func (*TSIServiceInsertRecordsResult) Write 

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

type TSIServiceInsertStringRecordArgs 

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

Attributes:

  • Req

func NewTSIServiceInsertStringRecordArgs 

func NewTSIServiceInsertStringRecordArgs() *TSIServiceInsertStringRecordArgs

func (*TSIServiceInsertStringRecordArgs) GetReq 

func (p *TSIServiceInsertStringRecordArgs) GetReq() *TSInsertStringRecordReq

func (*TSIServiceInsertStringRecordArgs) IsSetReq 

func (p *TSIServiceInsertStringRecordArgs) IsSetReq() bool

func (*TSIServiceInsertStringRecordArgs) Read 

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

func (*TSIServiceInsertStringRecordArgs) ReadField1 

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

func (*TSIServiceInsertStringRecordArgs) String 

func (p *TSIServiceInsertStringRecordArgs) String() string

func (*TSIServiceInsertStringRecordArgs) Write 

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

type TSIServiceInsertStringRecordResult 

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

Attributes:

  • Success

func NewTSIServiceInsertStringRecordResult 

func NewTSIServiceInsertStringRecordResult() *TSIServiceInsertStringRecordResult

func (*TSIServiceInsertStringRecordResult) GetSuccess 

func (p *TSIServiceInsertStringRecordResult) GetSuccess() *TSStatus

func (*TSIServiceInsertStringRecordResult) IsSetSuccess 

func (p *TSIServiceInsertStringRecordResult) IsSetSuccess() bool

func (*TSIServiceInsertStringRecordResult) Read 

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

func (*TSIServiceInsertStringRecordResult) ReadField0 

func (p *TSIServiceInsertStringRecordResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceInsertStringRecordResult) String 

func (p *TSIServiceInsertStringRecordResult) String() string

func (*TSIServiceInsertStringRecordResult) Write 

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

type TSIServiceInsertStringRecordsArgs 

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

Attributes:

  • Req

func NewTSIServiceInsertStringRecordsArgs 

func NewTSIServiceInsertStringRecordsArgs() *TSIServiceInsertStringRecordsArgs

func (*TSIServiceInsertStringRecordsArgs) GetReq 

func (p *TSIServiceInsertStringRecordsArgs) GetReq() *TSInsertStringRecordsReq

func (*TSIServiceInsertStringRecordsArgs) IsSetReq 

func (p *TSIServiceInsertStringRecordsArgs) IsSetReq() bool

func (*TSIServiceInsertStringRecordsArgs) Read 

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

func (*TSIServiceInsertStringRecordsArgs) ReadField1 

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

func (*TSIServiceInsertStringRecordsArgs) String 

func (p *TSIServiceInsertStringRecordsArgs) String() string

func (*TSIServiceInsertStringRecordsArgs) Write 

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

type TSIServiceInsertStringRecordsOfOneDeviceArgs added in v0.13.0 

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

Attributes:

  • Req

func NewTSIServiceInsertStringRecordsOfOneDeviceArgs added in v0.13.0 

func NewTSIServiceInsertStringRecordsOfOneDeviceArgs() *TSIServiceInsertStringRecordsOfOneDeviceArgs

func (*TSIServiceInsertStringRecordsOfOneDeviceArgs) GetReq added in v0.13.0 

func (p *TSIServiceInsertStringRecordsOfOneDeviceArgs) GetReq() *TSInsertStringRecordsOfOneDeviceReq

func (*TSIServiceInsertStringRecordsOfOneDeviceArgs) IsSetReq added in v0.13.0 

func (p *TSIServiceInsertStringRecordsOfOneDeviceArgs) IsSetReq() bool

func (*TSIServiceInsertStringRecordsOfOneDeviceArgs) Read added in v0.13.0 

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

func (*TSIServiceInsertStringRecordsOfOneDeviceArgs) ReadField1 added in v0.13.0 

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

func (*TSIServiceInsertStringRecordsOfOneDeviceArgs) String added in v0.13.0 

func (p *TSIServiceInsertStringRecordsOfOneDeviceArgs) String() string

func (*TSIServiceInsertStringRecordsOfOneDeviceArgs) Write added in v0.13.0 

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

type TSIServiceInsertStringRecordsOfOneDeviceResult added in v0.13.0 

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

Attributes:

  • Success

func NewTSIServiceInsertStringRecordsOfOneDeviceResult added in v0.13.0 

func NewTSIServiceInsertStringRecordsOfOneDeviceResult() *TSIServiceInsertStringRecordsOfOneDeviceResult

func (*TSIServiceInsertStringRecordsOfOneDeviceResult) GetSuccess added in v0.13.0 

func (p *TSIServiceInsertStringRecordsOfOneDeviceResult) GetSuccess() *TSStatus

func (*TSIServiceInsertStringRecordsOfOneDeviceResult) IsSetSuccess added in v0.13.0 

func (p *TSIServiceInsertStringRecordsOfOneDeviceResult) IsSetSuccess() bool

func (*TSIServiceInsertStringRecordsOfOneDeviceResult) Read added in v0.13.0 

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

func (*TSIServiceInsertStringRecordsOfOneDeviceResult) ReadField0 added in v0.13.0 

func (p *TSIServiceInsertStringRecordsOfOneDeviceResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceInsertStringRecordsOfOneDeviceResult) String added in v0.13.0 

func (p *TSIServiceInsertStringRecordsOfOneDeviceResult) String() string

func (*TSIServiceInsertStringRecordsOfOneDeviceResult) Write added in v0.13.0 

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

type TSIServiceInsertStringRecordsResult 

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

Attributes:

  • Success

func NewTSIServiceInsertStringRecordsResult 

func NewTSIServiceInsertStringRecordsResult() *TSIServiceInsertStringRecordsResult

func (*TSIServiceInsertStringRecordsResult) GetSuccess 

func (p *TSIServiceInsertStringRecordsResult) GetSuccess() *TSStatus

func (*TSIServiceInsertStringRecordsResult) IsSetSuccess 

func (p *TSIServiceInsertStringRecordsResult) IsSetSuccess() bool

func (*TSIServiceInsertStringRecordsResult) Read 

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

func (*TSIServiceInsertStringRecordsResult) ReadField0 

func (p *TSIServiceInsertStringRecordsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceInsertStringRecordsResult) String 

func (p *TSIServiceInsertStringRecordsResult) String() string

func (*TSIServiceInsertStringRecordsResult) Write 

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

type TSIServiceInsertTabletArgs 

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

Attributes:

  • Req

func NewTSIServiceInsertTabletArgs 

func NewTSIServiceInsertTabletArgs() *TSIServiceInsertTabletArgs

func (*TSIServiceInsertTabletArgs) GetReq 

func (p *TSIServiceInsertTabletArgs) GetReq() *TSInsertTabletReq

func (*TSIServiceInsertTabletArgs) IsSetReq 

func (p *TSIServiceInsertTabletArgs) IsSetReq() bool

func (*TSIServiceInsertTabletArgs) Read 

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

func (*TSIServiceInsertTabletArgs) ReadField1 

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

func (*TSIServiceInsertTabletArgs) String 

func (p *TSIServiceInsertTabletArgs) String() string

func (*TSIServiceInsertTabletArgs) Write 

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

type TSIServiceInsertTabletResult 

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

Attributes:

  • Success

func NewTSIServiceInsertTabletResult 

func NewTSIServiceInsertTabletResult() *TSIServiceInsertTabletResult

func (*TSIServiceInsertTabletResult) GetSuccess 

func (p *TSIServiceInsertTabletResult) GetSuccess() *TSStatus

func (*TSIServiceInsertTabletResult) IsSetSuccess 

func (p *TSIServiceInsertTabletResult) IsSetSuccess() bool

func (*TSIServiceInsertTabletResult) Read 

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

func (*TSIServiceInsertTabletResult) ReadField0 

func (p *TSIServiceInsertTabletResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceInsertTabletResult) String 

func (p *TSIServiceInsertTabletResult) String() string

func (*TSIServiceInsertTabletResult) Write 

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

type TSIServiceInsertTabletsArgs 

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

Attributes:

  • Req

func NewTSIServiceInsertTabletsArgs 

func NewTSIServiceInsertTabletsArgs() *TSIServiceInsertTabletsArgs

func (*TSIServiceInsertTabletsArgs) GetReq 

func (p *TSIServiceInsertTabletsArgs) GetReq() *TSInsertTabletsReq

func (*TSIServiceInsertTabletsArgs) IsSetReq 

func (p *TSIServiceInsertTabletsArgs) IsSetReq() bool

func (*TSIServiceInsertTabletsArgs) Read 

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

func (*TSIServiceInsertTabletsArgs) ReadField1 

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

func (*TSIServiceInsertTabletsArgs) String 

func (p *TSIServiceInsertTabletsArgs) String() string

func (*TSIServiceInsertTabletsArgs) Write 

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

type TSIServiceInsertTabletsResult 

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

Attributes:

  • Success

func NewTSIServiceInsertTabletsResult 

func NewTSIServiceInsertTabletsResult() *TSIServiceInsertTabletsResult

func (*TSIServiceInsertTabletsResult) GetSuccess 

func (p *TSIServiceInsertTabletsResult) GetSuccess() *TSStatus

func (*TSIServiceInsertTabletsResult) IsSetSuccess 

func (p *TSIServiceInsertTabletsResult) IsSetSuccess() bool

func (*TSIServiceInsertTabletsResult) Read 

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

func (*TSIServiceInsertTabletsResult) ReadField0 

func (p *TSIServiceInsertTabletsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceInsertTabletsResult) String 

func (p *TSIServiceInsertTabletsResult) String() string

func (*TSIServiceInsertTabletsResult) Write 

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

type TSIServiceOpenSessionArgs 

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

Attributes:

  • Req

func NewTSIServiceOpenSessionArgs 

func NewTSIServiceOpenSessionArgs() *TSIServiceOpenSessionArgs

func (*TSIServiceOpenSessionArgs) GetReq 

func (p *TSIServiceOpenSessionArgs) GetReq() *TSOpenSessionReq

func (*TSIServiceOpenSessionArgs) IsSetReq 

func (p *TSIServiceOpenSessionArgs) IsSetReq() bool

func (*TSIServiceOpenSessionArgs) Read 

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

func (*TSIServiceOpenSessionArgs) ReadField1 

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

func (*TSIServiceOpenSessionArgs) String 

func (p *TSIServiceOpenSessionArgs) String() string

func (*TSIServiceOpenSessionArgs) Write 

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

type TSIServiceOpenSessionResult 

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

Attributes:

  • Success

func NewTSIServiceOpenSessionResult 

func NewTSIServiceOpenSessionResult() *TSIServiceOpenSessionResult

func (*TSIServiceOpenSessionResult) GetSuccess 

func (p *TSIServiceOpenSessionResult) GetSuccess() *TSOpenSessionResp

func (*TSIServiceOpenSessionResult) IsSetSuccess 

func (p *TSIServiceOpenSessionResult) IsSetSuccess() bool

func (*TSIServiceOpenSessionResult) Read 

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

func (*TSIServiceOpenSessionResult) ReadField0 

func (p *TSIServiceOpenSessionResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceOpenSessionResult) String 

func (p *TSIServiceOpenSessionResult) String() string

func (*TSIServiceOpenSessionResult) Write 

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

type TSIServiceProcessor 

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

func NewTSIServiceProcessor 

func NewTSIServiceProcessor(handler TSIService) *TSIServiceProcessor

func (*TSIServiceProcessor) AddToProcessorMap 

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

func (*TSIServiceProcessor) GetProcessorFunction 

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

func (*TSIServiceProcessor) Process 

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

func (*TSIServiceProcessor) ProcessorMap 

func (p *TSIServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type TSIServicePruneSchemaTemplateArgs added in v0.13.0 

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

Attributes:

  • Req

func NewTSIServicePruneSchemaTemplateArgs added in v0.13.0 

func NewTSIServicePruneSchemaTemplateArgs() *TSIServicePruneSchemaTemplateArgs

func (*TSIServicePruneSchemaTemplateArgs) GetReq added in v0.13.0 

func (p *TSIServicePruneSchemaTemplateArgs) GetReq() *TSPruneSchemaTemplateReq

func (*TSIServicePruneSchemaTemplateArgs) IsSetReq added in v0.13.0 

func (p *TSIServicePruneSchemaTemplateArgs) IsSetReq() bool

func (*TSIServicePruneSchemaTemplateArgs) Read added in v0.13.0 

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

func (*TSIServicePruneSchemaTemplateArgs) ReadField1 added in v0.13.0 

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

func (*TSIServicePruneSchemaTemplateArgs) String added in v0.13.0 

func (p *TSIServicePruneSchemaTemplateArgs) String() string

func (*TSIServicePruneSchemaTemplateArgs) Write added in v0.13.0 

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

type TSIServicePruneSchemaTemplateResult added in v0.13.0 

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

Attributes:

  • Success

func NewTSIServicePruneSchemaTemplateResult added in v0.13.0 

func NewTSIServicePruneSchemaTemplateResult() *TSIServicePruneSchemaTemplateResult

func (*TSIServicePruneSchemaTemplateResult) GetSuccess added in v0.13.0 

func (p *TSIServicePruneSchemaTemplateResult) GetSuccess() *TSStatus

func (*TSIServicePruneSchemaTemplateResult) IsSetSuccess added in v0.13.0 

func (p *TSIServicePruneSchemaTemplateResult) IsSetSuccess() bool

func (*TSIServicePruneSchemaTemplateResult) Read added in v0.13.0 

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

func (*TSIServicePruneSchemaTemplateResult) ReadField0 added in v0.13.0 

func (p *TSIServicePruneSchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServicePruneSchemaTemplateResult) String added in v0.13.0 

func (p *TSIServicePruneSchemaTemplateResult) String() string

func (*TSIServicePruneSchemaTemplateResult) Write added in v0.13.0 

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

type TSIServiceQuerySchemaTemplateArgs added in v0.13.0 

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

Attributes:

  • Req

func NewTSIServiceQuerySchemaTemplateArgs added in v0.13.0 

func NewTSIServiceQuerySchemaTemplateArgs() *TSIServiceQuerySchemaTemplateArgs

func (*TSIServiceQuerySchemaTemplateArgs) GetReq added in v0.13.0 

func (p *TSIServiceQuerySchemaTemplateArgs) GetReq() *TSQueryTemplateReq

func (*TSIServiceQuerySchemaTemplateArgs) IsSetReq added in v0.13.0 

func (p *TSIServiceQuerySchemaTemplateArgs) IsSetReq() bool

func (*TSIServiceQuerySchemaTemplateArgs) Read added in v0.13.0 

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

func (*TSIServiceQuerySchemaTemplateArgs) ReadField1 added in v0.13.0 

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

func (*TSIServiceQuerySchemaTemplateArgs) String added in v0.13.0 

func (p *TSIServiceQuerySchemaTemplateArgs) String() string

func (*TSIServiceQuerySchemaTemplateArgs) Write added in v0.13.0 

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

type TSIServiceQuerySchemaTemplateResult added in v0.13.0 

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

Attributes:

  • Success

func NewTSIServiceQuerySchemaTemplateResult added in v0.13.0 

func NewTSIServiceQuerySchemaTemplateResult() *TSIServiceQuerySchemaTemplateResult

func (*TSIServiceQuerySchemaTemplateResult) GetSuccess added in v0.13.0 

func (p *TSIServiceQuerySchemaTemplateResult) GetSuccess() *TSQueryTemplateResp

func (*TSIServiceQuerySchemaTemplateResult) IsSetSuccess added in v0.13.0 

func (p *TSIServiceQuerySchemaTemplateResult) IsSetSuccess() bool

func (*TSIServiceQuerySchemaTemplateResult) Read added in v0.13.0 

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

func (*TSIServiceQuerySchemaTemplateResult) ReadField0 added in v0.13.0 

func (p *TSIServiceQuerySchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceQuerySchemaTemplateResult) String added in v0.13.0 

func (p *TSIServiceQuerySchemaTemplateResult) String() string

func (*TSIServiceQuerySchemaTemplateResult) Write added in v0.13.0 

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

type TSIServiceRequestStatementIdArgs 

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

Attributes:

  • SessionId

func NewTSIServiceRequestStatementIdArgs 

func NewTSIServiceRequestStatementIdArgs() *TSIServiceRequestStatementIdArgs

func (*TSIServiceRequestStatementIdArgs) GetSessionId 

func (p *TSIServiceRequestStatementIdArgs) GetSessionId() int64

func (*TSIServiceRequestStatementIdArgs) Read 

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

func (*TSIServiceRequestStatementIdArgs) ReadField1 

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

func (*TSIServiceRequestStatementIdArgs) String 

func (p *TSIServiceRequestStatementIdArgs) String() string

func (*TSIServiceRequestStatementIdArgs) Write 

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

type TSIServiceRequestStatementIdResult 

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

Attributes:

  • Success

func NewTSIServiceRequestStatementIdResult 

func NewTSIServiceRequestStatementIdResult() *TSIServiceRequestStatementIdResult

func (*TSIServiceRequestStatementIdResult) GetSuccess 

func (p *TSIServiceRequestStatementIdResult) GetSuccess() int64

func (*TSIServiceRequestStatementIdResult) IsSetSuccess 

func (p *TSIServiceRequestStatementIdResult) IsSetSuccess() bool

func (*TSIServiceRequestStatementIdResult) Read 

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

func (*TSIServiceRequestStatementIdResult) ReadField0 

func (p *TSIServiceRequestStatementIdResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceRequestStatementIdResult) String 

func (p *TSIServiceRequestStatementIdResult) String() string

func (*TSIServiceRequestStatementIdResult) Write 

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

type TSIServiceSetSchemaTemplateArgs added in v0.13.0 

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

Attributes:

  • Req

func NewTSIServiceSetSchemaTemplateArgs added in v0.13.0 

func NewTSIServiceSetSchemaTemplateArgs() *TSIServiceSetSchemaTemplateArgs

func (*TSIServiceSetSchemaTemplateArgs) GetReq added in v0.13.0 

func (p *TSIServiceSetSchemaTemplateArgs) GetReq() *TSSetSchemaTemplateReq

func (*TSIServiceSetSchemaTemplateArgs) IsSetReq added in v0.13.0 

func (p *TSIServiceSetSchemaTemplateArgs) IsSetReq() bool

func (*TSIServiceSetSchemaTemplateArgs) Read added in v0.13.0 

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

func (*TSIServiceSetSchemaTemplateArgs) ReadField1 added in v0.13.0 

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

func (*TSIServiceSetSchemaTemplateArgs) String added in v0.13.0 

func (p *TSIServiceSetSchemaTemplateArgs) String() string

func (*TSIServiceSetSchemaTemplateArgs) Write added in v0.13.0 

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

type TSIServiceSetSchemaTemplateResult added in v0.13.0 

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

Attributes:

  • Success

func NewTSIServiceSetSchemaTemplateResult added in v0.13.0 

func NewTSIServiceSetSchemaTemplateResult() *TSIServiceSetSchemaTemplateResult

func (*TSIServiceSetSchemaTemplateResult) GetSuccess added in v0.13.0 

func (p *TSIServiceSetSchemaTemplateResult) GetSuccess() *TSStatus

func (*TSIServiceSetSchemaTemplateResult) IsSetSuccess added in v0.13.0 

func (p *TSIServiceSetSchemaTemplateResult) IsSetSuccess() bool

func (*TSIServiceSetSchemaTemplateResult) Read added in v0.13.0 

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

func (*TSIServiceSetSchemaTemplateResult) ReadField0 added in v0.13.0 

func (p *TSIServiceSetSchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceSetSchemaTemplateResult) String added in v0.13.0 

func (p *TSIServiceSetSchemaTemplateResult) String() string

func (*TSIServiceSetSchemaTemplateResult) Write added in v0.13.0 

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

type TSIServiceSetStorageGroupArgs 

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

Attributes:

  • SessionId
  • StorageGroup

func NewTSIServiceSetStorageGroupArgs 

func NewTSIServiceSetStorageGroupArgs() *TSIServiceSetStorageGroupArgs

func (*TSIServiceSetStorageGroupArgs) GetSessionId 

func (p *TSIServiceSetStorageGroupArgs) GetSessionId() int64

func (*TSIServiceSetStorageGroupArgs) GetStorageGroup 

func (p *TSIServiceSetStorageGroupArgs) GetStorageGroup() string

func (*TSIServiceSetStorageGroupArgs) Read 

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

func (*TSIServiceSetStorageGroupArgs) ReadField1 

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

func (*TSIServiceSetStorageGroupArgs) ReadField2 

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

func (*TSIServiceSetStorageGroupArgs) String 

func (p *TSIServiceSetStorageGroupArgs) String() string

func (*TSIServiceSetStorageGroupArgs) Write 

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

type TSIServiceSetStorageGroupResult 

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

Attributes:

  • Success

func NewTSIServiceSetStorageGroupResult 

func NewTSIServiceSetStorageGroupResult() *TSIServiceSetStorageGroupResult

func (*TSIServiceSetStorageGroupResult) GetSuccess 

func (p *TSIServiceSetStorageGroupResult) GetSuccess() *TSStatus

func (*TSIServiceSetStorageGroupResult) IsSetSuccess 

func (p *TSIServiceSetStorageGroupResult) IsSetSuccess() bool

func (*TSIServiceSetStorageGroupResult) Read 

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

func (*TSIServiceSetStorageGroupResult) ReadField0 

func (p *TSIServiceSetStorageGroupResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceSetStorageGroupResult) String 

func (p *TSIServiceSetStorageGroupResult) String() string

func (*TSIServiceSetStorageGroupResult) Write 

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

type TSIServiceSetTimeZoneArgs 

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

Attributes:

  • Req

func NewTSIServiceSetTimeZoneArgs 

func NewTSIServiceSetTimeZoneArgs() *TSIServiceSetTimeZoneArgs

func (*TSIServiceSetTimeZoneArgs) GetReq 

func (p *TSIServiceSetTimeZoneArgs) GetReq() *TSSetTimeZoneReq

func (*TSIServiceSetTimeZoneArgs) IsSetReq 

func (p *TSIServiceSetTimeZoneArgs) IsSetReq() bool

func (*TSIServiceSetTimeZoneArgs) Read 

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

func (*TSIServiceSetTimeZoneArgs) ReadField1 

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

func (*TSIServiceSetTimeZoneArgs) String 

func (p *TSIServiceSetTimeZoneArgs) String() string

func (*TSIServiceSetTimeZoneArgs) Write 

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

type TSIServiceSetTimeZoneResult 

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

Attributes:

  • Success

func NewTSIServiceSetTimeZoneResult 

func NewTSIServiceSetTimeZoneResult() *TSIServiceSetTimeZoneResult

func (*TSIServiceSetTimeZoneResult) GetSuccess 

func (p *TSIServiceSetTimeZoneResult) GetSuccess() *TSStatus

func (*TSIServiceSetTimeZoneResult) IsSetSuccess 

func (p *TSIServiceSetTimeZoneResult) IsSetSuccess() bool

func (*TSIServiceSetTimeZoneResult) Read 

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

func (*TSIServiceSetTimeZoneResult) ReadField0 

func (p *TSIServiceSetTimeZoneResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceSetTimeZoneResult) String 

func (p *TSIServiceSetTimeZoneResult) String() string

func (*TSIServiceSetTimeZoneResult) Write 

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

type TSIServiceSetUsingTemplateArgs added in v0.13.0 

type TSIServiceSetUsingTemplateArgs struct {
	Req *TSSetUsingTemplateReq `thrift:"req,1" db:"req" json:"req"`
}

Attributes:

  • Req

func NewTSIServiceSetUsingTemplateArgs added in v0.13.0 

func NewTSIServiceSetUsingTemplateArgs() *TSIServiceSetUsingTemplateArgs

func (*TSIServiceSetUsingTemplateArgs) GetReq added in v0.13.0 

func (p *TSIServiceSetUsingTemplateArgs) GetReq() *TSSetUsingTemplateReq

func (*TSIServiceSetUsingTemplateArgs) IsSetReq added in v0.13.0 

func (p *TSIServiceSetUsingTemplateArgs) IsSetReq() bool

func (*TSIServiceSetUsingTemplateArgs) Read added in v0.13.0 

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

func (*TSIServiceSetUsingTemplateArgs) ReadField1 added in v0.13.0 

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

func (*TSIServiceSetUsingTemplateArgs) String added in v0.13.0 

func (p *TSIServiceSetUsingTemplateArgs) String() string

func (*TSIServiceSetUsingTemplateArgs) Write added in v0.13.0 

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

type TSIServiceSetUsingTemplateResult added in v0.13.0 

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

Attributes:

  • Success

func NewTSIServiceSetUsingTemplateResult added in v0.13.0 

func NewTSIServiceSetUsingTemplateResult() *TSIServiceSetUsingTemplateResult

func (*TSIServiceSetUsingTemplateResult) GetSuccess added in v0.13.0 

func (p *TSIServiceSetUsingTemplateResult) GetSuccess() *TSStatus

func (*TSIServiceSetUsingTemplateResult) IsSetSuccess added in v0.13.0 

func (p *TSIServiceSetUsingTemplateResult) IsSetSuccess() bool

func (*TSIServiceSetUsingTemplateResult) Read added in v0.13.0 

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

func (*TSIServiceSetUsingTemplateResult) ReadField0 added in v0.13.0 

func (p *TSIServiceSetUsingTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceSetUsingTemplateResult) String added in v0.13.0 

func (p *TSIServiceSetUsingTemplateResult) String() string

func (*TSIServiceSetUsingTemplateResult) Write added in v0.13.0 

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

type TSIServiceTestInsertRecordArgs 

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

Attributes:

  • Req

func NewTSIServiceTestInsertRecordArgs 

func NewTSIServiceTestInsertRecordArgs() *TSIServiceTestInsertRecordArgs

func (*TSIServiceTestInsertRecordArgs) GetReq 

func (p *TSIServiceTestInsertRecordArgs) GetReq() *TSInsertRecordReq

func (*TSIServiceTestInsertRecordArgs) IsSetReq 

func (p *TSIServiceTestInsertRecordArgs) IsSetReq() bool

func (*TSIServiceTestInsertRecordArgs) Read 

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

func (*TSIServiceTestInsertRecordArgs) ReadField1 

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

func (*TSIServiceTestInsertRecordArgs) String 

func (p *TSIServiceTestInsertRecordArgs) String() string

func (*TSIServiceTestInsertRecordArgs) Write 

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

type TSIServiceTestInsertRecordResult 

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

Attributes:

  • Success

func NewTSIServiceTestInsertRecordResult 

func NewTSIServiceTestInsertRecordResult() *TSIServiceTestInsertRecordResult

func (*TSIServiceTestInsertRecordResult) GetSuccess 

func (p *TSIServiceTestInsertRecordResult) GetSuccess() *TSStatus

func (*TSIServiceTestInsertRecordResult) IsSetSuccess 

func (p *TSIServiceTestInsertRecordResult) IsSetSuccess() bool

func (*TSIServiceTestInsertRecordResult) Read 

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

func (*TSIServiceTestInsertRecordResult) ReadField0 

func (p *TSIServiceTestInsertRecordResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceTestInsertRecordResult) String 

func (p *TSIServiceTestInsertRecordResult) String() string

func (*TSIServiceTestInsertRecordResult) Write 

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

type TSIServiceTestInsertRecordsArgs 

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

Attributes:

  • Req

func NewTSIServiceTestInsertRecordsArgs 

func NewTSIServiceTestInsertRecordsArgs() *TSIServiceTestInsertRecordsArgs

func (*TSIServiceTestInsertRecordsArgs) GetReq 

func (p *TSIServiceTestInsertRecordsArgs) GetReq() *TSInsertRecordsReq

func (*TSIServiceTestInsertRecordsArgs) IsSetReq 

func (p *TSIServiceTestInsertRecordsArgs) IsSetReq() bool

func (*TSIServiceTestInsertRecordsArgs) Read 

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

func (*TSIServiceTestInsertRecordsArgs) ReadField1 

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

func (*TSIServiceTestInsertRecordsArgs) String 

func (p *TSIServiceTestInsertRecordsArgs) String() string

func (*TSIServiceTestInsertRecordsArgs) Write 

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

type TSIServiceTestInsertRecordsOfOneDeviceArgs 

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

Attributes:

  • Req

func NewTSIServiceTestInsertRecordsOfOneDeviceArgs 

func NewTSIServiceTestInsertRecordsOfOneDeviceArgs() *TSIServiceTestInsertRecordsOfOneDeviceArgs

func (*TSIServiceTestInsertRecordsOfOneDeviceArgs) GetReq 

func (p *TSIServiceTestInsertRecordsOfOneDeviceArgs) GetReq() *TSInsertRecordsOfOneDeviceReq

func (*TSIServiceTestInsertRecordsOfOneDeviceArgs) IsSetReq 

func (p *TSIServiceTestInsertRecordsOfOneDeviceArgs) IsSetReq() bool

func (*TSIServiceTestInsertRecordsOfOneDeviceArgs) Read 

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

func (*TSIServiceTestInsertRecordsOfOneDeviceArgs) ReadField1 

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

func (*TSIServiceTestInsertRecordsOfOneDeviceArgs) String 

func (p *TSIServiceTestInsertRecordsOfOneDeviceArgs) String() string

func (*TSIServiceTestInsertRecordsOfOneDeviceArgs) Write 

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

type TSIServiceTestInsertRecordsOfOneDeviceResult 

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

Attributes:

  • Success

func NewTSIServiceTestInsertRecordsOfOneDeviceResult 

func NewTSIServiceTestInsertRecordsOfOneDeviceResult() *TSIServiceTestInsertRecordsOfOneDeviceResult

func (*TSIServiceTestInsertRecordsOfOneDeviceResult) GetSuccess 

func (p *TSIServiceTestInsertRecordsOfOneDeviceResult) GetSuccess() *TSStatus

func (*TSIServiceTestInsertRecordsOfOneDeviceResult) IsSetSuccess 

func (p *TSIServiceTestInsertRecordsOfOneDeviceResult) IsSetSuccess() bool

func (*TSIServiceTestInsertRecordsOfOneDeviceResult) Read 

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

func (*TSIServiceTestInsertRecordsOfOneDeviceResult) ReadField0 

func (p *TSIServiceTestInsertRecordsOfOneDeviceResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceTestInsertRecordsOfOneDeviceResult) String 

func (p *TSIServiceTestInsertRecordsOfOneDeviceResult) String() string

func (*TSIServiceTestInsertRecordsOfOneDeviceResult) Write 

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

type TSIServiceTestInsertRecordsResult 

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

Attributes:

  • Success

func NewTSIServiceTestInsertRecordsResult 

func NewTSIServiceTestInsertRecordsResult() *TSIServiceTestInsertRecordsResult

func (*TSIServiceTestInsertRecordsResult) GetSuccess 

func (p *TSIServiceTestInsertRecordsResult) GetSuccess() *TSStatus

func (*TSIServiceTestInsertRecordsResult) IsSetSuccess 

func (p *TSIServiceTestInsertRecordsResult) IsSetSuccess() bool

func (*TSIServiceTestInsertRecordsResult) Read 

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

func (*TSIServiceTestInsertRecordsResult) ReadField0 

func (p *TSIServiceTestInsertRecordsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceTestInsertRecordsResult) String 

func (p *TSIServiceTestInsertRecordsResult) String() string

func (*TSIServiceTestInsertRecordsResult) Write 

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

type TSIServiceTestInsertStringRecordArgs 

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

Attributes:

  • Req

func NewTSIServiceTestInsertStringRecordArgs 

func NewTSIServiceTestInsertStringRecordArgs() *TSIServiceTestInsertStringRecordArgs

func (*TSIServiceTestInsertStringRecordArgs) GetReq 

func (p *TSIServiceTestInsertStringRecordArgs) GetReq() *TSInsertStringRecordReq

func (*TSIServiceTestInsertStringRecordArgs) IsSetReq 

func (p *TSIServiceTestInsertStringRecordArgs) IsSetReq() bool

func (*TSIServiceTestInsertStringRecordArgs) Read 

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

func (*TSIServiceTestInsertStringRecordArgs) ReadField1 

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

func (*TSIServiceTestInsertStringRecordArgs) String 

func (p *TSIServiceTestInsertStringRecordArgs) String() string

func (*TSIServiceTestInsertStringRecordArgs) Write 

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

type TSIServiceTestInsertStringRecordResult 

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

Attributes:

  • Success

func NewTSIServiceTestInsertStringRecordResult 

func NewTSIServiceTestInsertStringRecordResult() *TSIServiceTestInsertStringRecordResult

func (*TSIServiceTestInsertStringRecordResult) GetSuccess 

func (p *TSIServiceTestInsertStringRecordResult) GetSuccess() *TSStatus

func (*TSIServiceTestInsertStringRecordResult) IsSetSuccess 

func (p *TSIServiceTestInsertStringRecordResult) IsSetSuccess() bool

func (*TSIServiceTestInsertStringRecordResult) Read 

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

func (*TSIServiceTestInsertStringRecordResult) ReadField0 

func (p *TSIServiceTestInsertStringRecordResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceTestInsertStringRecordResult) String 

func (p *TSIServiceTestInsertStringRecordResult) String() string

func (*TSIServiceTestInsertStringRecordResult) Write 

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

type TSIServiceTestInsertStringRecordsArgs 

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

Attributes:

  • Req

func NewTSIServiceTestInsertStringRecordsArgs 

func NewTSIServiceTestInsertStringRecordsArgs() *TSIServiceTestInsertStringRecordsArgs

func (*TSIServiceTestInsertStringRecordsArgs) GetReq 

func (p *TSIServiceTestInsertStringRecordsArgs) GetReq() *TSInsertStringRecordsReq

func (*TSIServiceTestInsertStringRecordsArgs) IsSetReq 

func (p *TSIServiceTestInsertStringRecordsArgs) IsSetReq() bool

func (*TSIServiceTestInsertStringRecordsArgs) Read 

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

func (*TSIServiceTestInsertStringRecordsArgs) ReadField1 

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

func (*TSIServiceTestInsertStringRecordsArgs) String 

func (p *TSIServiceTestInsertStringRecordsArgs) String() string

func (*TSIServiceTestInsertStringRecordsArgs) Write 

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

type TSIServiceTestInsertStringRecordsResult 

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

Attributes:

  • Success

func NewTSIServiceTestInsertStringRecordsResult 

func NewTSIServiceTestInsertStringRecordsResult() *TSIServiceTestInsertStringRecordsResult

func (*TSIServiceTestInsertStringRecordsResult) GetSuccess 

func (p *TSIServiceTestInsertStringRecordsResult) GetSuccess() *TSStatus

func (*TSIServiceTestInsertStringRecordsResult) IsSetSuccess 

func (p *TSIServiceTestInsertStringRecordsResult) IsSetSuccess() bool

func (*TSIServiceTestInsertStringRecordsResult) Read 

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

func (*TSIServiceTestInsertStringRecordsResult) ReadField0 

func (p *TSIServiceTestInsertStringRecordsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceTestInsertStringRecordsResult) String 

func (p *TSIServiceTestInsertStringRecordsResult) String() string

func (*TSIServiceTestInsertStringRecordsResult) Write 

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

type TSIServiceTestInsertTabletArgs 

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

Attributes:

  • Req

func NewTSIServiceTestInsertTabletArgs 

func NewTSIServiceTestInsertTabletArgs() *TSIServiceTestInsertTabletArgs

func (*TSIServiceTestInsertTabletArgs) GetReq 

func (p *TSIServiceTestInsertTabletArgs) GetReq() *TSInsertTabletReq

func (*TSIServiceTestInsertTabletArgs) IsSetReq 

func (p *TSIServiceTestInsertTabletArgs) IsSetReq() bool

func (*TSIServiceTestInsertTabletArgs) Read 

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

func (*TSIServiceTestInsertTabletArgs) ReadField1 

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

func (*TSIServiceTestInsertTabletArgs) String 

func (p *TSIServiceTestInsertTabletArgs) String() string

func (*TSIServiceTestInsertTabletArgs) Write 

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

type TSIServiceTestInsertTabletResult 

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

Attributes:

  • Success

func NewTSIServiceTestInsertTabletResult 

func NewTSIServiceTestInsertTabletResult() *TSIServiceTestInsertTabletResult

func (*TSIServiceTestInsertTabletResult) GetSuccess 

func (p *TSIServiceTestInsertTabletResult) GetSuccess() *TSStatus

func (*TSIServiceTestInsertTabletResult) IsSetSuccess 

func (p *TSIServiceTestInsertTabletResult) IsSetSuccess() bool

func (*TSIServiceTestInsertTabletResult) Read 

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

func (*TSIServiceTestInsertTabletResult) ReadField0 

func (p *TSIServiceTestInsertTabletResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceTestInsertTabletResult) String 

func (p *TSIServiceTestInsertTabletResult) String() string

func (*TSIServiceTestInsertTabletResult) Write 

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

type TSIServiceTestInsertTabletsArgs 

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

Attributes:

  • Req

func NewTSIServiceTestInsertTabletsArgs 

func NewTSIServiceTestInsertTabletsArgs() *TSIServiceTestInsertTabletsArgs

func (*TSIServiceTestInsertTabletsArgs) GetReq 

func (p *TSIServiceTestInsertTabletsArgs) GetReq() *TSInsertTabletsReq

func (*TSIServiceTestInsertTabletsArgs) IsSetReq 

func (p *TSIServiceTestInsertTabletsArgs) IsSetReq() bool

func (*TSIServiceTestInsertTabletsArgs) Read 

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

func (*TSIServiceTestInsertTabletsArgs) ReadField1 

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

func (*TSIServiceTestInsertTabletsArgs) String 

func (p *TSIServiceTestInsertTabletsArgs) String() string

func (*TSIServiceTestInsertTabletsArgs) Write 

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

type TSIServiceTestInsertTabletsResult 

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

Attributes:

  • Success

func NewTSIServiceTestInsertTabletsResult 

func NewTSIServiceTestInsertTabletsResult() *TSIServiceTestInsertTabletsResult

func (*TSIServiceTestInsertTabletsResult) GetSuccess 

func (p *TSIServiceTestInsertTabletsResult) GetSuccess() *TSStatus

func (*TSIServiceTestInsertTabletsResult) IsSetSuccess 

func (p *TSIServiceTestInsertTabletsResult) IsSetSuccess() bool

func (*TSIServiceTestInsertTabletsResult) Read 

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

func (*TSIServiceTestInsertTabletsResult) ReadField0 

func (p *TSIServiceTestInsertTabletsResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceTestInsertTabletsResult) String 

func (p *TSIServiceTestInsertTabletsResult) String() string

func (*TSIServiceTestInsertTabletsResult) Write 

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

type TSIServiceUnsetSchemaTemplateArgs added in v0.13.0 

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

Attributes:

  • Req

func NewTSIServiceUnsetSchemaTemplateArgs added in v0.13.0 

func NewTSIServiceUnsetSchemaTemplateArgs() *TSIServiceUnsetSchemaTemplateArgs

func (*TSIServiceUnsetSchemaTemplateArgs) GetReq added in v0.13.0 

func (p *TSIServiceUnsetSchemaTemplateArgs) GetReq() *TSUnsetSchemaTemplateReq

func (*TSIServiceUnsetSchemaTemplateArgs) IsSetReq added in v0.13.0 

func (p *TSIServiceUnsetSchemaTemplateArgs) IsSetReq() bool

func (*TSIServiceUnsetSchemaTemplateArgs) Read added in v0.13.0 

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

func (*TSIServiceUnsetSchemaTemplateArgs) ReadField1 added in v0.13.0 

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

func (*TSIServiceUnsetSchemaTemplateArgs) String added in v0.13.0 

func (p *TSIServiceUnsetSchemaTemplateArgs) String() string

func (*TSIServiceUnsetSchemaTemplateArgs) Write added in v0.13.0 

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

type TSIServiceUnsetSchemaTemplateResult added in v0.13.0 

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

Attributes:

  • Success

func NewTSIServiceUnsetSchemaTemplateResult added in v0.13.0 

func NewTSIServiceUnsetSchemaTemplateResult() *TSIServiceUnsetSchemaTemplateResult

func (*TSIServiceUnsetSchemaTemplateResult) GetSuccess added in v0.13.0 

func (p *TSIServiceUnsetSchemaTemplateResult) GetSuccess() *TSStatus

func (*TSIServiceUnsetSchemaTemplateResult) IsSetSuccess added in v0.13.0 

func (p *TSIServiceUnsetSchemaTemplateResult) IsSetSuccess() bool

func (*TSIServiceUnsetSchemaTemplateResult) Read added in v0.13.0 

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

func (*TSIServiceUnsetSchemaTemplateResult) ReadField0 added in v0.13.0 

func (p *TSIServiceUnsetSchemaTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceUnsetSchemaTemplateResult) String added in v0.13.0 

func (p *TSIServiceUnsetSchemaTemplateResult) String() string

func (*TSIServiceUnsetSchemaTemplateResult) Write added in v0.13.0 

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

type TSIServiceUnsetUsingTemplateArgs added in v0.13.0 

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

Attributes:

  • SessionId
  • TemplateName
  • PrefixPath

func NewTSIServiceUnsetUsingTemplateArgs added in v0.13.0 

func NewTSIServiceUnsetUsingTemplateArgs() *TSIServiceUnsetUsingTemplateArgs

func (*TSIServiceUnsetUsingTemplateArgs) GetPrefixPath added in v0.13.0 

func (p *TSIServiceUnsetUsingTemplateArgs) GetPrefixPath() string

func (*TSIServiceUnsetUsingTemplateArgs) GetSessionId added in v0.13.0 

func (p *TSIServiceUnsetUsingTemplateArgs) GetSessionId() int64

func (*TSIServiceUnsetUsingTemplateArgs) GetTemplateName added in v0.13.0 

func (p *TSIServiceUnsetUsingTemplateArgs) GetTemplateName() string

func (*TSIServiceUnsetUsingTemplateArgs) Read added in v0.13.0 

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

func (*TSIServiceUnsetUsingTemplateArgs) ReadField1 added in v0.13.0 

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

func (*TSIServiceUnsetUsingTemplateArgs) ReadField2 added in v0.13.0 

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

func (*TSIServiceUnsetUsingTemplateArgs) ReadField3 added in v0.13.0 

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

func (*TSIServiceUnsetUsingTemplateArgs) String added in v0.13.0 

func (p *TSIServiceUnsetUsingTemplateArgs) String() string

func (*TSIServiceUnsetUsingTemplateArgs) Write added in v0.13.0 

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

type TSIServiceUnsetUsingTemplateResult added in v0.13.0 

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

Attributes:

  • Success

func NewTSIServiceUnsetUsingTemplateResult added in v0.13.0 

func NewTSIServiceUnsetUsingTemplateResult() *TSIServiceUnsetUsingTemplateResult

func (*TSIServiceUnsetUsingTemplateResult) GetSuccess added in v0.13.0 

func (p *TSIServiceUnsetUsingTemplateResult) GetSuccess() *TSStatus

func (*TSIServiceUnsetUsingTemplateResult) IsSetSuccess added in v0.13.0 

func (p *TSIServiceUnsetUsingTemplateResult) IsSetSuccess() bool

func (*TSIServiceUnsetUsingTemplateResult) Read added in v0.13.0 

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

func (*TSIServiceUnsetUsingTemplateResult) ReadField0 added in v0.13.0 

func (p *TSIServiceUnsetUsingTemplateResult) ReadField0(ctx context.Context, iprot thrift.TProtocol) error

func (*TSIServiceUnsetUsingTemplateResult) String added in v0.13.0 

func (p *TSIServiceUnsetUsingTemplateResult) String() string

func (*TSIServiceUnsetUsingTemplateResult) Write added in v0.13.0 

func (p *TSIServiceUnsetUsingTemplateResult) 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 TSIServiceInsertRecordArgs_Req_DEFAULT *TSInsertRecordReq
var TSIServiceTestInsertRecordArgs_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 TSIServiceInsertRecordsOfOneDeviceArgs_Req_DEFAULT *TSInsertRecordsOfOneDeviceReq
var TSIServiceTestInsertRecordsOfOneDeviceArgs_Req_DEFAULT *TSInsertRecordsOfOneDeviceReq

func NewTSInsertRecordsOfOneDeviceReq 

func NewTSInsertRecordsOfOneDeviceReq() *TSInsertRecordsOfOneDeviceReq

func (*TSInsertRecordsOfOneDeviceReq) Equals added in v0.12.1 

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

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 (p *TSInsertRecordsOfOneDeviceReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertRecordsOfOneDeviceReq) ReadField1 

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

func (*TSInsertRecordsOfOneDeviceReq) ReadField2 

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

func (*TSInsertRecordsOfOneDeviceReq) ReadField3 

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

func (*TSInsertRecordsOfOneDeviceReq) ReadField4 

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

func (*TSInsertRecordsOfOneDeviceReq) ReadField5 

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

func (*TSInsertRecordsOfOneDeviceReq) ReadField6 added in v0.13.0 

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

func (*TSInsertRecordsOfOneDeviceReq) String 

func (p *TSInsertRecordsOfOneDeviceReq) String() string

func (*TSInsertRecordsOfOneDeviceReq) Write 

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

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 TSIServiceInsertRecordsArgs_Req_DEFAULT *TSInsertRecordsReq
var TSIServiceTestInsertRecordsArgs_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 (p *TSInsertRecordsReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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"`
}

Attributes:

  • SessionId
  • PrefixPath
  • Measurements
  • Values
  • Timestamp
  • IsAligned
var TSIServiceInsertStringRecordArgs_Req_DEFAULT *TSInsertStringRecordReq
var TSIServiceTestInsertStringRecordArgs_Req_DEFAULT *TSInsertStringRecordReq

func NewTSInsertStringRecordReq 

func NewTSInsertStringRecordReq() *TSInsertStringRecordReq

func (*TSInsertStringRecordReq) Equals added in v0.12.1 

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

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) 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) Read 

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

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) String 

func (p *TSInsertStringRecordReq) String() string

func (*TSInsertStringRecordReq) Write 

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

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 TSIServiceInsertStringRecordsOfOneDeviceArgs_Req_DEFAULT *TSInsertStringRecordsOfOneDeviceReq

func NewTSInsertStringRecordsOfOneDeviceReq added in v0.13.0 

func NewTSInsertStringRecordsOfOneDeviceReq() *TSInsertStringRecordsOfOneDeviceReq

func (*TSInsertStringRecordsOfOneDeviceReq) Equals added in v0.13.0 

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

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 (p *TSInsertStringRecordsOfOneDeviceReq) Read(ctx context.Context, iprot thrift.TProtocol) error

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField1 added in v0.13.0 

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

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField2 added in v0.13.0 

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

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField3 added in v0.13.0 

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

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField4 added in v0.13.0 

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

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField5 added in v0.13.0 

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

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField6 added in v0.13.0 

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

func (*TSInsertStringRecordsOfOneDeviceReq) String added in v0.13.0 

func (p *TSInsertStringRecordsOfOneDeviceReq) String() string

func (*TSInsertStringRecordsOfOneDeviceReq) Write added in v0.13.0 

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

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 TSIServiceInsertStringRecordsArgs_Req_DEFAULT *TSInsertStringRecordsReq
var TSIServiceTestInsertStringRecordsArgs_Req_DEFAULT *TSInsertStringRecordsReq

func NewTSInsertStringRecordsReq 

func NewTSInsertStringRecordsReq() *TSInsertStringRecordsReq

func (*TSInsertStringRecordsReq) Equals added in v0.12.1 

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

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 (p *TSInsertStringRecordsReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 TSIServiceInsertTabletArgs_Req_DEFAULT *TSInsertTabletReq
var TSIServiceTestInsertTabletArgs_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 TSIServiceInsertTabletsArgs_Req_DEFAULT *TSInsertTabletsReq
var TSIServiceTestInsertTabletsArgs_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 (p *TSInsertTabletsReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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"`
}

Attributes:

  • SessionId
  • Paths
  • FetchSize
  • Time
  • StatementId
  • EnableRedirectQuery
  • JdbcQuery
var TSIServiceExecuteLastDataQueryArgs_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) 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) Read added in v0.13.0 

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

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) 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" db:"username" json:"username,omitempty"`
	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 TSIServiceOpenSessionArgs_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) IsSetUsername 

func (p *TSOpenSessionReq) IsSetUsername() 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                *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 TSIServiceOpenSessionResult_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() *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 TSOperationSyncWriteReq added in v0.13.0 

type TSOperationSyncWriteReq struct {
	SessionId         int64  `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	OperationSyncType int8   `thrift:"operationSyncType,2,required" db:"operationSyncType" json:"operationSyncType"`
	PhysicalPlan      []byte `thrift:"physicalPlan,3,required" db:"physicalPlan" json:"physicalPlan"`
}

Attributes:

  • SessionId
  • OperationSyncType
  • PhysicalPlan
var TSIServiceExecuteOperationSyncArgs_Req_DEFAULT *TSOperationSyncWriteReq

func NewTSOperationSyncWriteReq added in v0.13.0 

func NewTSOperationSyncWriteReq() *TSOperationSyncWriteReq

func (*TSOperationSyncWriteReq) Equals added in v0.13.0 

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

func (*TSOperationSyncWriteReq) GetOperationSyncType added in v0.13.0 

func (p *TSOperationSyncWriteReq) GetOperationSyncType() int8

func (*TSOperationSyncWriteReq) GetPhysicalPlan added in v0.13.0 

func (p *TSOperationSyncWriteReq) GetPhysicalPlan() []byte

func (*TSOperationSyncWriteReq) GetSessionId added in v0.13.0 

func (p *TSOperationSyncWriteReq) GetSessionId() int64

func (*TSOperationSyncWriteReq) Read added in v0.13.0 

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

func (*TSOperationSyncWriteReq) ReadField1 added in v0.13.0 

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

func (*TSOperationSyncWriteReq) ReadField2 added in v0.13.0 

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

func (*TSOperationSyncWriteReq) ReadField3 added in v0.13.0 

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

func (*TSOperationSyncWriteReq) String added in v0.13.0 

func (p *TSOperationSyncWriteReq) String() string

func (*TSOperationSyncWriteReq) Write added in v0.13.0 

func (p *TSOperationSyncWriteReq) 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 TSIServicePruneSchemaTemplateArgs_Req_DEFAULT *TSPruneSchemaTemplateReq

func NewTSPruneSchemaTemplateReq added in v0.13.0 

func NewTSPruneSchemaTemplateReq() *TSPruneSchemaTemplateReq

func (*TSPruneSchemaTemplateReq) Equals added in v0.13.0 

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

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 (p *TSPruneSchemaTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 (p *TSQueryNonAlignDataSet) Equals(other *TSQueryNonAlignDataSet) bool

func (*TSQueryNonAlignDataSet) GetTimeList 

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

func (*TSQueryNonAlignDataSet) GetValueList 

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

func (*TSQueryNonAlignDataSet) Read 

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

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 

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

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 TSIServiceQuerySchemaTemplateArgs_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 (p *TSQueryTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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       *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 TSIServiceQuerySchemaTemplateResult_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() *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 (p *TSQueryTemplateResp) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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"`
}

Attributes:

  • SessionId
  • Paths
  • FetchSize
  • StartTime
  • EndTime
  • StatementId
  • EnableRedirectQuery
  • JdbcQuery
var TSIServiceExecuteRawDataQueryArgs_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) 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) 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) 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 TSIServiceSetSchemaTemplateArgs_Req_DEFAULT *TSSetSchemaTemplateReq

func NewTSSetSchemaTemplateReq added in v0.13.0 

func NewTSSetSchemaTemplateReq() *TSSetSchemaTemplateReq

func (*TSSetSchemaTemplateReq) Equals added in v0.13.0 

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

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 (p *TSSetSchemaTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

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 TSIServiceSetTimeZoneArgs_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 TSSetUsingTemplateReq added in v0.13.0 

type TSSetUsingTemplateReq struct {
	SessionId int64  `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"`
	DstPath   string `thrift:"dstPath,2,required" db:"dstPath" json:"dstPath"`
}

Attributes:

  • SessionId
  • DstPath
var TSIServiceSetUsingTemplateArgs_Req_DEFAULT *TSSetUsingTemplateReq

func NewTSSetUsingTemplateReq added in v0.13.0 

func NewTSSetUsingTemplateReq() *TSSetUsingTemplateReq

func (*TSSetUsingTemplateReq) Equals added in v0.13.0 

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

func (*TSSetUsingTemplateReq) GetDstPath added in v0.13.0 

func (p *TSSetUsingTemplateReq) GetDstPath() string

func (*TSSetUsingTemplateReq) GetSessionId added in v0.13.0 

func (p *TSSetUsingTemplateReq) GetSessionId() int64

func (*TSSetUsingTemplateReq) Read added in v0.13.0 

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

func (*TSSetUsingTemplateReq) ReadField1 added in v0.13.0 

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

func (*TSSetUsingTemplateReq) ReadField2 added in v0.13.0 

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

func (*TSSetUsingTemplateReq) String added in v0.13.0 

func (p *TSSetUsingTemplateReq) String() string

func (*TSSetUsingTemplateReq) Write added in v0.13.0 

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

type TSStatus 

type TSStatus struct {
	Code         int32       `thrift:"code,1,required" db:"code" json:"code"`
	Message      *string     `thrift:"message,2" db:"message" json:"message,omitempty"`
	SubStatus    []*TSStatus `thrift:"subStatus,3" db:"subStatus" json:"subStatus,omitempty"`
	RedirectNode *EndPoint   `thrift:"redirectNode,4" db:"redirectNode" json:"redirectNode,omitempty"`
}

Attributes:

  • Code
  • Message
  • SubStatus
  • RedirectNode
var TSExecuteStatementResp_Status_DEFAULT *TSStatus
var TSFetchMetadataResp_Status_DEFAULT *TSStatus
var TSFetchResultsResp_Status_DEFAULT *TSStatus
var TSGetTimeZoneResp_Status_DEFAULT *TSStatus
var TSIServiceAppendSchemaTemplateResult_Success_DEFAULT *TSStatus
var TSIServiceCancelOperationResult_Success_DEFAULT *TSStatus
var TSIServiceCloseOperationResult_Success_DEFAULT *TSStatus
var TSIServiceCloseSessionResult_Success_DEFAULT *TSStatus
var TSIServiceCreateAlignedTimeseriesResult_Success_DEFAULT *TSStatus
var TSIServiceCreateMultiTimeseriesResult_Success_DEFAULT *TSStatus
var TSIServiceCreateSchemaTemplateResult_Success_DEFAULT *TSStatus
var TSIServiceCreateTimeseriesResult_Success_DEFAULT *TSStatus
var TSIServiceDeleteDataResult_Success_DEFAULT *TSStatus
var TSIServiceDeleteStorageGroupsResult_Success_DEFAULT *TSStatus
var TSIServiceDeleteTimeseriesResult_Success_DEFAULT *TSStatus
var TSIServiceDropSchemaTemplateResult_Success_DEFAULT *TSStatus
var TSIServiceExecuteBatchStatementResult_Success_DEFAULT *TSStatus
var TSIServiceExecuteOperationSyncResult_Success_DEFAULT *TSStatus
var TSIServiceInsertRecordResult_Success_DEFAULT *TSStatus
var TSIServiceInsertRecordsOfOneDeviceResult_Success_DEFAULT *TSStatus
var TSIServiceInsertRecordsResult_Success_DEFAULT *TSStatus
var TSIServiceInsertStringRecordResult_Success_DEFAULT *TSStatus
var TSIServiceInsertStringRecordsOfOneDeviceResult_Success_DEFAULT *TSStatus
var TSIServiceInsertStringRecordsResult_Success_DEFAULT *TSStatus
var TSIServiceInsertTabletResult_Success_DEFAULT *TSStatus
var TSIServiceInsertTabletsResult_Success_DEFAULT *TSStatus
var TSIServicePruneSchemaTemplateResult_Success_DEFAULT *TSStatus
var TSIServiceSetSchemaTemplateResult_Success_DEFAULT *TSStatus
var TSIServiceSetStorageGroupResult_Success_DEFAULT *TSStatus
var TSIServiceSetTimeZoneResult_Success_DEFAULT *TSStatus
var TSIServiceSetUsingTemplateResult_Success_DEFAULT *TSStatus
var TSIServiceTestInsertRecordResult_Success_DEFAULT *TSStatus
var TSIServiceTestInsertRecordsOfOneDeviceResult_Success_DEFAULT *TSStatus
var TSIServiceTestInsertRecordsResult_Success_DEFAULT *TSStatus
var TSIServiceTestInsertStringRecordResult_Success_DEFAULT *TSStatus
var TSIServiceTestInsertStringRecordsResult_Success_DEFAULT *TSStatus
var TSIServiceTestInsertTabletResult_Success_DEFAULT *TSStatus
var TSIServiceTestInsertTabletsResult_Success_DEFAULT *TSStatus
var TSIServiceUnsetSchemaTemplateResult_Success_DEFAULT *TSStatus
var TSIServiceUnsetUsingTemplateResult_Success_DEFAULT *TSStatus
var TSOpenSessionResp_Status_DEFAULT *TSStatus
var TSQueryTemplateResp_Status_DEFAULT *TSStatus

func NewTSStatus 

func NewTSStatus() *TSStatus

func (*TSStatus) Equals added in v0.12.1 

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

func (*TSStatus) GetCode 

func (p *TSStatus) GetCode() int32

func (*TSStatus) GetMessage 

func (p *TSStatus) GetMessage() string

func (*TSStatus) GetRedirectNode 

func (p *TSStatus) GetRedirectNode() *EndPoint

func (*TSStatus) GetSubStatus 

func (p *TSStatus) GetSubStatus() []*TSStatus

func (*TSStatus) IsSetMessage 

func (p *TSStatus) IsSetMessage() bool

func (*TSStatus) IsSetRedirectNode 

func (p *TSStatus) IsSetRedirectNode() bool

func (*TSStatus) IsSetSubStatus 

func (p *TSStatus) IsSetSubStatus() bool

func (*TSStatus) Read 

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

func (*TSStatus) ReadField1 

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

func (*TSStatus) ReadField2 

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

func (*TSStatus) ReadField3 

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

func (*TSStatus) ReadField4 

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

func (*TSStatus) String 

func (p *TSStatus) String() string

func (*TSStatus) Write 

func (p *TSStatus) 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 TSIServiceUnsetSchemaTemplateArgs_Req_DEFAULT *TSUnsetSchemaTemplateReq

func NewTSUnsetSchemaTemplateReq added in v0.13.0 

func NewTSUnsetSchemaTemplateReq() *TSUnsetSchemaTemplateReq

func (*TSUnsetSchemaTemplateReq) Equals added in v0.13.0 

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

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 (p *TSUnsetSchemaTemplateReq) Read(ctx context.Context, iprot thrift.TProtocol) error

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 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.