iotdb

package module
v0.0.0-...-c735c99 Latest Latest
Warning

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

 Go to latest Published: Jul 10, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	SarefEtsiOrg   = "<https://saref.etsi.org/" // does not include trailing >
	OutputLocation = SarefEtsiOrg + "datasets/examples/"
	DatasetPrefix  = "root.datasets.etsi."
	TimeFormat     = "2006-01-02T15:04:05Z" // yyyy-MM-ddThh:mm:ssZ not quite RFC3339 format. What about timezone?
	LastColumnName = "DatasetName"
)

Variables

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

func Init_IoTDB 

func Init_IoTDB() (bool, string)

func StandardName 

func StandardName(oldName string) (string, string)

Return quoted name and its alias. Alias: open brackets are replaced with underscore. Need to handle 2 aliases being the same. Handles some IotDB reserved keywords.

func TimeDifference 

func TimeDifference(a, b time.Time) (year, month, day, hour, min, sec int)

For dates different more than 1 day apart.

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 

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 IoTDbDataFile 

type IoTDbDataFile struct {
	Description        string                     `json:"description"`
	DataFilePath       string                     `json:"datafilepath"`
	DataFileType       string                     `json:"datafiletype"`
	SummaryFilePath    string                     `json:"summaryfilepath"`
	DatasetName        string                     `json:"datasetname"`
	Measurements       map[string]MeasurementItem `json:"measurements"`
	TimeseriesCommands []string                   `json:"timeseriescommands"` // command-line parameters
	Summary            [][]string                 `json:"summary"`            // from summary file
	Dataset            [][]string                 `json:"dataset"`            // actual data
	// contains filtered or unexported fields
}

func Initialize_IoTDbDataFile 

func Initialize_IoTDbDataFile(programArgs []string) (IoTDbDataFile, error)

func (*IoTDbDataFile) Format_TurtleOntology 

func (iot *IoTDbDataFile) Format_TurtleOntology() []string

Produce DatatypeProperty ontology from summary & dataset. Write to filesystem, then upload to website. Make the dataset its own Class and loadable into GraphDB as Named Graph. Special handling: "dateTime", "XMLLiteral", "anyURI"

func (*IoTDbDataFile) FormattedColumnNames 

func (iot *IoTDbDataFile) FormattedColumnNames() string

Return list of ordered dataset column names as string. Does not include enclosing ()

func (*IoTDbDataFile) OutputDescription 

func (iot *IoTDbDataFile) OutputDescription(displayColumnInfo bool) string

Include percentage of missing data, which can be got from a SELECT count(*) from root.datasets.etsi.household_data_1min_singleindex;

func (*IoTDbDataFile) ProcessTimeseries 

func (iot *IoTDbDataFile) ProcessTimeseries() error

Command-line parameters: {drop create delete insert ...}. Always output dataset description. create timeseries root.datasets.etsi.household_data_60min_singleindex.DE_KN_industrial1_grid_import with datatype=FLOAT, encoding=GORILLA, compressor=SNAPPY; ProcessTimeseries() is the only place where iot.session is instantiated and clientConfig is used.

func (*IoTDbDataFile) ReadCsvFile 

func (iot *IoTDbDataFile) ReadCsvFile(filePath string, isDataset bool)

Expects comma-separated files. Assigns Dataset or Summary.

func (*IoTDbDataFile) SaveInsertStatements 

func (iot *IoTDbDataFile) SaveInsertStatements()

COUNT TIMESERIES root.datasets.etsi.household_data_60min_singleindex.DatasetName; Each ALIGNED insert statement inserts one row. Dataset includes header row so subtract 1. Automatically inserts long time column as first column (which should be UTC) Avoid returning huge result.

func (*IoTDbDataFile) XsvSummaryTypeMap 

func (iot *IoTDbDataFile) XsvSummaryTypeMap()

Expects {Units, DatasetName} fields to have been appended to the summary file. Assign []Measurements. Expects Summary to be assigned. Use XSD data types. []string{"field", "type", "sum", "min", "max", "min_length", "max_length", "mean", "stddev", "median", "mode", "cardinality", "Units", "DatasetName"} len() only returns the length of the "external" array.

type IoTDbProgramParameters 

type IoTDbProgramParameters struct {
	Host     string `json:"host"`
	Port     string `json:"port"`
	User     string `json:"user"`
	Password string `json:"password"`
}

type MeasurementItem 

type MeasurementItem struct {
	MeasurementName  string `json:"measurementname"`  // Original name always single-quoted
	MeasurementAlias string `json:"measurementalias"` // Names that fit IotDB format; see StandardName() => [0-9 a-z A-Z _ ]
	MeasurementType  string `json:"measurementtype"`  // XSD data type
	MeasurementUnits string `json:"measurementunits"`
	ColumnOrder      int    `json:"columnorder"` // Column order from data file
}

mapped to original column name

func (MeasurementItem) ToString 

func (mi MeasurementItem) ToString() string

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 

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

func (*ServerProperties) GetIsReadOnly 

func (p *ServerProperties) GetIsReadOnly() bool

func (*ServerProperties) GetMaxConcurrentClientNum 

func (p *ServerProperties) GetMaxConcurrentClientNum() int32

func (*ServerProperties) GetSupportedTimeAggregationOperations 

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

func (*ServerProperties) GetThriftMaxFrameSize 

func (p *ServerProperties) GetThriftMaxFrameSize() int32

func (*ServerProperties) GetTimestampPrecision 

func (p *ServerProperties) GetTimestampPrecision() string

func (*ServerProperties) GetVersion 

func (p *ServerProperties) GetVersion() string

func (*ServerProperties) GetWatermarkBitString 

func (p *ServerProperties) GetWatermarkBitString() string

func (*ServerProperties) GetWatermarkParamMarkRate 

func (p *ServerProperties) GetWatermarkParamMarkRate() int32

func (*ServerProperties) GetWatermarkParamMaxRightBit 

func (p *ServerProperties) GetWatermarkParamMaxRightBit() int32

func (*ServerProperties) GetWatermarkSecretKey 

func (p *ServerProperties) GetWatermarkSecretKey() string

func (*ServerProperties) IsSetIsReadOnly 

func (p *ServerProperties) IsSetIsReadOnly() bool

func (*ServerProperties) IsSetThriftMaxFrameSize 

func (p *ServerProperties) IsSetThriftMaxFrameSize() bool

func (*ServerProperties) IsSetWatermarkBitString 

func (p *ServerProperties) IsSetWatermarkBitString() bool

func (*ServerProperties) IsSetWatermarkParamMarkRate 

func (p *ServerProperties) IsSetWatermarkParamMarkRate() bool

func (*ServerProperties) IsSetWatermarkParamMaxRightBit 

func (p *ServerProperties) IsSetWatermarkParamMaxRightBit() bool

func (*ServerProperties) IsSetWatermarkSecretKey 

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 

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 

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

func (*ServerProperties) ReadField5 

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

func (*ServerProperties) ReadField6 

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

func (*ServerProperties) ReadField7 

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

func (*ServerProperties) ReadField8 

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

func (*ServerProperties) ReadField9 

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 

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 

func NewTSAppendSchemaTemplateReq() *TSAppendSchemaTemplateReq

func (*TSAppendSchemaTemplateReq) Equals 

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

func (*TSAppendSchemaTemplateReq) GetCompressors 

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

func (*TSAppendSchemaTemplateReq) GetDataTypes 

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

func (*TSAppendSchemaTemplateReq) GetEncodings 

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

func (*TSAppendSchemaTemplateReq) GetIsAligned 

func (p *TSAppendSchemaTemplateReq) GetIsAligned() bool

func (*TSAppendSchemaTemplateReq) GetMeasurements 

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

func (*TSAppendSchemaTemplateReq) GetName 

func (p *TSAppendSchemaTemplateReq) GetName() string

func (*TSAppendSchemaTemplateReq) GetSessionId 

func (p *TSAppendSchemaTemplateReq) GetSessionId() int64

func (*TSAppendSchemaTemplateReq) Read 

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

func (*TSAppendSchemaTemplateReq) ReadField1 

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

func (*TSAppendSchemaTemplateReq) ReadField2 

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

func (*TSAppendSchemaTemplateReq) ReadField3 

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

func (*TSAppendSchemaTemplateReq) ReadField4 

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

func (*TSAppendSchemaTemplateReq) ReadField5 

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

func (*TSAppendSchemaTemplateReq) ReadField6 

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

func (*TSAppendSchemaTemplateReq) ReadField7 

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

func (*TSAppendSchemaTemplateReq) String 

func (p *TSAppendSchemaTemplateReq) String() string

func (*TSAppendSchemaTemplateReq) Write 

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 

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 

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 

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 

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 

func NewTSCreateAlignedTimeseriesReq() *TSCreateAlignedTimeseriesReq

func (*TSCreateAlignedTimeseriesReq) Equals 

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

func (*TSCreateAlignedTimeseriesReq) GetCompressors 

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

func (*TSCreateAlignedTimeseriesReq) GetDataTypes 

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

func (*TSCreateAlignedTimeseriesReq) GetEncodings 

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

func (*TSCreateAlignedTimeseriesReq) GetMeasurementAlias 

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

func (*TSCreateAlignedTimeseriesReq) GetMeasurements 

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

func (*TSCreateAlignedTimeseriesReq) GetPrefixPath 

func (p *TSCreateAlignedTimeseriesReq) GetPrefixPath() string

func (*TSCreateAlignedTimeseriesReq) GetSessionId 

func (p *TSCreateAlignedTimeseriesReq) GetSessionId() int64

func (*TSCreateAlignedTimeseriesReq) IsSetMeasurementAlias 

func (p *TSCreateAlignedTimeseriesReq) IsSetMeasurementAlias() bool

func (*TSCreateAlignedTimeseriesReq) Read 

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

func (*TSCreateAlignedTimeseriesReq) ReadField1 

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

func (*TSCreateAlignedTimeseriesReq) ReadField2 

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

func (*TSCreateAlignedTimeseriesReq) ReadField3 

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

func (*TSCreateAlignedTimeseriesReq) ReadField4 

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

func (*TSCreateAlignedTimeseriesReq) ReadField5 

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

func (*TSCreateAlignedTimeseriesReq) ReadField6 

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

func (*TSCreateAlignedTimeseriesReq) ReadField7 

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

func (*TSCreateAlignedTimeseriesReq) String 

func (p *TSCreateAlignedTimeseriesReq) String() string

func (*TSCreateAlignedTimeseriesReq) Write 

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 

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 

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 

func NewTSCreateSchemaTemplateReq() *TSCreateSchemaTemplateReq

func (*TSCreateSchemaTemplateReq) Equals 

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

func (*TSCreateSchemaTemplateReq) GetName 

func (p *TSCreateSchemaTemplateReq) GetName() string

func (*TSCreateSchemaTemplateReq) GetSerializedTemplate 

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

func (*TSCreateSchemaTemplateReq) GetSessionId 

func (p *TSCreateSchemaTemplateReq) GetSessionId() int64

func (*TSCreateSchemaTemplateReq) Read 

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

func (*TSCreateSchemaTemplateReq) ReadField1 

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

func (*TSCreateSchemaTemplateReq) ReadField2 

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

func (*TSCreateSchemaTemplateReq) ReadField3 

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

func (*TSCreateSchemaTemplateReq) String 

func (p *TSCreateSchemaTemplateReq) String() string

func (*TSCreateSchemaTemplateReq) Write 

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 

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 

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 

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 

func NewTSDropSchemaTemplateReq() *TSDropSchemaTemplateReq

func (*TSDropSchemaTemplateReq) Equals 

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

func (*TSDropSchemaTemplateReq) GetSessionId 

func (p *TSDropSchemaTemplateReq) GetSessionId() int64

func (*TSDropSchemaTemplateReq) GetTemplateName 

func (p *TSDropSchemaTemplateReq) GetTemplateName() string

func (*TSDropSchemaTemplateReq) Read 

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

func (*TSDropSchemaTemplateReq) ReadField1 

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

func (*TSDropSchemaTemplateReq) ReadField2 

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

func (*TSDropSchemaTemplateReq) String 

func (p *TSDropSchemaTemplateReq) String() string

func (*TSDropSchemaTemplateReq) Write 

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 

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 

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

func (*TSExecuteStatementReq) GetEnableRedirectQuery 

func (p *TSExecuteStatementReq) GetEnableRedirectQuery() bool

func (*TSExecuteStatementReq) GetFetchSize 

func (p *TSExecuteStatementReq) GetFetchSize() int32

func (*TSExecuteStatementReq) GetJdbcQuery 

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 

func (p *TSExecuteStatementReq) IsSetEnableRedirectQuery() bool

func (*TSExecuteStatementReq) IsSetFetchSize 

func (p *TSExecuteStatementReq) IsSetFetchSize() bool

func (*TSExecuteStatementReq) IsSetJdbcQuery 

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 

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

func (*TSExecuteStatementReq) ReadField7 

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 

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

func (*TSExecuteStatementResp) GetAliasColumns 

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 

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

func (*TSExecuteStatementResp) GetStatus 

func (p *TSExecuteStatementResp) GetStatus() *TSStatus

func (*TSExecuteStatementResp) GetTracingInfo 

func (p *TSExecuteStatementResp) GetTracingInfo() *TSTracingInfo

func (*TSExecuteStatementResp) IsSetAliasColumns 

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 

func (p *TSExecuteStatementResp) IsSetSgColumns() bool

func (*TSExecuteStatementResp) IsSetStatus 

func (p *TSExecuteStatementResp) IsSetStatus() bool

func (*TSExecuteStatementResp) IsSetTracingInfo 

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 

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

func (*TSExecuteStatementResp) ReadField11 

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

func (*TSExecuteStatementResp) ReadField12 

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 

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 

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 

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 

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 

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 

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 

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 

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

Attributes:

  • Req

func NewTSIServiceAppendSchemaTemplateArgs 

func NewTSIServiceAppendSchemaTemplateArgs() *TSIServiceAppendSchemaTemplateArgs

func (*TSIServiceAppendSchemaTemplateArgs) GetReq 

func (p *TSIServiceAppendSchemaTemplateArgs) GetReq() *TSAppendSchemaTemplateReq

func (*TSIServiceAppendSchemaTemplateArgs) IsSetReq 

func (p *TSIServiceAppendSchemaTemplateArgs) IsSetReq() bool

func (*TSIServiceAppendSchemaTemplateArgs) Read 

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

func (*TSIServiceAppendSchemaTemplateArgs) ReadField1 

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

func (*TSIServiceAppendSchemaTemplateArgs) String 

func (p *TSIServiceAppendSchemaTemplateArgs) String() string

func (*TSIServiceAppendSchemaTemplateArgs) Write 

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

type TSIServiceAppendSchemaTemplateResult 

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

Attributes:

  • Success

func NewTSIServiceAppendSchemaTemplateResult 

func NewTSIServiceAppendSchemaTemplateResult() *TSIServiceAppendSchemaTemplateResult

func (*TSIServiceAppendSchemaTemplateResult) GetSuccess 

func (p *TSIServiceAppendSchemaTemplateResult) GetSuccess() *TSStatus

func (*TSIServiceAppendSchemaTemplateResult) IsSetSuccess 

func (p *TSIServiceAppendSchemaTemplateResult) IsSetSuccess() bool

func (*TSIServiceAppendSchemaTemplateResult) Read 

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

func (*TSIServiceAppendSchemaTemplateResult) ReadField0 

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

func (*TSIServiceAppendSchemaTemplateResult) String 

func (p *TSIServiceAppendSchemaTemplateResult) String() string

func (*TSIServiceAppendSchemaTemplateResult) Write 

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 

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 

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 

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 

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 

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

Parameters:

  • Req

func (*TSIServiceClient) ExecuteOperationSync 

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 

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_ 

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 

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

Parameters:

  • Req

func (*TSIServiceClient) QuerySchemaTemplate 

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_ 

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

func (*TSIServiceClient) SetSchemaTemplate 

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 

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 

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

Parameters:

  • Req

func (*TSIServiceClient) UnsetUsingTemplate 

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 

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

Attributes:

  • Req

func NewTSIServiceCreateAlignedTimeseriesArgs 

func NewTSIServiceCreateAlignedTimeseriesArgs() *TSIServiceCreateAlignedTimeseriesArgs

func (*TSIServiceCreateAlignedTimeseriesArgs) GetReq 

func (p *TSIServiceCreateAlignedTimeseriesArgs) GetReq() *TSCreateAlignedTimeseriesReq

func (*TSIServiceCreateAlignedTimeseriesArgs) IsSetReq 

func (p *TSIServiceCreateAlignedTimeseriesArgs) IsSetReq() bool

func (*TSIServiceCreateAlignedTimeseriesArgs) Read 

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

func (*TSIServiceCreateAlignedTimeseriesArgs) ReadField1 

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

func (*TSIServiceCreateAlignedTimeseriesArgs) String 

func (p *TSIServiceCreateAlignedTimeseriesArgs) String() string

func (*TSIServiceCreateAlignedTimeseriesArgs) Write 

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

type TSIServiceCreateAlignedTimeseriesResult 

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

Attributes:

  • Success

func NewTSIServiceCreateAlignedTimeseriesResult 

func NewTSIServiceCreateAlignedTimeseriesResult() *TSIServiceCreateAlignedTimeseriesResult

func (*TSIServiceCreateAlignedTimeseriesResult) GetSuccess 

func (p *TSIServiceCreateAlignedTimeseriesResult) GetSuccess() *TSStatus

func (*TSIServiceCreateAlignedTimeseriesResult) IsSetSuccess 

func (p *TSIServiceCreateAlignedTimeseriesResult) IsSetSuccess() bool

func (*TSIServiceCreateAlignedTimeseriesResult) Read 

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

func (*TSIServiceCreateAlignedTimeseriesResult) ReadField0 

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

func (*TSIServiceCreateAlignedTimeseriesResult) String 

func (p *TSIServiceCreateAlignedTimeseriesResult) String() string

func (*TSIServiceCreateAlignedTimeseriesResult) Write 

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 

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

Attributes:

  • Req

func NewTSIServiceCreateSchemaTemplateArgs 

func NewTSIServiceCreateSchemaTemplateArgs() *TSIServiceCreateSchemaTemplateArgs

func (*TSIServiceCreateSchemaTemplateArgs) GetReq 

func (p *TSIServiceCreateSchemaTemplateArgs) GetReq() *TSCreateSchemaTemplateReq

func (*TSIServiceCreateSchemaTemplateArgs) IsSetReq 

func (p *TSIServiceCreateSchemaTemplateArgs) IsSetReq() bool

func (*TSIServiceCreateSchemaTemplateArgs) Read 

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

func (*TSIServiceCreateSchemaTemplateArgs) ReadField1 

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

func (*TSIServiceCreateSchemaTemplateArgs) String 

func (p *TSIServiceCreateSchemaTemplateArgs) String() string

func (*TSIServiceCreateSchemaTemplateArgs) Write 

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

type TSIServiceCreateSchemaTemplateResult 

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

Attributes:

  • Success

func NewTSIServiceCreateSchemaTemplateResult 

func NewTSIServiceCreateSchemaTemplateResult() *TSIServiceCreateSchemaTemplateResult

func (*TSIServiceCreateSchemaTemplateResult) GetSuccess 

func (p *TSIServiceCreateSchemaTemplateResult) GetSuccess() *TSStatus

func (*TSIServiceCreateSchemaTemplateResult) IsSetSuccess 

func (p *TSIServiceCreateSchemaTemplateResult) IsSetSuccess() bool

func (*TSIServiceCreateSchemaTemplateResult) Read 

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

func (*TSIServiceCreateSchemaTemplateResult) ReadField0 

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

func (*TSIServiceCreateSchemaTemplateResult) String 

func (p *TSIServiceCreateSchemaTemplateResult) String() string

func (*TSIServiceCreateSchemaTemplateResult) Write 

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 

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

Attributes:

  • Req

func NewTSIServiceDropSchemaTemplateArgs 

func NewTSIServiceDropSchemaTemplateArgs() *TSIServiceDropSchemaTemplateArgs

func (*TSIServiceDropSchemaTemplateArgs) GetReq 

func (p *TSIServiceDropSchemaTemplateArgs) GetReq() *TSDropSchemaTemplateReq

func (*TSIServiceDropSchemaTemplateArgs) IsSetReq 

func (p *TSIServiceDropSchemaTemplateArgs) IsSetReq() bool

func (*TSIServiceDropSchemaTemplateArgs) Read 

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

func (*TSIServiceDropSchemaTemplateArgs) ReadField1 

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

func (*TSIServiceDropSchemaTemplateArgs) String 

func (p *TSIServiceDropSchemaTemplateArgs) String() string

func (*TSIServiceDropSchemaTemplateArgs) Write 

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

type TSIServiceDropSchemaTemplateResult 

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

Attributes:

  • Success

func NewTSIServiceDropSchemaTemplateResult 

func NewTSIServiceDropSchemaTemplateResult() *TSIServiceDropSchemaTemplateResult

func (*TSIServiceDropSchemaTemplateResult) GetSuccess 

func (p *TSIServiceDropSchemaTemplateResult) GetSuccess() *TSStatus

func (*TSIServiceDropSchemaTemplateResult) IsSetSuccess 

func (p *TSIServiceDropSchemaTemplateResult) IsSetSuccess() bool

func (*TSIServiceDropSchemaTemplateResult) Read 

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

func (*TSIServiceDropSchemaTemplateResult) ReadField0 

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

func (*TSIServiceDropSchemaTemplateResult) String 

func (p *TSIServiceDropSchemaTemplateResult) String() string

func (*TSIServiceDropSchemaTemplateResult) Write 

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 

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

Attributes:

  • Req

func NewTSIServiceExecuteLastDataQueryArgs 

func NewTSIServiceExecuteLastDataQueryArgs() *TSIServiceExecuteLastDataQueryArgs

func (*TSIServiceExecuteLastDataQueryArgs) GetReq 

func (p *TSIServiceExecuteLastDataQueryArgs) GetReq() *TSLastDataQueryReq

func (*TSIServiceExecuteLastDataQueryArgs) IsSetReq 

func (p *TSIServiceExecuteLastDataQueryArgs) IsSetReq() bool

func (*TSIServiceExecuteLastDataQueryArgs) Read 

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

func (*TSIServiceExecuteLastDataQueryArgs) ReadField1 

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

func (*TSIServiceExecuteLastDataQueryArgs) String 

func (p *TSIServiceExecuteLastDataQueryArgs) String() string

func (*TSIServiceExecuteLastDataQueryArgs) Write 

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

type TSIServiceExecuteLastDataQueryResult 

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

Attributes:

  • Success

func NewTSIServiceExecuteLastDataQueryResult 

func NewTSIServiceExecuteLastDataQueryResult() *TSIServiceExecuteLastDataQueryResult

func (*TSIServiceExecuteLastDataQueryResult) GetSuccess 

func (p *TSIServiceExecuteLastDataQueryResult) GetSuccess() *TSExecuteStatementResp

func (*TSIServiceExecuteLastDataQueryResult) IsSetSuccess 

func (p *TSIServiceExecuteLastDataQueryResult) IsSetSuccess() bool

func (*TSIServiceExecuteLastDataQueryResult) Read 

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

func (*TSIServiceExecuteLastDataQueryResult) ReadField0 

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

func (*TSIServiceExecuteLastDataQueryResult) String 

func (p *TSIServiceExecuteLastDataQueryResult) String() string

func (*TSIServiceExecuteLastDataQueryResult) Write 

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

type TSIServiceExecuteOperationSyncArgs 

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

Attributes:

  • Req

func NewTSIServiceExecuteOperationSyncArgs 

func NewTSIServiceExecuteOperationSyncArgs() *TSIServiceExecuteOperationSyncArgs

func (*TSIServiceExecuteOperationSyncArgs) GetReq 

func (p *TSIServiceExecuteOperationSyncArgs) GetReq() *TSOperationSyncWriteReq

func (*TSIServiceExecuteOperationSyncArgs) IsSetReq 

func (p *TSIServiceExecuteOperationSyncArgs) IsSetReq() bool

func (*TSIServiceExecuteOperationSyncArgs) Read 

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

func (*TSIServiceExecuteOperationSyncArgs) ReadField1 

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

func (*TSIServiceExecuteOperationSyncArgs) String 

func (p *TSIServiceExecuteOperationSyncArgs) String() string

func (*TSIServiceExecuteOperationSyncArgs) Write 

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

type TSIServiceExecuteOperationSyncResult 

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

Attributes:

  • Success

func NewTSIServiceExecuteOperationSyncResult 

func NewTSIServiceExecuteOperationSyncResult() *TSIServiceExecuteOperationSyncResult

func (*TSIServiceExecuteOperationSyncResult) GetSuccess 

func (p *TSIServiceExecuteOperationSyncResult) GetSuccess() *TSStatus

func (*TSIServiceExecuteOperationSyncResult) IsSetSuccess 

func (p *TSIServiceExecuteOperationSyncResult) IsSetSuccess() bool

func (*TSIServiceExecuteOperationSyncResult) Read 

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

func (*TSIServiceExecuteOperationSyncResult) ReadField0 

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

func (*TSIServiceExecuteOperationSyncResult) String 

func (p *TSIServiceExecuteOperationSyncResult) String() string

func (*TSIServiceExecuteOperationSyncResult) Write 

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 

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

Attributes:

  • Req

func NewTSIServiceInsertStringRecordsOfOneDeviceArgs 

func NewTSIServiceInsertStringRecordsOfOneDeviceArgs() *TSIServiceInsertStringRecordsOfOneDeviceArgs

func (*TSIServiceInsertStringRecordsOfOneDeviceArgs) GetReq 

func (p *TSIServiceInsertStringRecordsOfOneDeviceArgs) GetReq() *TSInsertStringRecordsOfOneDeviceReq

func (*TSIServiceInsertStringRecordsOfOneDeviceArgs) IsSetReq 

func (p *TSIServiceInsertStringRecordsOfOneDeviceArgs) IsSetReq() bool

func (*TSIServiceInsertStringRecordsOfOneDeviceArgs) Read 

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

func (*TSIServiceInsertStringRecordsOfOneDeviceArgs) ReadField1 

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

func (*TSIServiceInsertStringRecordsOfOneDeviceArgs) String 

func (p *TSIServiceInsertStringRecordsOfOneDeviceArgs) String() string

func (*TSIServiceInsertStringRecordsOfOneDeviceArgs) Write 

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

type TSIServiceInsertStringRecordsOfOneDeviceResult 

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

Attributes:

  • Success

func NewTSIServiceInsertStringRecordsOfOneDeviceResult 

func NewTSIServiceInsertStringRecordsOfOneDeviceResult() *TSIServiceInsertStringRecordsOfOneDeviceResult

func (*TSIServiceInsertStringRecordsOfOneDeviceResult) GetSuccess 

func (p *TSIServiceInsertStringRecordsOfOneDeviceResult) GetSuccess() *TSStatus

func (*TSIServiceInsertStringRecordsOfOneDeviceResult) IsSetSuccess 

func (p *TSIServiceInsertStringRecordsOfOneDeviceResult) IsSetSuccess() bool

func (*TSIServiceInsertStringRecordsOfOneDeviceResult) Read 

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

func (*TSIServiceInsertStringRecordsOfOneDeviceResult) ReadField0 

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

func (*TSIServiceInsertStringRecordsOfOneDeviceResult) String 

func (p *TSIServiceInsertStringRecordsOfOneDeviceResult) String() string

func (*TSIServiceInsertStringRecordsOfOneDeviceResult) Write 

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 

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

Attributes:

  • Req

func NewTSIServicePruneSchemaTemplateArgs 

func NewTSIServicePruneSchemaTemplateArgs() *TSIServicePruneSchemaTemplateArgs

func (*TSIServicePruneSchemaTemplateArgs) GetReq 

func (p *TSIServicePruneSchemaTemplateArgs) GetReq() *TSPruneSchemaTemplateReq

func (*TSIServicePruneSchemaTemplateArgs) IsSetReq 

func (p *TSIServicePruneSchemaTemplateArgs) IsSetReq() bool

func (*TSIServicePruneSchemaTemplateArgs) Read 

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

func (*TSIServicePruneSchemaTemplateArgs) ReadField1 

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

func (*TSIServicePruneSchemaTemplateArgs) String 

func (p *TSIServicePruneSchemaTemplateArgs) String() string

func (*TSIServicePruneSchemaTemplateArgs) Write 

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

type TSIServicePruneSchemaTemplateResult 

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

Attributes:

  • Success

func NewTSIServicePruneSchemaTemplateResult 

func NewTSIServicePruneSchemaTemplateResult() *TSIServicePruneSchemaTemplateResult

func (*TSIServicePruneSchemaTemplateResult) GetSuccess 

func (p *TSIServicePruneSchemaTemplateResult) GetSuccess() *TSStatus

func (*TSIServicePruneSchemaTemplateResult) IsSetSuccess 

func (p *TSIServicePruneSchemaTemplateResult) IsSetSuccess() bool

func (*TSIServicePruneSchemaTemplateResult) Read 

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

func (*TSIServicePruneSchemaTemplateResult) ReadField0 

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

func (*TSIServicePruneSchemaTemplateResult) String 

func (p *TSIServicePruneSchemaTemplateResult) String() string

func (*TSIServicePruneSchemaTemplateResult) Write 

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

type TSIServiceQuerySchemaTemplateArgs 

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

Attributes:

  • Req

func NewTSIServiceQuerySchemaTemplateArgs 

func NewTSIServiceQuerySchemaTemplateArgs() *TSIServiceQuerySchemaTemplateArgs

func (*TSIServiceQuerySchemaTemplateArgs) GetReq 

func (p *TSIServiceQuerySchemaTemplateArgs) GetReq() *TSQueryTemplateReq

func (*TSIServiceQuerySchemaTemplateArgs) IsSetReq 

func (p *TSIServiceQuerySchemaTemplateArgs) IsSetReq() bool

func (*TSIServiceQuerySchemaTemplateArgs) Read 

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

func (*TSIServiceQuerySchemaTemplateArgs) ReadField1 

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

func (*TSIServiceQuerySchemaTemplateArgs) String 

func (p *TSIServiceQuerySchemaTemplateArgs) String() string

func (*TSIServiceQuerySchemaTemplateArgs) Write 

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

type TSIServiceQuerySchemaTemplateResult 

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

Attributes:

  • Success

func NewTSIServiceQuerySchemaTemplateResult 

func NewTSIServiceQuerySchemaTemplateResult() *TSIServiceQuerySchemaTemplateResult

func (*TSIServiceQuerySchemaTemplateResult) GetSuccess 

func (p *TSIServiceQuerySchemaTemplateResult) GetSuccess() *TSQueryTemplateResp

func (*TSIServiceQuerySchemaTemplateResult) IsSetSuccess 

func (p *TSIServiceQuerySchemaTemplateResult) IsSetSuccess() bool

func (*TSIServiceQuerySchemaTemplateResult) Read 

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

func (*TSIServiceQuerySchemaTemplateResult) ReadField0 

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

func (*TSIServiceQuerySchemaTemplateResult) String 

func (p *TSIServiceQuerySchemaTemplateResult) String() string

func (*TSIServiceQuerySchemaTemplateResult) Write 

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 

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

Attributes:

  • Req

func NewTSIServiceSetSchemaTemplateArgs 

func NewTSIServiceSetSchemaTemplateArgs() *TSIServiceSetSchemaTemplateArgs

func (*TSIServiceSetSchemaTemplateArgs) GetReq 

func (p *TSIServiceSetSchemaTemplateArgs) GetReq() *TSSetSchemaTemplateReq

func (*TSIServiceSetSchemaTemplateArgs) IsSetReq 

func (p *TSIServiceSetSchemaTemplateArgs) IsSetReq() bool

func (*TSIServiceSetSchemaTemplateArgs) Read 

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

func (*TSIServiceSetSchemaTemplateArgs) ReadField1 

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

func (*TSIServiceSetSchemaTemplateArgs) String 

func (p *TSIServiceSetSchemaTemplateArgs) String() string

func (*TSIServiceSetSchemaTemplateArgs) Write 

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

type TSIServiceSetSchemaTemplateResult 

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

Attributes:

  • Success

func NewTSIServiceSetSchemaTemplateResult 

func NewTSIServiceSetSchemaTemplateResult() *TSIServiceSetSchemaTemplateResult

func (*TSIServiceSetSchemaTemplateResult) GetSuccess 

func (p *TSIServiceSetSchemaTemplateResult) GetSuccess() *TSStatus

func (*TSIServiceSetSchemaTemplateResult) IsSetSuccess 

func (p *TSIServiceSetSchemaTemplateResult) IsSetSuccess() bool

func (*TSIServiceSetSchemaTemplateResult) Read 

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

func (*TSIServiceSetSchemaTemplateResult) ReadField0 

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

func (*TSIServiceSetSchemaTemplateResult) String 

func (p *TSIServiceSetSchemaTemplateResult) String() string

func (*TSIServiceSetSchemaTemplateResult) Write 

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 

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

Attributes:

  • Req

func NewTSIServiceSetUsingTemplateArgs 

func NewTSIServiceSetUsingTemplateArgs() *TSIServiceSetUsingTemplateArgs

func (*TSIServiceSetUsingTemplateArgs) GetReq 

func (p *TSIServiceSetUsingTemplateArgs) GetReq() *TSSetUsingTemplateReq

func (*TSIServiceSetUsingTemplateArgs) IsSetReq 

func (p *TSIServiceSetUsingTemplateArgs) IsSetReq() bool

func (*TSIServiceSetUsingTemplateArgs) Read 

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

func (*TSIServiceSetUsingTemplateArgs) ReadField1 

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

func (*TSIServiceSetUsingTemplateArgs) String 

func (p *TSIServiceSetUsingTemplateArgs) String() string

func (*TSIServiceSetUsingTemplateArgs) Write 

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

type TSIServiceSetUsingTemplateResult 

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

Attributes:

  • Success

func NewTSIServiceSetUsingTemplateResult 

func NewTSIServiceSetUsingTemplateResult() *TSIServiceSetUsingTemplateResult

func (*TSIServiceSetUsingTemplateResult) GetSuccess 

func (p *TSIServiceSetUsingTemplateResult) GetSuccess() *TSStatus

func (*TSIServiceSetUsingTemplateResult) IsSetSuccess 

func (p *TSIServiceSetUsingTemplateResult) IsSetSuccess() bool

func (*TSIServiceSetUsingTemplateResult) Read 

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

func (*TSIServiceSetUsingTemplateResult) ReadField0 

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

func (*TSIServiceSetUsingTemplateResult) String 

func (p *TSIServiceSetUsingTemplateResult) String() string

func (*TSIServiceSetUsingTemplateResult) Write 

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 

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

Attributes:

  • Req

func NewTSIServiceUnsetSchemaTemplateArgs 

func NewTSIServiceUnsetSchemaTemplateArgs() *TSIServiceUnsetSchemaTemplateArgs

func (*TSIServiceUnsetSchemaTemplateArgs) GetReq 

func (p *TSIServiceUnsetSchemaTemplateArgs) GetReq() *TSUnsetSchemaTemplateReq

func (*TSIServiceUnsetSchemaTemplateArgs) IsSetReq 

func (p *TSIServiceUnsetSchemaTemplateArgs) IsSetReq() bool

func (*TSIServiceUnsetSchemaTemplateArgs) Read 

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

func (*TSIServiceUnsetSchemaTemplateArgs) ReadField1 

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

func (*TSIServiceUnsetSchemaTemplateArgs) String 

func (p *TSIServiceUnsetSchemaTemplateArgs) String() string

func (*TSIServiceUnsetSchemaTemplateArgs) Write 

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

type TSIServiceUnsetSchemaTemplateResult 

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

Attributes:

  • Success

func NewTSIServiceUnsetSchemaTemplateResult 

func NewTSIServiceUnsetSchemaTemplateResult() *TSIServiceUnsetSchemaTemplateResult

func (*TSIServiceUnsetSchemaTemplateResult) GetSuccess 

func (p *TSIServiceUnsetSchemaTemplateResult) GetSuccess() *TSStatus

func (*TSIServiceUnsetSchemaTemplateResult) IsSetSuccess 

func (p *TSIServiceUnsetSchemaTemplateResult) IsSetSuccess() bool

func (*TSIServiceUnsetSchemaTemplateResult) Read 

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

func (*TSIServiceUnsetSchemaTemplateResult) ReadField0 

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

func (*TSIServiceUnsetSchemaTemplateResult) String 

func (p *TSIServiceUnsetSchemaTemplateResult) String() string

func (*TSIServiceUnsetSchemaTemplateResult) Write 

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

type TSIServiceUnsetUsingTemplateArgs 

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 

func NewTSIServiceUnsetUsingTemplateArgs() *TSIServiceUnsetUsingTemplateArgs

func (*TSIServiceUnsetUsingTemplateArgs) GetPrefixPath 

func (p *TSIServiceUnsetUsingTemplateArgs) GetPrefixPath() string

func (*TSIServiceUnsetUsingTemplateArgs) GetSessionId 

func (p *TSIServiceUnsetUsingTemplateArgs) GetSessionId() int64

func (*TSIServiceUnsetUsingTemplateArgs) GetTemplateName 

func (p *TSIServiceUnsetUsingTemplateArgs) GetTemplateName() string

func (*TSIServiceUnsetUsingTemplateArgs) Read 

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

func (*TSIServiceUnsetUsingTemplateArgs) ReadField1 

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

func (*TSIServiceUnsetUsingTemplateArgs) ReadField2 

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

func (*TSIServiceUnsetUsingTemplateArgs) ReadField3 

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

func (*TSIServiceUnsetUsingTemplateArgs) String 

func (p *TSIServiceUnsetUsingTemplateArgs) String() string

func (*TSIServiceUnsetUsingTemplateArgs) Write 

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

type TSIServiceUnsetUsingTemplateResult 

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

Attributes:

  • Success

func NewTSIServiceUnsetUsingTemplateResult 

func NewTSIServiceUnsetUsingTemplateResult() *TSIServiceUnsetUsingTemplateResult

func (*TSIServiceUnsetUsingTemplateResult) GetSuccess 

func (p *TSIServiceUnsetUsingTemplateResult) GetSuccess() *TSStatus

func (*TSIServiceUnsetUsingTemplateResult) IsSetSuccess 

func (p *TSIServiceUnsetUsingTemplateResult) IsSetSuccess() bool

func (*TSIServiceUnsetUsingTemplateResult) Read 

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

func (*TSIServiceUnsetUsingTemplateResult) ReadField0 

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

func (*TSIServiceUnsetUsingTemplateResult) String 

func (p *TSIServiceUnsetUsingTemplateResult) String() string

func (*TSIServiceUnsetUsingTemplateResult) Write 

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 

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

func (*TSInsertRecordReq) GetIsAligned 

func (p *TSInsertRecordReq) GetIsAligned() bool

func (*TSInsertRecordReq) GetMeasurements 

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

func (*TSInsertRecordReq) GetPrefixPath 

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 

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 

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 

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

func (*TSInsertRecordsOfOneDeviceReq) GetIsAligned 

func (p *TSInsertRecordsOfOneDeviceReq) GetIsAligned() bool

func (*TSInsertRecordsOfOneDeviceReq) GetMeasurementsList 

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

func (*TSInsertRecordsOfOneDeviceReq) GetPrefixPath 

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 

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 

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 

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

func (*TSInsertRecordsReq) GetIsAligned 

func (p *TSInsertRecordsReq) GetIsAligned() bool

func (*TSInsertRecordsReq) GetMeasurementsList 

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

func (*TSInsertRecordsReq) GetPrefixPaths 

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 

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 

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 

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

func (*TSInsertStringRecordReq) GetIsAligned 

func (p *TSInsertStringRecordReq) GetIsAligned() bool

func (*TSInsertStringRecordReq) GetMeasurements 

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

func (*TSInsertStringRecordReq) GetPrefixPath 

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 

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 

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 

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 

func NewTSInsertStringRecordsOfOneDeviceReq() *TSInsertStringRecordsOfOneDeviceReq

func (*TSInsertStringRecordsOfOneDeviceReq) Equals 

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

func (*TSInsertStringRecordsOfOneDeviceReq) GetIsAligned 

func (p *TSInsertStringRecordsOfOneDeviceReq) GetIsAligned() bool

func (*TSInsertStringRecordsOfOneDeviceReq) GetMeasurementsList 

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

func (*TSInsertStringRecordsOfOneDeviceReq) GetPrefixPath 

func (p *TSInsertStringRecordsOfOneDeviceReq) GetPrefixPath() string

func (*TSInsertStringRecordsOfOneDeviceReq) GetSessionId 

func (p *TSInsertStringRecordsOfOneDeviceReq) GetSessionId() int64

func (*TSInsertStringRecordsOfOneDeviceReq) GetTimestamps 

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

func (*TSInsertStringRecordsOfOneDeviceReq) GetValuesList 

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

func (*TSInsertStringRecordsOfOneDeviceReq) IsSetIsAligned 

func (p *TSInsertStringRecordsOfOneDeviceReq) IsSetIsAligned() bool

func (*TSInsertStringRecordsOfOneDeviceReq) Read 

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

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField1 

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

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField2 

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

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField3 

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

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField4 

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

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField5 

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

func (*TSInsertStringRecordsOfOneDeviceReq) ReadField6 

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

func (*TSInsertStringRecordsOfOneDeviceReq) String 

func (p *TSInsertStringRecordsOfOneDeviceReq) String() string

func (*TSInsertStringRecordsOfOneDeviceReq) Write 

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 

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

func (*TSInsertStringRecordsReq) GetIsAligned 

func (p *TSInsertStringRecordsReq) GetIsAligned() bool

func (*TSInsertStringRecordsReq) GetMeasurementsList 

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

func (*TSInsertStringRecordsReq) GetPrefixPaths 

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 

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 

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 

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

func (*TSInsertTabletReq) GetIsAligned 

func (p *TSInsertTabletReq) GetIsAligned() bool

func (*TSInsertTabletReq) GetMeasurements 

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

func (*TSInsertTabletReq) GetPrefixPath 

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 

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 

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 

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

func (*TSInsertTabletsReq) GetIsAligned 

func (p *TSInsertTabletsReq) GetIsAligned() bool

func (*TSInsertTabletsReq) GetMeasurementsList 

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

func (*TSInsertTabletsReq) GetPrefixPaths 

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 

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 

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 

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 

func NewTSLastDataQueryReq() *TSLastDataQueryReq

func (*TSLastDataQueryReq) Equals 

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

func (*TSLastDataQueryReq) GetEnableRedirectQuery 

func (p *TSLastDataQueryReq) GetEnableRedirectQuery() bool

func (*TSLastDataQueryReq) GetFetchSize 

func (p *TSLastDataQueryReq) GetFetchSize() int32

func (*TSLastDataQueryReq) GetJdbcQuery 

func (p *TSLastDataQueryReq) GetJdbcQuery() bool

func (*TSLastDataQueryReq) GetPaths 

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

func (*TSLastDataQueryReq) GetSessionId 

func (p *TSLastDataQueryReq) GetSessionId() int64

func (*TSLastDataQueryReq) GetStatementId 

func (p *TSLastDataQueryReq) GetStatementId() int64

func (*TSLastDataQueryReq) GetTime 

func (p *TSLastDataQueryReq) GetTime() int64

func (*TSLastDataQueryReq) IsSetEnableRedirectQuery 

func (p *TSLastDataQueryReq) IsSetEnableRedirectQuery() bool

func (*TSLastDataQueryReq) IsSetFetchSize 

func (p *TSLastDataQueryReq) IsSetFetchSize() bool

func (*TSLastDataQueryReq) IsSetJdbcQuery 

func (p *TSLastDataQueryReq) IsSetJdbcQuery() bool

func (*TSLastDataQueryReq) Read 

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

func (*TSLastDataQueryReq) ReadField1 

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

func (*TSLastDataQueryReq) ReadField2 

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

func (*TSLastDataQueryReq) ReadField3 

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

func (*TSLastDataQueryReq) ReadField4 

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

func (*TSLastDataQueryReq) ReadField5 

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

func (*TSLastDataQueryReq) ReadField6 

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

func (*TSLastDataQueryReq) ReadField7 

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

func (*TSLastDataQueryReq) String 

func (p *TSLastDataQueryReq) String() string

func (*TSLastDataQueryReq) Write 

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 

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 

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 

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 

func NewTSOperationSyncWriteReq() *TSOperationSyncWriteReq

func (*TSOperationSyncWriteReq) Equals 

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

func (*TSOperationSyncWriteReq) GetOperationSyncType 

func (p *TSOperationSyncWriteReq) GetOperationSyncType() int8

func (*TSOperationSyncWriteReq) GetPhysicalPlan 

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

func (*TSOperationSyncWriteReq) GetSessionId 

func (p *TSOperationSyncWriteReq) GetSessionId() int64

func (*TSOperationSyncWriteReq) Read 

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

func (*TSOperationSyncWriteReq) ReadField1 

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

func (*TSOperationSyncWriteReq) ReadField2 

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

func (*TSOperationSyncWriteReq) ReadField3 

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

func (*TSOperationSyncWriteReq) String 

func (p *TSOperationSyncWriteReq) String() string

func (*TSOperationSyncWriteReq) Write 

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 

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 

func NewTSPruneSchemaTemplateReq() *TSPruneSchemaTemplateReq

func (*TSPruneSchemaTemplateReq) Equals 

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

func (*TSPruneSchemaTemplateReq) GetName 

func (p *TSPruneSchemaTemplateReq) GetName() string

func (*TSPruneSchemaTemplateReq) GetPath 

func (p *TSPruneSchemaTemplateReq) GetPath() string

func (*TSPruneSchemaTemplateReq) GetSessionId 

func (p *TSPruneSchemaTemplateReq) GetSessionId() int64

func (*TSPruneSchemaTemplateReq) Read 

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

func (*TSPruneSchemaTemplateReq) ReadField1 

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

func (*TSPruneSchemaTemplateReq) ReadField2 

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

func (*TSPruneSchemaTemplateReq) ReadField3 

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

func (*TSPruneSchemaTemplateReq) String 

func (p *TSPruneSchemaTemplateReq) String() string

func (*TSPruneSchemaTemplateReq) Write 

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 

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 

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 

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 

func NewTSQueryTemplateReq() *TSQueryTemplateReq

func (*TSQueryTemplateReq) Equals 

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

func (*TSQueryTemplateReq) GetMeasurement 

func (p *TSQueryTemplateReq) GetMeasurement() string

func (*TSQueryTemplateReq) GetName 

func (p *TSQueryTemplateReq) GetName() string

func (*TSQueryTemplateReq) GetQueryType 

func (p *TSQueryTemplateReq) GetQueryType() int32

func (*TSQueryTemplateReq) GetSessionId 

func (p *TSQueryTemplateReq) GetSessionId() int64

func (*TSQueryTemplateReq) IsSetMeasurement 

func (p *TSQueryTemplateReq) IsSetMeasurement() bool

func (*TSQueryTemplateReq) Read 

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

func (*TSQueryTemplateReq) ReadField1 

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

func (*TSQueryTemplateReq) ReadField2 

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

func (*TSQueryTemplateReq) ReadField3 

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

func (*TSQueryTemplateReq) ReadField4 

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

func (*TSQueryTemplateReq) String 

func (p *TSQueryTemplateReq) String() string

func (*TSQueryTemplateReq) Write 

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

type TSQueryTemplateResp 

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 

func NewTSQueryTemplateResp() *TSQueryTemplateResp

func (*TSQueryTemplateResp) Equals 

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

func (*TSQueryTemplateResp) GetCount 

func (p *TSQueryTemplateResp) GetCount() int32

func (*TSQueryTemplateResp) GetMeasurements 

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

func (*TSQueryTemplateResp) GetQueryType 

func (p *TSQueryTemplateResp) GetQueryType() int32

func (*TSQueryTemplateResp) GetResult_ 

func (p *TSQueryTemplateResp) GetResult_() bool

func (*TSQueryTemplateResp) GetStatus 

func (p *TSQueryTemplateResp) GetStatus() *TSStatus

func (*TSQueryTemplateResp) IsSetCount 

func (p *TSQueryTemplateResp) IsSetCount() bool

func (*TSQueryTemplateResp) IsSetMeasurements 

func (p *TSQueryTemplateResp) IsSetMeasurements() bool

func (*TSQueryTemplateResp) IsSetResult_ 

func (p *TSQueryTemplateResp) IsSetResult_() bool

func (*TSQueryTemplateResp) IsSetStatus 

func (p *TSQueryTemplateResp) IsSetStatus() bool

func (*TSQueryTemplateResp) Read 

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

func (*TSQueryTemplateResp) ReadField1 

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

func (*TSQueryTemplateResp) ReadField2 

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

func (*TSQueryTemplateResp) ReadField3 

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

func (*TSQueryTemplateResp) ReadField4 

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

func (*TSQueryTemplateResp) ReadField5 

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

func (*TSQueryTemplateResp) String 

func (p *TSQueryTemplateResp) String() string

func (*TSQueryTemplateResp) Write 

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 

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

func (*TSRawDataQueryReq) GetEnableRedirectQuery 

func (p *TSRawDataQueryReq) GetEnableRedirectQuery() bool

func (*TSRawDataQueryReq) GetEndTime 

func (p *TSRawDataQueryReq) GetEndTime() int64

func (*TSRawDataQueryReq) GetFetchSize 

func (p *TSRawDataQueryReq) GetFetchSize() int32

func (*TSRawDataQueryReq) GetJdbcQuery 

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 

func (p *TSRawDataQueryReq) IsSetEnableRedirectQuery() bool

func (*TSRawDataQueryReq) IsSetFetchSize 

func (p *TSRawDataQueryReq) IsSetFetchSize() bool

func (*TSRawDataQueryReq) IsSetJdbcQuery 

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 

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

func (*TSRawDataQueryReq) ReadField8 

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 

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 

func NewTSSetSchemaTemplateReq() *TSSetSchemaTemplateReq

func (*TSSetSchemaTemplateReq) Equals 

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

func (*TSSetSchemaTemplateReq) GetPrefixPath 

func (p *TSSetSchemaTemplateReq) GetPrefixPath() string

func (*TSSetSchemaTemplateReq) GetSessionId 

func (p *TSSetSchemaTemplateReq) GetSessionId() int64

func (*TSSetSchemaTemplateReq) GetTemplateName 

func (p *TSSetSchemaTemplateReq) GetTemplateName() string

func (*TSSetSchemaTemplateReq) Read 

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

func (*TSSetSchemaTemplateReq) ReadField1 

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

func (*TSSetSchemaTemplateReq) ReadField2 

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

func (*TSSetSchemaTemplateReq) ReadField3 

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

func (*TSSetSchemaTemplateReq) String 

func (p *TSSetSchemaTemplateReq) String() string

func (*TSSetSchemaTemplateReq) Write 

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 

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 

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 

func NewTSSetUsingTemplateReq() *TSSetUsingTemplateReq

func (*TSSetUsingTemplateReq) Equals 

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

func (*TSSetUsingTemplateReq) GetDstPath 

func (p *TSSetUsingTemplateReq) GetDstPath() string

func (*TSSetUsingTemplateReq) GetSessionId 

func (p *TSSetUsingTemplateReq) GetSessionId() int64

func (*TSSetUsingTemplateReq) Read 

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

func (*TSSetUsingTemplateReq) ReadField1 

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

func (*TSSetUsingTemplateReq) ReadField2 

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

func (*TSSetUsingTemplateReq) String 

func (p *TSSetUsingTemplateReq) String() string

func (*TSSetUsingTemplateReq) Write 

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 

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 

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 

func NewTSTracingInfo() *TSTracingInfo

func (*TSTracingInfo) Equals 

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

func (*TSTracingInfo) GetActivityList 

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

func (*TSTracingInfo) GetElapsedTimeList 

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

func (*TSTracingInfo) GetOverlappedPageNum 

func (p *TSTracingInfo) GetOverlappedPageNum() int32

func (*TSTracingInfo) GetSeqFileNum 

func (p *TSTracingInfo) GetSeqFileNum() int32

func (*TSTracingInfo) GetSequenceChunkNum 

func (p *TSTracingInfo) GetSequenceChunkNum() int32

func (*TSTracingInfo) GetSequenceChunkPointNum 

func (p *TSTracingInfo) GetSequenceChunkPointNum() int64

func (*TSTracingInfo) GetSeriesPathNum 

func (p *TSTracingInfo) GetSeriesPathNum() int32

func (*TSTracingInfo) GetTotalPageNum 

func (p *TSTracingInfo) GetTotalPageNum() int32

func (*TSTracingInfo) GetUnSeqFileNum 

func (p *TSTracingInfo) GetUnSeqFileNum() int32

func (*TSTracingInfo) GetUnsequenceChunkNum 

func (p *TSTracingInfo) GetUnsequenceChunkNum() int32

func (*TSTracingInfo) GetUnsequenceChunkPointNum 

func (p *TSTracingInfo) GetUnsequenceChunkPointNum() int64

func (*TSTracingInfo) IsSetOverlappedPageNum 

func (p *TSTracingInfo) IsSetOverlappedPageNum() bool

func (*TSTracingInfo) IsSetSeqFileNum 

func (p *TSTracingInfo) IsSetSeqFileNum() bool

func (*TSTracingInfo) IsSetSequenceChunkNum 

func (p *TSTracingInfo) IsSetSequenceChunkNum() bool

func (*TSTracingInfo) IsSetSequenceChunkPointNum 

func (p *TSTracingInfo) IsSetSequenceChunkPointNum() bool

func (*TSTracingInfo) IsSetSeriesPathNum 

func (p *TSTracingInfo) IsSetSeriesPathNum() bool

func (*TSTracingInfo) IsSetTotalPageNum 

func (p *TSTracingInfo) IsSetTotalPageNum() bool

func (*TSTracingInfo) IsSetUnSeqFileNum 

func (p *TSTracingInfo) IsSetUnSeqFileNum() bool

func (*TSTracingInfo) IsSetUnsequenceChunkNum 

func (p *TSTracingInfo) IsSetUnsequenceChunkNum() bool

func (*TSTracingInfo) IsSetUnsequenceChunkPointNum 

func (p *TSTracingInfo) IsSetUnsequenceChunkPointNum() bool

func (*TSTracingInfo) Read 

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

func (*TSTracingInfo) ReadField1 

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

func (*TSTracingInfo) ReadField10 

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

func (*TSTracingInfo) ReadField11 

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

func (*TSTracingInfo) ReadField2 

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

func (*TSTracingInfo) ReadField3 

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

func (*TSTracingInfo) ReadField4 

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

func (*TSTracingInfo) ReadField5 

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

func (*TSTracingInfo) ReadField6 

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

func (*TSTracingInfo) ReadField7 

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

func (*TSTracingInfo) ReadField8 

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

func (*TSTracingInfo) ReadField9 

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

func (*TSTracingInfo) String 

func (p *TSTracingInfo) String() string

func (*TSTracingInfo) Write 

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

type TSUnsetSchemaTemplateReq 

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 

func NewTSUnsetSchemaTemplateReq() *TSUnsetSchemaTemplateReq

func (*TSUnsetSchemaTemplateReq) Equals 

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

func (*TSUnsetSchemaTemplateReq) GetPrefixPath 

func (p *TSUnsetSchemaTemplateReq) GetPrefixPath() string

func (*TSUnsetSchemaTemplateReq) GetSessionId 

func (p *TSUnsetSchemaTemplateReq) GetSessionId() int64

func (*TSUnsetSchemaTemplateReq) GetTemplateName 

func (p *TSUnsetSchemaTemplateReq) GetTemplateName() string

func (*TSUnsetSchemaTemplateReq) Read 

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

func (*TSUnsetSchemaTemplateReq) ReadField1 

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

func (*TSUnsetSchemaTemplateReq) ReadField2 

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

func (*TSUnsetSchemaTemplateReq) ReadField3 

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

func (*TSUnsetSchemaTemplateReq) String 

func (p *TSUnsetSchemaTemplateReq) String() string

func (*TSUnsetSchemaTemplateReq) Write 

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

Source Files

View all Source files

Directories

Path Synopsis

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.