Documentation ¶
Index ¶
- Variables
- type ServerProperties
- func (p *ServerProperties) GetSupportedTimeAggregationOperations() []string
- func (p *ServerProperties) GetTimestampPrecision() string
- func (p *ServerProperties) GetVersion() string
- func (p *ServerProperties) Read(iprot thrift.TProtocol) error
- func (p *ServerProperties) ReadField1(iprot thrift.TProtocol) error
- func (p *ServerProperties) ReadField2(iprot thrift.TProtocol) error
- func (p *ServerProperties) ReadField3(iprot thrift.TProtocol) error
- func (p *ServerProperties) String() string
- func (p *ServerProperties) Write(oprot thrift.TProtocol) error
- type TSCancelOperationReq
- func (p *TSCancelOperationReq) GetQueryId() int64
- func (p *TSCancelOperationReq) GetSessionId() int64
- func (p *TSCancelOperationReq) Read(iprot thrift.TProtocol) error
- func (p *TSCancelOperationReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSCancelOperationReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSCancelOperationReq) String() string
- func (p *TSCancelOperationReq) Write(oprot thrift.TProtocol) error
- type TSCloseOperationReq
- func (p *TSCloseOperationReq) GetQueryId() int64
- func (p *TSCloseOperationReq) GetSessionId() int64
- func (p *TSCloseOperationReq) GetStatementId() int64
- func (p *TSCloseOperationReq) IsSetQueryId() bool
- func (p *TSCloseOperationReq) IsSetStatementId() bool
- func (p *TSCloseOperationReq) Read(iprot thrift.TProtocol) error
- func (p *TSCloseOperationReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSCloseOperationReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSCloseOperationReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSCloseOperationReq) String() string
- func (p *TSCloseOperationReq) Write(oprot thrift.TProtocol) error
- type TSCloseSessionReq
- type TSCreateMultiTimeseriesReq
- func (p *TSCreateMultiTimeseriesReq) GetAttributesList() []map[string]string
- func (p *TSCreateMultiTimeseriesReq) GetCompressors() []int32
- func (p *TSCreateMultiTimeseriesReq) GetDataTypes() []int32
- func (p *TSCreateMultiTimeseriesReq) GetEncodings() []int32
- func (p *TSCreateMultiTimeseriesReq) GetMeasurementAliasList() []string
- func (p *TSCreateMultiTimeseriesReq) GetPaths() []string
- func (p *TSCreateMultiTimeseriesReq) GetPropsList() []map[string]string
- func (p *TSCreateMultiTimeseriesReq) GetSessionId() int64
- func (p *TSCreateMultiTimeseriesReq) GetTagsList() []map[string]string
- func (p *TSCreateMultiTimeseriesReq) IsSetAttributesList() bool
- func (p *TSCreateMultiTimeseriesReq) IsSetMeasurementAliasList() bool
- func (p *TSCreateMultiTimeseriesReq) IsSetPropsList() bool
- func (p *TSCreateMultiTimeseriesReq) IsSetTagsList() bool
- func (p *TSCreateMultiTimeseriesReq) Read(iprot thrift.TProtocol) error
- func (p *TSCreateMultiTimeseriesReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSCreateMultiTimeseriesReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSCreateMultiTimeseriesReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSCreateMultiTimeseriesReq) ReadField4(iprot thrift.TProtocol) error
- func (p *TSCreateMultiTimeseriesReq) ReadField5(iprot thrift.TProtocol) error
- func (p *TSCreateMultiTimeseriesReq) ReadField6(iprot thrift.TProtocol) error
- func (p *TSCreateMultiTimeseriesReq) ReadField7(iprot thrift.TProtocol) error
- func (p *TSCreateMultiTimeseriesReq) ReadField8(iprot thrift.TProtocol) error
- func (p *TSCreateMultiTimeseriesReq) ReadField9(iprot thrift.TProtocol) error
- func (p *TSCreateMultiTimeseriesReq) String() string
- func (p *TSCreateMultiTimeseriesReq) Write(oprot thrift.TProtocol) error
- type TSCreateTimeseriesReq
- func (p *TSCreateTimeseriesReq) GetAttributes() map[string]string
- func (p *TSCreateTimeseriesReq) GetCompressor() int32
- func (p *TSCreateTimeseriesReq) GetDataType() int32
- func (p *TSCreateTimeseriesReq) GetEncoding() int32
- func (p *TSCreateTimeseriesReq) GetMeasurementAlias() string
- func (p *TSCreateTimeseriesReq) GetPath() string
- func (p *TSCreateTimeseriesReq) GetProps() map[string]string
- func (p *TSCreateTimeseriesReq) GetSessionId() int64
- func (p *TSCreateTimeseriesReq) GetTags() map[string]string
- func (p *TSCreateTimeseriesReq) IsSetAttributes() bool
- func (p *TSCreateTimeseriesReq) IsSetMeasurementAlias() bool
- func (p *TSCreateTimeseriesReq) IsSetProps() bool
- func (p *TSCreateTimeseriesReq) IsSetTags() bool
- func (p *TSCreateTimeseriesReq) Read(iprot thrift.TProtocol) error
- func (p *TSCreateTimeseriesReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSCreateTimeseriesReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSCreateTimeseriesReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSCreateTimeseriesReq) ReadField4(iprot thrift.TProtocol) error
- func (p *TSCreateTimeseriesReq) ReadField5(iprot thrift.TProtocol) error
- func (p *TSCreateTimeseriesReq) ReadField6(iprot thrift.TProtocol) error
- func (p *TSCreateTimeseriesReq) ReadField7(iprot thrift.TProtocol) error
- func (p *TSCreateTimeseriesReq) ReadField8(iprot thrift.TProtocol) error
- func (p *TSCreateTimeseriesReq) ReadField9(iprot thrift.TProtocol) error
- func (p *TSCreateTimeseriesReq) String() string
- func (p *TSCreateTimeseriesReq) Write(oprot thrift.TProtocol) error
- type TSDeleteDataReq
- func (p *TSDeleteDataReq) GetEndTime() int64
- func (p *TSDeleteDataReq) GetPaths() []string
- func (p *TSDeleteDataReq) GetSessionId() int64
- func (p *TSDeleteDataReq) GetStartTime() int64
- func (p *TSDeleteDataReq) Read(iprot thrift.TProtocol) error
- func (p *TSDeleteDataReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSDeleteDataReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSDeleteDataReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSDeleteDataReq) ReadField4(iprot thrift.TProtocol) error
- func (p *TSDeleteDataReq) String() string
- func (p *TSDeleteDataReq) Write(oprot thrift.TProtocol) error
- type TSExecuteBatchStatementReq
- func (p *TSExecuteBatchStatementReq) GetSessionId() int64
- func (p *TSExecuteBatchStatementReq) GetStatements() []string
- func (p *TSExecuteBatchStatementReq) Read(iprot thrift.TProtocol) error
- func (p *TSExecuteBatchStatementReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSExecuteBatchStatementReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSExecuteBatchStatementReq) String() string
- func (p *TSExecuteBatchStatementReq) Write(oprot thrift.TProtocol) error
- type TSExecuteStatementReq
- func (p *TSExecuteStatementReq) GetFetchSize() int32
- func (p *TSExecuteStatementReq) GetSessionId() int64
- func (p *TSExecuteStatementReq) GetStatement() string
- func (p *TSExecuteStatementReq) GetStatementId() int64
- func (p *TSExecuteStatementReq) IsSetFetchSize() bool
- func (p *TSExecuteStatementReq) Read(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementReq) ReadField4(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementReq) String() string
- func (p *TSExecuteStatementReq) Write(oprot thrift.TProtocol) error
- type TSExecuteStatementResp
- func (p *TSExecuteStatementResp) GetColumnNameIndexMap() map[string]int32
- func (p *TSExecuteStatementResp) GetColumns() []string
- func (p *TSExecuteStatementResp) GetDataTypeList() []string
- func (p *TSExecuteStatementResp) GetIgnoreTimeStamp() bool
- func (p *TSExecuteStatementResp) GetNonAlignQueryDataSet() *TSQueryNonAlignDataSet
- func (p *TSExecuteStatementResp) GetOperationType() string
- func (p *TSExecuteStatementResp) GetQueryDataSet() *TSQueryDataSet
- func (p *TSExecuteStatementResp) GetQueryId() int64
- func (p *TSExecuteStatementResp) GetStatus() *TSStatus
- func (p *TSExecuteStatementResp) IsSetColumnNameIndexMap() bool
- func (p *TSExecuteStatementResp) IsSetColumns() bool
- func (p *TSExecuteStatementResp) IsSetDataTypeList() bool
- func (p *TSExecuteStatementResp) IsSetIgnoreTimeStamp() bool
- func (p *TSExecuteStatementResp) IsSetNonAlignQueryDataSet() bool
- func (p *TSExecuteStatementResp) IsSetOperationType() bool
- func (p *TSExecuteStatementResp) IsSetQueryDataSet() bool
- func (p *TSExecuteStatementResp) IsSetQueryId() bool
- func (p *TSExecuteStatementResp) IsSetStatus() bool
- func (p *TSExecuteStatementResp) Read(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementResp) ReadField1(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementResp) ReadField2(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementResp) ReadField3(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementResp) ReadField4(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementResp) ReadField5(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementResp) ReadField6(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementResp) ReadField7(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementResp) ReadField8(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementResp) ReadField9(iprot thrift.TProtocol) error
- func (p *TSExecuteStatementResp) String() string
- func (p *TSExecuteStatementResp) Write(oprot thrift.TProtocol) error
- type TSFetchMetadataReq
- func (p *TSFetchMetadataReq) GetColumnPath() string
- func (p *TSFetchMetadataReq) GetSessionId() int64
- func (p *TSFetchMetadataReq) GetType() string
- func (p *TSFetchMetadataReq) IsSetColumnPath() bool
- func (p *TSFetchMetadataReq) Read(iprot thrift.TProtocol) error
- func (p *TSFetchMetadataReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSFetchMetadataReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSFetchMetadataReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSFetchMetadataReq) String() string
- func (p *TSFetchMetadataReq) Write(oprot thrift.TProtocol) error
- type TSFetchMetadataResp
- func (p *TSFetchMetadataResp) GetColumnsList() []string
- func (p *TSFetchMetadataResp) GetDataType() string
- func (p *TSFetchMetadataResp) GetMetadataInJson() string
- func (p *TSFetchMetadataResp) GetStatus() *TSStatus
- func (p *TSFetchMetadataResp) IsSetColumnsList() bool
- func (p *TSFetchMetadataResp) IsSetDataType() bool
- func (p *TSFetchMetadataResp) IsSetMetadataInJson() bool
- func (p *TSFetchMetadataResp) IsSetStatus() bool
- func (p *TSFetchMetadataResp) Read(iprot thrift.TProtocol) error
- func (p *TSFetchMetadataResp) ReadField1(iprot thrift.TProtocol) error
- func (p *TSFetchMetadataResp) ReadField2(iprot thrift.TProtocol) error
- func (p *TSFetchMetadataResp) ReadField3(iprot thrift.TProtocol) error
- func (p *TSFetchMetadataResp) ReadField4(iprot thrift.TProtocol) error
- func (p *TSFetchMetadataResp) String() string
- func (p *TSFetchMetadataResp) Write(oprot thrift.TProtocol) error
- type TSFetchResultsReq
- func (p *TSFetchResultsReq) GetFetchSize() int32
- func (p *TSFetchResultsReq) GetIsAlign() bool
- func (p *TSFetchResultsReq) GetQueryId() int64
- func (p *TSFetchResultsReq) GetSessionId() int64
- func (p *TSFetchResultsReq) GetStatement() string
- func (p *TSFetchResultsReq) Read(iprot thrift.TProtocol) error
- func (p *TSFetchResultsReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSFetchResultsReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSFetchResultsReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSFetchResultsReq) ReadField4(iprot thrift.TProtocol) error
- func (p *TSFetchResultsReq) ReadField5(iprot thrift.TProtocol) error
- func (p *TSFetchResultsReq) String() string
- func (p *TSFetchResultsReq) Write(oprot thrift.TProtocol) error
- type TSFetchResultsResp
- func (p *TSFetchResultsResp) GetHasResultSet() bool
- func (p *TSFetchResultsResp) GetIsAlign() bool
- func (p *TSFetchResultsResp) GetNonAlignQueryDataSet() *TSQueryNonAlignDataSet
- func (p *TSFetchResultsResp) GetQueryDataSet() *TSQueryDataSet
- func (p *TSFetchResultsResp) GetStatus() *TSStatus
- func (p *TSFetchResultsResp) IsSetNonAlignQueryDataSet() bool
- func (p *TSFetchResultsResp) IsSetQueryDataSet() bool
- func (p *TSFetchResultsResp) IsSetStatus() bool
- func (p *TSFetchResultsResp) Read(iprot thrift.TProtocol) error
- func (p *TSFetchResultsResp) ReadField1(iprot thrift.TProtocol) error
- func (p *TSFetchResultsResp) ReadField2(iprot thrift.TProtocol) error
- func (p *TSFetchResultsResp) ReadField3(iprot thrift.TProtocol) error
- func (p *TSFetchResultsResp) ReadField4(iprot thrift.TProtocol) error
- func (p *TSFetchResultsResp) ReadField5(iprot thrift.TProtocol) error
- func (p *TSFetchResultsResp) String() string
- func (p *TSFetchResultsResp) Write(oprot thrift.TProtocol) error
- type TSGetOperationStatusReq
- func (p *TSGetOperationStatusReq) GetQueryId() int64
- func (p *TSGetOperationStatusReq) GetSessionId() int64
- func (p *TSGetOperationStatusReq) Read(iprot thrift.TProtocol) error
- func (p *TSGetOperationStatusReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSGetOperationStatusReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSGetOperationStatusReq) String() string
- func (p *TSGetOperationStatusReq) Write(oprot thrift.TProtocol) error
- type TSGetTimeZoneResp
- func (p *TSGetTimeZoneResp) GetStatus() *TSStatus
- func (p *TSGetTimeZoneResp) GetTimeZone() string
- func (p *TSGetTimeZoneResp) IsSetStatus() bool
- func (p *TSGetTimeZoneResp) Read(iprot thrift.TProtocol) error
- func (p *TSGetTimeZoneResp) ReadField1(iprot thrift.TProtocol) error
- func (p *TSGetTimeZoneResp) ReadField2(iprot thrift.TProtocol) error
- func (p *TSGetTimeZoneResp) String() string
- func (p *TSGetTimeZoneResp) Write(oprot thrift.TProtocol) error
- type TSIService
- type TSIServiceCancelOperationArgs
- func (p *TSIServiceCancelOperationArgs) GetReq() *TSCancelOperationReq
- func (p *TSIServiceCancelOperationArgs) IsSetReq() bool
- func (p *TSIServiceCancelOperationArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceCancelOperationArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceCancelOperationArgs) String() string
- func (p *TSIServiceCancelOperationArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceCancelOperationResult
- func (p *TSIServiceCancelOperationResult) GetSuccess() *TSStatus
- func (p *TSIServiceCancelOperationResult) IsSetSuccess() bool
- func (p *TSIServiceCancelOperationResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceCancelOperationResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceCancelOperationResult) String() string
- func (p *TSIServiceCancelOperationResult) Write(oprot thrift.TProtocol) error
- type TSIServiceClient
- func (p *TSIServiceClient) CancelOperation(ctx context.Context, req *TSCancelOperationReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) Client_() thrift.TClient
- func (p *TSIServiceClient) CloseOperation(ctx context.Context, req *TSCloseOperationReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) CloseSession(ctx context.Context, req *TSCloseSessionReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) CreateMultiTimeseries(ctx context.Context, req *TSCreateMultiTimeseriesReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) CreateTimeseries(ctx context.Context, req *TSCreateTimeseriesReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) DeleteData(ctx context.Context, req *TSDeleteDataReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) DeleteStorageGroups(ctx context.Context, sessionId int64, storageGroup []string) (r *TSStatus, err error)
- func (p *TSIServiceClient) DeleteTimeseries(ctx context.Context, sessionId int64, path []string) (r *TSStatus, err error)
- func (p *TSIServiceClient) ExecuteBatchStatement(ctx context.Context, req *TSExecuteBatchStatementReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) ExecuteQueryStatement(ctx context.Context, req *TSExecuteStatementReq) (r *TSExecuteStatementResp, err error)
- func (p *TSIServiceClient) ExecuteRawDataQuery(ctx context.Context, req *TSRawDataQueryReq) (r *TSExecuteStatementResp, err error)
- func (p *TSIServiceClient) ExecuteStatement(ctx context.Context, req *TSExecuteStatementReq) (r *TSExecuteStatementResp, err error)
- func (p *TSIServiceClient) ExecuteUpdateStatement(ctx context.Context, req *TSExecuteStatementReq) (r *TSExecuteStatementResp, err error)
- func (p *TSIServiceClient) FetchMetadata(ctx context.Context, req *TSFetchMetadataReq) (r *TSFetchMetadataResp, err error)
- func (p *TSIServiceClient) FetchResults(ctx context.Context, req *TSFetchResultsReq) (r *TSFetchResultsResp, err error)
- func (p *TSIServiceClient) GetProperties(ctx context.Context) (r *ServerProperties, err error)
- func (p *TSIServiceClient) GetTimeZone(ctx context.Context, sessionId int64) (r *TSGetTimeZoneResp, err error)
- func (p *TSIServiceClient) InsertRecord(ctx context.Context, req *TSInsertRecordReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) InsertRecords(ctx context.Context, req *TSInsertRecordsReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) InsertStringRecord(ctx context.Context, req *TSInsertStringRecordReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) InsertStringRecords(ctx context.Context, req *TSInsertStringRecordsReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) InsertTablet(ctx context.Context, req *TSInsertTabletReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) InsertTablets(ctx context.Context, req *TSInsertTabletsReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) OpenSession(ctx context.Context, req *TSOpenSessionReq) (r *TSOpenSessionResp, err error)
- func (p *TSIServiceClient) RequestStatementId(ctx context.Context, sessionId int64) (r int64, err error)
- func (p *TSIServiceClient) SetStorageGroup(ctx context.Context, sessionId int64, storageGroup string) (r *TSStatus, err error)
- func (p *TSIServiceClient) SetTimeZone(ctx context.Context, req *TSSetTimeZoneReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) TestInsertRecord(ctx context.Context, req *TSInsertRecordReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) TestInsertRecords(ctx context.Context, req *TSInsertRecordsReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) TestInsertStringRecord(ctx context.Context, req *TSInsertStringRecordReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) TestInsertStringRecords(ctx context.Context, req *TSInsertStringRecordsReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) TestInsertTablet(ctx context.Context, req *TSInsertTabletReq) (r *TSStatus, err error)
- func (p *TSIServiceClient) TestInsertTablets(ctx context.Context, req *TSInsertTabletsReq) (r *TSStatus, err error)
- type TSIServiceCloseOperationArgs
- func (p *TSIServiceCloseOperationArgs) GetReq() *TSCloseOperationReq
- func (p *TSIServiceCloseOperationArgs) IsSetReq() bool
- func (p *TSIServiceCloseOperationArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceCloseOperationArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceCloseOperationArgs) String() string
- func (p *TSIServiceCloseOperationArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceCloseOperationResult
- func (p *TSIServiceCloseOperationResult) GetSuccess() *TSStatus
- func (p *TSIServiceCloseOperationResult) IsSetSuccess() bool
- func (p *TSIServiceCloseOperationResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceCloseOperationResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceCloseOperationResult) String() string
- func (p *TSIServiceCloseOperationResult) Write(oprot thrift.TProtocol) error
- type TSIServiceCloseSessionArgs
- func (p *TSIServiceCloseSessionArgs) GetReq() *TSCloseSessionReq
- func (p *TSIServiceCloseSessionArgs) IsSetReq() bool
- func (p *TSIServiceCloseSessionArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceCloseSessionArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceCloseSessionArgs) String() string
- func (p *TSIServiceCloseSessionArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceCloseSessionResult
- func (p *TSIServiceCloseSessionResult) GetSuccess() *TSStatus
- func (p *TSIServiceCloseSessionResult) IsSetSuccess() bool
- func (p *TSIServiceCloseSessionResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceCloseSessionResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceCloseSessionResult) String() string
- func (p *TSIServiceCloseSessionResult) Write(oprot thrift.TProtocol) error
- type TSIServiceCreateMultiTimeseriesArgs
- func (p *TSIServiceCreateMultiTimeseriesArgs) GetReq() *TSCreateMultiTimeseriesReq
- func (p *TSIServiceCreateMultiTimeseriesArgs) IsSetReq() bool
- func (p *TSIServiceCreateMultiTimeseriesArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceCreateMultiTimeseriesArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceCreateMultiTimeseriesArgs) String() string
- func (p *TSIServiceCreateMultiTimeseriesArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceCreateMultiTimeseriesResult
- func (p *TSIServiceCreateMultiTimeseriesResult) GetSuccess() *TSStatus
- func (p *TSIServiceCreateMultiTimeseriesResult) IsSetSuccess() bool
- func (p *TSIServiceCreateMultiTimeseriesResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceCreateMultiTimeseriesResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceCreateMultiTimeseriesResult) String() string
- func (p *TSIServiceCreateMultiTimeseriesResult) Write(oprot thrift.TProtocol) error
- type TSIServiceCreateTimeseriesArgs
- func (p *TSIServiceCreateTimeseriesArgs) GetReq() *TSCreateTimeseriesReq
- func (p *TSIServiceCreateTimeseriesArgs) IsSetReq() bool
- func (p *TSIServiceCreateTimeseriesArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceCreateTimeseriesArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceCreateTimeseriesArgs) String() string
- func (p *TSIServiceCreateTimeseriesArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceCreateTimeseriesResult
- func (p *TSIServiceCreateTimeseriesResult) GetSuccess() *TSStatus
- func (p *TSIServiceCreateTimeseriesResult) IsSetSuccess() bool
- func (p *TSIServiceCreateTimeseriesResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceCreateTimeseriesResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceCreateTimeseriesResult) String() string
- func (p *TSIServiceCreateTimeseriesResult) Write(oprot thrift.TProtocol) error
- type TSIServiceDeleteDataArgs
- func (p *TSIServiceDeleteDataArgs) GetReq() *TSDeleteDataReq
- func (p *TSIServiceDeleteDataArgs) IsSetReq() bool
- func (p *TSIServiceDeleteDataArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceDeleteDataArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceDeleteDataArgs) String() string
- func (p *TSIServiceDeleteDataArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceDeleteDataResult
- func (p *TSIServiceDeleteDataResult) GetSuccess() *TSStatus
- func (p *TSIServiceDeleteDataResult) IsSetSuccess() bool
- func (p *TSIServiceDeleteDataResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceDeleteDataResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceDeleteDataResult) String() string
- func (p *TSIServiceDeleteDataResult) Write(oprot thrift.TProtocol) error
- type TSIServiceDeleteStorageGroupsArgs
- func (p *TSIServiceDeleteStorageGroupsArgs) GetSessionId() int64
- func (p *TSIServiceDeleteStorageGroupsArgs) GetStorageGroup() []string
- func (p *TSIServiceDeleteStorageGroupsArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceDeleteStorageGroupsArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceDeleteStorageGroupsArgs) ReadField2(iprot thrift.TProtocol) error
- func (p *TSIServiceDeleteStorageGroupsArgs) String() string
- func (p *TSIServiceDeleteStorageGroupsArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceDeleteStorageGroupsResult
- func (p *TSIServiceDeleteStorageGroupsResult) GetSuccess() *TSStatus
- func (p *TSIServiceDeleteStorageGroupsResult) IsSetSuccess() bool
- func (p *TSIServiceDeleteStorageGroupsResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceDeleteStorageGroupsResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceDeleteStorageGroupsResult) String() string
- func (p *TSIServiceDeleteStorageGroupsResult) Write(oprot thrift.TProtocol) error
- type TSIServiceDeleteTimeseriesArgs
- func (p *TSIServiceDeleteTimeseriesArgs) GetPath() []string
- func (p *TSIServiceDeleteTimeseriesArgs) GetSessionId() int64
- func (p *TSIServiceDeleteTimeseriesArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceDeleteTimeseriesArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceDeleteTimeseriesArgs) ReadField2(iprot thrift.TProtocol) error
- func (p *TSIServiceDeleteTimeseriesArgs) String() string
- func (p *TSIServiceDeleteTimeseriesArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceDeleteTimeseriesResult
- func (p *TSIServiceDeleteTimeseriesResult) GetSuccess() *TSStatus
- func (p *TSIServiceDeleteTimeseriesResult) IsSetSuccess() bool
- func (p *TSIServiceDeleteTimeseriesResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceDeleteTimeseriesResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceDeleteTimeseriesResult) String() string
- func (p *TSIServiceDeleteTimeseriesResult) Write(oprot thrift.TProtocol) error
- type TSIServiceExecuteBatchStatementArgs
- func (p *TSIServiceExecuteBatchStatementArgs) GetReq() *TSExecuteBatchStatementReq
- func (p *TSIServiceExecuteBatchStatementArgs) IsSetReq() bool
- func (p *TSIServiceExecuteBatchStatementArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteBatchStatementArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteBatchStatementArgs) String() string
- func (p *TSIServiceExecuteBatchStatementArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceExecuteBatchStatementResult
- func (p *TSIServiceExecuteBatchStatementResult) GetSuccess() *TSStatus
- func (p *TSIServiceExecuteBatchStatementResult) IsSetSuccess() bool
- func (p *TSIServiceExecuteBatchStatementResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteBatchStatementResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteBatchStatementResult) String() string
- func (p *TSIServiceExecuteBatchStatementResult) Write(oprot thrift.TProtocol) error
- type TSIServiceExecuteQueryStatementArgs
- func (p *TSIServiceExecuteQueryStatementArgs) GetReq() *TSExecuteStatementReq
- func (p *TSIServiceExecuteQueryStatementArgs) IsSetReq() bool
- func (p *TSIServiceExecuteQueryStatementArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteQueryStatementArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteQueryStatementArgs) String() string
- func (p *TSIServiceExecuteQueryStatementArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceExecuteQueryStatementResult
- func (p *TSIServiceExecuteQueryStatementResult) GetSuccess() *TSExecuteStatementResp
- func (p *TSIServiceExecuteQueryStatementResult) IsSetSuccess() bool
- func (p *TSIServiceExecuteQueryStatementResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteQueryStatementResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteQueryStatementResult) String() string
- func (p *TSIServiceExecuteQueryStatementResult) Write(oprot thrift.TProtocol) error
- type TSIServiceExecuteRawDataQueryArgs
- func (p *TSIServiceExecuteRawDataQueryArgs) GetReq() *TSRawDataQueryReq
- func (p *TSIServiceExecuteRawDataQueryArgs) IsSetReq() bool
- func (p *TSIServiceExecuteRawDataQueryArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteRawDataQueryArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteRawDataQueryArgs) String() string
- func (p *TSIServiceExecuteRawDataQueryArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceExecuteRawDataQueryResult
- func (p *TSIServiceExecuteRawDataQueryResult) GetSuccess() *TSExecuteStatementResp
- func (p *TSIServiceExecuteRawDataQueryResult) IsSetSuccess() bool
- func (p *TSIServiceExecuteRawDataQueryResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteRawDataQueryResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteRawDataQueryResult) String() string
- func (p *TSIServiceExecuteRawDataQueryResult) Write(oprot thrift.TProtocol) error
- type TSIServiceExecuteStatementArgs
- func (p *TSIServiceExecuteStatementArgs) GetReq() *TSExecuteStatementReq
- func (p *TSIServiceExecuteStatementArgs) IsSetReq() bool
- func (p *TSIServiceExecuteStatementArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteStatementArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteStatementArgs) String() string
- func (p *TSIServiceExecuteStatementArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceExecuteStatementResult
- func (p *TSIServiceExecuteStatementResult) GetSuccess() *TSExecuteStatementResp
- func (p *TSIServiceExecuteStatementResult) IsSetSuccess() bool
- func (p *TSIServiceExecuteStatementResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteStatementResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteStatementResult) String() string
- func (p *TSIServiceExecuteStatementResult) Write(oprot thrift.TProtocol) error
- type TSIServiceExecuteUpdateStatementArgs
- func (p *TSIServiceExecuteUpdateStatementArgs) GetReq() *TSExecuteStatementReq
- func (p *TSIServiceExecuteUpdateStatementArgs) IsSetReq() bool
- func (p *TSIServiceExecuteUpdateStatementArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteUpdateStatementArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteUpdateStatementArgs) String() string
- func (p *TSIServiceExecuteUpdateStatementArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceExecuteUpdateStatementResult
- func (p *TSIServiceExecuteUpdateStatementResult) GetSuccess() *TSExecuteStatementResp
- func (p *TSIServiceExecuteUpdateStatementResult) IsSetSuccess() bool
- func (p *TSIServiceExecuteUpdateStatementResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteUpdateStatementResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceExecuteUpdateStatementResult) String() string
- func (p *TSIServiceExecuteUpdateStatementResult) Write(oprot thrift.TProtocol) error
- type TSIServiceFetchMetadataArgs
- func (p *TSIServiceFetchMetadataArgs) GetReq() *TSFetchMetadataReq
- func (p *TSIServiceFetchMetadataArgs) IsSetReq() bool
- func (p *TSIServiceFetchMetadataArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceFetchMetadataArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceFetchMetadataArgs) String() string
- func (p *TSIServiceFetchMetadataArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceFetchMetadataResult
- func (p *TSIServiceFetchMetadataResult) GetSuccess() *TSFetchMetadataResp
- func (p *TSIServiceFetchMetadataResult) IsSetSuccess() bool
- func (p *TSIServiceFetchMetadataResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceFetchMetadataResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceFetchMetadataResult) String() string
- func (p *TSIServiceFetchMetadataResult) Write(oprot thrift.TProtocol) error
- type TSIServiceFetchResultsArgs
- func (p *TSIServiceFetchResultsArgs) GetReq() *TSFetchResultsReq
- func (p *TSIServiceFetchResultsArgs) IsSetReq() bool
- func (p *TSIServiceFetchResultsArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceFetchResultsArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceFetchResultsArgs) String() string
- func (p *TSIServiceFetchResultsArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceFetchResultsResult
- func (p *TSIServiceFetchResultsResult) GetSuccess() *TSFetchResultsResp
- func (p *TSIServiceFetchResultsResult) IsSetSuccess() bool
- func (p *TSIServiceFetchResultsResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceFetchResultsResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceFetchResultsResult) String() string
- func (p *TSIServiceFetchResultsResult) Write(oprot thrift.TProtocol) error
- type TSIServiceGetPropertiesArgs
- type TSIServiceGetPropertiesResult
- func (p *TSIServiceGetPropertiesResult) GetSuccess() *ServerProperties
- func (p *TSIServiceGetPropertiesResult) IsSetSuccess() bool
- func (p *TSIServiceGetPropertiesResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceGetPropertiesResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceGetPropertiesResult) String() string
- func (p *TSIServiceGetPropertiesResult) Write(oprot thrift.TProtocol) error
- type TSIServiceGetTimeZoneArgs
- func (p *TSIServiceGetTimeZoneArgs) GetSessionId() int64
- func (p *TSIServiceGetTimeZoneArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceGetTimeZoneArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceGetTimeZoneArgs) String() string
- func (p *TSIServiceGetTimeZoneArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceGetTimeZoneResult
- func (p *TSIServiceGetTimeZoneResult) GetSuccess() *TSGetTimeZoneResp
- func (p *TSIServiceGetTimeZoneResult) IsSetSuccess() bool
- func (p *TSIServiceGetTimeZoneResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceGetTimeZoneResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceGetTimeZoneResult) String() string
- func (p *TSIServiceGetTimeZoneResult) Write(oprot thrift.TProtocol) error
- type TSIServiceInsertRecordArgs
- func (p *TSIServiceInsertRecordArgs) GetReq() *TSInsertRecordReq
- func (p *TSIServiceInsertRecordArgs) IsSetReq() bool
- func (p *TSIServiceInsertRecordArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertRecordArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertRecordArgs) String() string
- func (p *TSIServiceInsertRecordArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceInsertRecordResult
- func (p *TSIServiceInsertRecordResult) GetSuccess() *TSStatus
- func (p *TSIServiceInsertRecordResult) IsSetSuccess() bool
- func (p *TSIServiceInsertRecordResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertRecordResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertRecordResult) String() string
- func (p *TSIServiceInsertRecordResult) Write(oprot thrift.TProtocol) error
- type TSIServiceInsertRecordsArgs
- func (p *TSIServiceInsertRecordsArgs) GetReq() *TSInsertRecordsReq
- func (p *TSIServiceInsertRecordsArgs) IsSetReq() bool
- func (p *TSIServiceInsertRecordsArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertRecordsArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertRecordsArgs) String() string
- func (p *TSIServiceInsertRecordsArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceInsertRecordsResult
- func (p *TSIServiceInsertRecordsResult) GetSuccess() *TSStatus
- func (p *TSIServiceInsertRecordsResult) IsSetSuccess() bool
- func (p *TSIServiceInsertRecordsResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertRecordsResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertRecordsResult) String() string
- func (p *TSIServiceInsertRecordsResult) Write(oprot thrift.TProtocol) error
- type TSIServiceInsertStringRecordArgs
- func (p *TSIServiceInsertStringRecordArgs) GetReq() *TSInsertStringRecordReq
- func (p *TSIServiceInsertStringRecordArgs) IsSetReq() bool
- func (p *TSIServiceInsertStringRecordArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertStringRecordArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertStringRecordArgs) String() string
- func (p *TSIServiceInsertStringRecordArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceInsertStringRecordResult
- func (p *TSIServiceInsertStringRecordResult) GetSuccess() *TSStatus
- func (p *TSIServiceInsertStringRecordResult) IsSetSuccess() bool
- func (p *TSIServiceInsertStringRecordResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertStringRecordResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertStringRecordResult) String() string
- func (p *TSIServiceInsertStringRecordResult) Write(oprot thrift.TProtocol) error
- type TSIServiceInsertStringRecordsArgs
- func (p *TSIServiceInsertStringRecordsArgs) GetReq() *TSInsertStringRecordsReq
- func (p *TSIServiceInsertStringRecordsArgs) IsSetReq() bool
- func (p *TSIServiceInsertStringRecordsArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertStringRecordsArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertStringRecordsArgs) String() string
- func (p *TSIServiceInsertStringRecordsArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceInsertStringRecordsResult
- func (p *TSIServiceInsertStringRecordsResult) GetSuccess() *TSStatus
- func (p *TSIServiceInsertStringRecordsResult) IsSetSuccess() bool
- func (p *TSIServiceInsertStringRecordsResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertStringRecordsResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertStringRecordsResult) String() string
- func (p *TSIServiceInsertStringRecordsResult) Write(oprot thrift.TProtocol) error
- type TSIServiceInsertTabletArgs
- func (p *TSIServiceInsertTabletArgs) GetReq() *TSInsertTabletReq
- func (p *TSIServiceInsertTabletArgs) IsSetReq() bool
- func (p *TSIServiceInsertTabletArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertTabletArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertTabletArgs) String() string
- func (p *TSIServiceInsertTabletArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceInsertTabletResult
- func (p *TSIServiceInsertTabletResult) GetSuccess() *TSStatus
- func (p *TSIServiceInsertTabletResult) IsSetSuccess() bool
- func (p *TSIServiceInsertTabletResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertTabletResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertTabletResult) String() string
- func (p *TSIServiceInsertTabletResult) Write(oprot thrift.TProtocol) error
- type TSIServiceInsertTabletsArgs
- func (p *TSIServiceInsertTabletsArgs) GetReq() *TSInsertTabletsReq
- func (p *TSIServiceInsertTabletsArgs) IsSetReq() bool
- func (p *TSIServiceInsertTabletsArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertTabletsArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertTabletsArgs) String() string
- func (p *TSIServiceInsertTabletsArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceInsertTabletsResult
- func (p *TSIServiceInsertTabletsResult) GetSuccess() *TSStatus
- func (p *TSIServiceInsertTabletsResult) IsSetSuccess() bool
- func (p *TSIServiceInsertTabletsResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertTabletsResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceInsertTabletsResult) String() string
- func (p *TSIServiceInsertTabletsResult) Write(oprot thrift.TProtocol) error
- type TSIServiceOpenSessionArgs
- func (p *TSIServiceOpenSessionArgs) GetReq() *TSOpenSessionReq
- func (p *TSIServiceOpenSessionArgs) IsSetReq() bool
- func (p *TSIServiceOpenSessionArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceOpenSessionArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceOpenSessionArgs) String() string
- func (p *TSIServiceOpenSessionArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceOpenSessionResult
- func (p *TSIServiceOpenSessionResult) GetSuccess() *TSOpenSessionResp
- func (p *TSIServiceOpenSessionResult) IsSetSuccess() bool
- func (p *TSIServiceOpenSessionResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceOpenSessionResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceOpenSessionResult) String() string
- func (p *TSIServiceOpenSessionResult) Write(oprot thrift.TProtocol) error
- type TSIServiceProcessor
- func (p *TSIServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
- func (p *TSIServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
- func (p *TSIServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
- func (p *TSIServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
- type TSIServiceRequestStatementIdArgs
- func (p *TSIServiceRequestStatementIdArgs) GetSessionId() int64
- func (p *TSIServiceRequestStatementIdArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceRequestStatementIdArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceRequestStatementIdArgs) String() string
- func (p *TSIServiceRequestStatementIdArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceRequestStatementIdResult
- func (p *TSIServiceRequestStatementIdResult) GetSuccess() int64
- func (p *TSIServiceRequestStatementIdResult) IsSetSuccess() bool
- func (p *TSIServiceRequestStatementIdResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceRequestStatementIdResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceRequestStatementIdResult) String() string
- func (p *TSIServiceRequestStatementIdResult) Write(oprot thrift.TProtocol) error
- type TSIServiceSetStorageGroupArgs
- func (p *TSIServiceSetStorageGroupArgs) GetSessionId() int64
- func (p *TSIServiceSetStorageGroupArgs) GetStorageGroup() string
- func (p *TSIServiceSetStorageGroupArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceSetStorageGroupArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceSetStorageGroupArgs) ReadField2(iprot thrift.TProtocol) error
- func (p *TSIServiceSetStorageGroupArgs) String() string
- func (p *TSIServiceSetStorageGroupArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceSetStorageGroupResult
- func (p *TSIServiceSetStorageGroupResult) GetSuccess() *TSStatus
- func (p *TSIServiceSetStorageGroupResult) IsSetSuccess() bool
- func (p *TSIServiceSetStorageGroupResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceSetStorageGroupResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceSetStorageGroupResult) String() string
- func (p *TSIServiceSetStorageGroupResult) Write(oprot thrift.TProtocol) error
- type TSIServiceSetTimeZoneArgs
- func (p *TSIServiceSetTimeZoneArgs) GetReq() *TSSetTimeZoneReq
- func (p *TSIServiceSetTimeZoneArgs) IsSetReq() bool
- func (p *TSIServiceSetTimeZoneArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceSetTimeZoneArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceSetTimeZoneArgs) String() string
- func (p *TSIServiceSetTimeZoneArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceSetTimeZoneResult
- func (p *TSIServiceSetTimeZoneResult) GetSuccess() *TSStatus
- func (p *TSIServiceSetTimeZoneResult) IsSetSuccess() bool
- func (p *TSIServiceSetTimeZoneResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceSetTimeZoneResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceSetTimeZoneResult) String() string
- func (p *TSIServiceSetTimeZoneResult) Write(oprot thrift.TProtocol) error
- type TSIServiceTestInsertRecordArgs
- func (p *TSIServiceTestInsertRecordArgs) GetReq() *TSInsertRecordReq
- func (p *TSIServiceTestInsertRecordArgs) IsSetReq() bool
- func (p *TSIServiceTestInsertRecordArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertRecordArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertRecordArgs) String() string
- func (p *TSIServiceTestInsertRecordArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceTestInsertRecordResult
- func (p *TSIServiceTestInsertRecordResult) GetSuccess() *TSStatus
- func (p *TSIServiceTestInsertRecordResult) IsSetSuccess() bool
- func (p *TSIServiceTestInsertRecordResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertRecordResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertRecordResult) String() string
- func (p *TSIServiceTestInsertRecordResult) Write(oprot thrift.TProtocol) error
- type TSIServiceTestInsertRecordsArgs
- func (p *TSIServiceTestInsertRecordsArgs) GetReq() *TSInsertRecordsReq
- func (p *TSIServiceTestInsertRecordsArgs) IsSetReq() bool
- func (p *TSIServiceTestInsertRecordsArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertRecordsArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertRecordsArgs) String() string
- func (p *TSIServiceTestInsertRecordsArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceTestInsertRecordsResult
- func (p *TSIServiceTestInsertRecordsResult) GetSuccess() *TSStatus
- func (p *TSIServiceTestInsertRecordsResult) IsSetSuccess() bool
- func (p *TSIServiceTestInsertRecordsResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertRecordsResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertRecordsResult) String() string
- func (p *TSIServiceTestInsertRecordsResult) Write(oprot thrift.TProtocol) error
- type TSIServiceTestInsertStringRecordArgs
- func (p *TSIServiceTestInsertStringRecordArgs) GetReq() *TSInsertStringRecordReq
- func (p *TSIServiceTestInsertStringRecordArgs) IsSetReq() bool
- func (p *TSIServiceTestInsertStringRecordArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertStringRecordArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertStringRecordArgs) String() string
- func (p *TSIServiceTestInsertStringRecordArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceTestInsertStringRecordResult
- func (p *TSIServiceTestInsertStringRecordResult) GetSuccess() *TSStatus
- func (p *TSIServiceTestInsertStringRecordResult) IsSetSuccess() bool
- func (p *TSIServiceTestInsertStringRecordResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertStringRecordResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertStringRecordResult) String() string
- func (p *TSIServiceTestInsertStringRecordResult) Write(oprot thrift.TProtocol) error
- type TSIServiceTestInsertStringRecordsArgs
- func (p *TSIServiceTestInsertStringRecordsArgs) GetReq() *TSInsertStringRecordsReq
- func (p *TSIServiceTestInsertStringRecordsArgs) IsSetReq() bool
- func (p *TSIServiceTestInsertStringRecordsArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertStringRecordsArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertStringRecordsArgs) String() string
- func (p *TSIServiceTestInsertStringRecordsArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceTestInsertStringRecordsResult
- func (p *TSIServiceTestInsertStringRecordsResult) GetSuccess() *TSStatus
- func (p *TSIServiceTestInsertStringRecordsResult) IsSetSuccess() bool
- func (p *TSIServiceTestInsertStringRecordsResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertStringRecordsResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertStringRecordsResult) String() string
- func (p *TSIServiceTestInsertStringRecordsResult) Write(oprot thrift.TProtocol) error
- type TSIServiceTestInsertTabletArgs
- func (p *TSIServiceTestInsertTabletArgs) GetReq() *TSInsertTabletReq
- func (p *TSIServiceTestInsertTabletArgs) IsSetReq() bool
- func (p *TSIServiceTestInsertTabletArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertTabletArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertTabletArgs) String() string
- func (p *TSIServiceTestInsertTabletArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceTestInsertTabletResult
- func (p *TSIServiceTestInsertTabletResult) GetSuccess() *TSStatus
- func (p *TSIServiceTestInsertTabletResult) IsSetSuccess() bool
- func (p *TSIServiceTestInsertTabletResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertTabletResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertTabletResult) String() string
- func (p *TSIServiceTestInsertTabletResult) Write(oprot thrift.TProtocol) error
- type TSIServiceTestInsertTabletsArgs
- func (p *TSIServiceTestInsertTabletsArgs) GetReq() *TSInsertTabletsReq
- func (p *TSIServiceTestInsertTabletsArgs) IsSetReq() bool
- func (p *TSIServiceTestInsertTabletsArgs) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertTabletsArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertTabletsArgs) String() string
- func (p *TSIServiceTestInsertTabletsArgs) Write(oprot thrift.TProtocol) error
- type TSIServiceTestInsertTabletsResult
- func (p *TSIServiceTestInsertTabletsResult) GetSuccess() *TSStatus
- func (p *TSIServiceTestInsertTabletsResult) IsSetSuccess() bool
- func (p *TSIServiceTestInsertTabletsResult) Read(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertTabletsResult) ReadField0(iprot thrift.TProtocol) error
- func (p *TSIServiceTestInsertTabletsResult) String() string
- func (p *TSIServiceTestInsertTabletsResult) Write(oprot thrift.TProtocol) error
- type TSInsertRecordReq
- func (p *TSInsertRecordReq) GetDeviceId() string
- func (p *TSInsertRecordReq) GetMeasurements() []string
- func (p *TSInsertRecordReq) GetSessionId() int64
- func (p *TSInsertRecordReq) GetTimestamp() int64
- func (p *TSInsertRecordReq) GetValues() []byte
- func (p *TSInsertRecordReq) Read(iprot thrift.TProtocol) error
- func (p *TSInsertRecordReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSInsertRecordReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSInsertRecordReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSInsertRecordReq) ReadField4(iprot thrift.TProtocol) error
- func (p *TSInsertRecordReq) ReadField5(iprot thrift.TProtocol) error
- func (p *TSInsertRecordReq) String() string
- func (p *TSInsertRecordReq) Write(oprot thrift.TProtocol) error
- type TSInsertRecordsReq
- func (p *TSInsertRecordsReq) GetDeviceIds() []string
- func (p *TSInsertRecordsReq) GetMeasurementsList() [][]string
- func (p *TSInsertRecordsReq) GetSessionId() int64
- func (p *TSInsertRecordsReq) GetTimestamps() []int64
- func (p *TSInsertRecordsReq) GetValuesList() [][]byte
- func (p *TSInsertRecordsReq) Read(iprot thrift.TProtocol) error
- func (p *TSInsertRecordsReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSInsertRecordsReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSInsertRecordsReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSInsertRecordsReq) ReadField4(iprot thrift.TProtocol) error
- func (p *TSInsertRecordsReq) ReadField5(iprot thrift.TProtocol) error
- func (p *TSInsertRecordsReq) String() string
- func (p *TSInsertRecordsReq) Write(oprot thrift.TProtocol) error
- type TSInsertStringRecordReq
- func (p *TSInsertStringRecordReq) GetDeviceId() string
- func (p *TSInsertStringRecordReq) GetMeasurements() []string
- func (p *TSInsertStringRecordReq) GetSessionId() int64
- func (p *TSInsertStringRecordReq) GetTimestamp() int64
- func (p *TSInsertStringRecordReq) GetValues() []string
- func (p *TSInsertStringRecordReq) Read(iprot thrift.TProtocol) error
- func (p *TSInsertStringRecordReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSInsertStringRecordReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSInsertStringRecordReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSInsertStringRecordReq) ReadField4(iprot thrift.TProtocol) error
- func (p *TSInsertStringRecordReq) ReadField5(iprot thrift.TProtocol) error
- func (p *TSInsertStringRecordReq) String() string
- func (p *TSInsertStringRecordReq) Write(oprot thrift.TProtocol) error
- type TSInsertStringRecordsReq
- func (p *TSInsertStringRecordsReq) GetDeviceIds() []string
- func (p *TSInsertStringRecordsReq) GetMeasurementsList() [][]string
- func (p *TSInsertStringRecordsReq) GetSessionId() int64
- func (p *TSInsertStringRecordsReq) GetTimestamps() []int64
- func (p *TSInsertStringRecordsReq) GetValuesList() [][]string
- func (p *TSInsertStringRecordsReq) Read(iprot thrift.TProtocol) error
- func (p *TSInsertStringRecordsReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSInsertStringRecordsReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSInsertStringRecordsReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSInsertStringRecordsReq) ReadField4(iprot thrift.TProtocol) error
- func (p *TSInsertStringRecordsReq) ReadField5(iprot thrift.TProtocol) error
- func (p *TSInsertStringRecordsReq) String() string
- func (p *TSInsertStringRecordsReq) Write(oprot thrift.TProtocol) error
- type TSInsertTabletReq
- func (p *TSInsertTabletReq) GetDeviceId() string
- func (p *TSInsertTabletReq) GetMeasurements() []string
- func (p *TSInsertTabletReq) GetSessionId() int64
- func (p *TSInsertTabletReq) GetSize() int32
- func (p *TSInsertTabletReq) GetTimestamps() []byte
- func (p *TSInsertTabletReq) GetTypes() []int32
- func (p *TSInsertTabletReq) GetValues() []byte
- func (p *TSInsertTabletReq) Read(iprot thrift.TProtocol) error
- func (p *TSInsertTabletReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSInsertTabletReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSInsertTabletReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSInsertTabletReq) ReadField4(iprot thrift.TProtocol) error
- func (p *TSInsertTabletReq) ReadField5(iprot thrift.TProtocol) error
- func (p *TSInsertTabletReq) ReadField6(iprot thrift.TProtocol) error
- func (p *TSInsertTabletReq) ReadField7(iprot thrift.TProtocol) error
- func (p *TSInsertTabletReq) String() string
- func (p *TSInsertTabletReq) Write(oprot thrift.TProtocol) error
- type TSInsertTabletsReq
- func (p *TSInsertTabletsReq) GetDeviceIds() []string
- func (p *TSInsertTabletsReq) GetMeasurementsList() [][]string
- func (p *TSInsertTabletsReq) GetSessionId() int64
- func (p *TSInsertTabletsReq) GetSizeList() []int32
- func (p *TSInsertTabletsReq) GetTimestampsList() [][]byte
- func (p *TSInsertTabletsReq) GetTypesList() [][]int32
- func (p *TSInsertTabletsReq) GetValuesList() [][]byte
- func (p *TSInsertTabletsReq) Read(iprot thrift.TProtocol) error
- func (p *TSInsertTabletsReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSInsertTabletsReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSInsertTabletsReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSInsertTabletsReq) ReadField4(iprot thrift.TProtocol) error
- func (p *TSInsertTabletsReq) ReadField5(iprot thrift.TProtocol) error
- func (p *TSInsertTabletsReq) ReadField6(iprot thrift.TProtocol) error
- func (p *TSInsertTabletsReq) ReadField7(iprot thrift.TProtocol) error
- func (p *TSInsertTabletsReq) String() string
- func (p *TSInsertTabletsReq) Write(oprot thrift.TProtocol) error
- type TSOpenSessionReq
- func (p *TSOpenSessionReq) GetClientProtocol() TSProtocolVersion
- func (p *TSOpenSessionReq) GetConfiguration() map[string]string
- func (p *TSOpenSessionReq) GetPassword() string
- func (p *TSOpenSessionReq) GetUsername() string
- func (p *TSOpenSessionReq) GetZoneId() string
- func (p *TSOpenSessionReq) IsSetConfiguration() bool
- func (p *TSOpenSessionReq) IsSetPassword() bool
- func (p *TSOpenSessionReq) IsSetUsername() bool
- func (p *TSOpenSessionReq) Read(iprot thrift.TProtocol) error
- func (p *TSOpenSessionReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSOpenSessionReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSOpenSessionReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSOpenSessionReq) ReadField4(iprot thrift.TProtocol) error
- func (p *TSOpenSessionReq) ReadField5(iprot thrift.TProtocol) error
- func (p *TSOpenSessionReq) String() string
- func (p *TSOpenSessionReq) Write(oprot thrift.TProtocol) error
- type TSOpenSessionResp
- func (p *TSOpenSessionResp) GetConfiguration() map[string]string
- func (p *TSOpenSessionResp) GetServerProtocolVersion() TSProtocolVersion
- func (p *TSOpenSessionResp) GetSessionId() int64
- func (p *TSOpenSessionResp) GetStatus() *TSStatus
- func (p *TSOpenSessionResp) IsSetConfiguration() bool
- func (p *TSOpenSessionResp) IsSetSessionId() bool
- func (p *TSOpenSessionResp) IsSetStatus() bool
- func (p *TSOpenSessionResp) Read(iprot thrift.TProtocol) error
- func (p *TSOpenSessionResp) ReadField1(iprot thrift.TProtocol) error
- func (p *TSOpenSessionResp) ReadField2(iprot thrift.TProtocol) error
- func (p *TSOpenSessionResp) ReadField3(iprot thrift.TProtocol) error
- func (p *TSOpenSessionResp) ReadField4(iprot thrift.TProtocol) error
- func (p *TSOpenSessionResp) String() string
- func (p *TSOpenSessionResp) Write(oprot thrift.TProtocol) error
- type TSProtocolVersion
- type TSQueryDataSet
- func (p *TSQueryDataSet) GetBitmapList() [][]byte
- func (p *TSQueryDataSet) GetTime() []byte
- func (p *TSQueryDataSet) GetValueList() [][]byte
- func (p *TSQueryDataSet) Read(iprot thrift.TProtocol) error
- func (p *TSQueryDataSet) ReadField1(iprot thrift.TProtocol) error
- func (p *TSQueryDataSet) ReadField2(iprot thrift.TProtocol) error
- func (p *TSQueryDataSet) ReadField3(iprot thrift.TProtocol) error
- func (p *TSQueryDataSet) String() string
- func (p *TSQueryDataSet) Write(oprot thrift.TProtocol) error
- type TSQueryNonAlignDataSet
- func (p *TSQueryNonAlignDataSet) GetTimeList() [][]byte
- func (p *TSQueryNonAlignDataSet) GetValueList() [][]byte
- func (p *TSQueryNonAlignDataSet) Read(iprot thrift.TProtocol) error
- func (p *TSQueryNonAlignDataSet) ReadField1(iprot thrift.TProtocol) error
- func (p *TSQueryNonAlignDataSet) ReadField2(iprot thrift.TProtocol) error
- func (p *TSQueryNonAlignDataSet) String() string
- func (p *TSQueryNonAlignDataSet) Write(oprot thrift.TProtocol) error
- type TSRawDataQueryReq
- func (p *TSRawDataQueryReq) GetEndTime() int64
- func (p *TSRawDataQueryReq) GetFetchSize() int32
- func (p *TSRawDataQueryReq) GetPaths() []string
- func (p *TSRawDataQueryReq) GetSessionId() int64
- func (p *TSRawDataQueryReq) GetStartTime() int64
- func (p *TSRawDataQueryReq) GetStatementId() int64
- func (p *TSRawDataQueryReq) IsSetFetchSize() bool
- func (p *TSRawDataQueryReq) Read(iprot thrift.TProtocol) error
- func (p *TSRawDataQueryReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSRawDataQueryReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSRawDataQueryReq) ReadField3(iprot thrift.TProtocol) error
- func (p *TSRawDataQueryReq) ReadField4(iprot thrift.TProtocol) error
- func (p *TSRawDataQueryReq) ReadField5(iprot thrift.TProtocol) error
- func (p *TSRawDataQueryReq) ReadField6(iprot thrift.TProtocol) error
- func (p *TSRawDataQueryReq) String() string
- func (p *TSRawDataQueryReq) Write(oprot thrift.TProtocol) error
- type TSSetTimeZoneReq
- func (p *TSSetTimeZoneReq) GetSessionId() int64
- func (p *TSSetTimeZoneReq) GetTimeZone() string
- func (p *TSSetTimeZoneReq) Read(iprot thrift.TProtocol) error
- func (p *TSSetTimeZoneReq) ReadField1(iprot thrift.TProtocol) error
- func (p *TSSetTimeZoneReq) ReadField2(iprot thrift.TProtocol) error
- func (p *TSSetTimeZoneReq) String() string
- func (p *TSSetTimeZoneReq) Write(oprot thrift.TProtocol) error
- type TSStatus
- func (p *TSStatus) GetCode() int32
- func (p *TSStatus) GetMessage() string
- func (p *TSStatus) GetSubStatus() []*TSStatus
- func (p *TSStatus) IsSetMessage() bool
- func (p *TSStatus) IsSetSubStatus() bool
- func (p *TSStatus) Read(iprot thrift.TProtocol) error
- func (p *TSStatus) ReadField1(iprot thrift.TProtocol) error
- func (p *TSStatus) ReadField2(iprot thrift.TProtocol) error
- func (p *TSStatus) ReadField3(iprot thrift.TProtocol) error
- func (p *TSStatus) String() string
- func (p *TSStatus) Write(oprot thrift.TProtocol) error
Constants ¶
This section is empty.
Variables ¶
var GoUnusedProtection__ int
var TSCloseOperationReq_QueryId_DEFAULT int64
var TSCloseOperationReq_StatementId_DEFAULT int64
var TSCreateMultiTimeseriesReq_AttributesList_DEFAULT []map[string]string
var TSCreateMultiTimeseriesReq_MeasurementAliasList_DEFAULT []string
var TSCreateMultiTimeseriesReq_PropsList_DEFAULT []map[string]string
var TSCreateMultiTimeseriesReq_TagsList_DEFAULT []map[string]string
var TSCreateTimeseriesReq_Attributes_DEFAULT map[string]string
var TSCreateTimeseriesReq_MeasurementAlias_DEFAULT string
var TSCreateTimeseriesReq_Props_DEFAULT map[string]string
var TSCreateTimeseriesReq_Tags_DEFAULT map[string]string
var TSExecuteStatementReq_FetchSize_DEFAULT int32
var TSExecuteStatementResp_ColumnNameIndexMap_DEFAULT map[string]int32
var TSExecuteStatementResp_Columns_DEFAULT []string
var TSExecuteStatementResp_DataTypeList_DEFAULT []string
var TSExecuteStatementResp_IgnoreTimeStamp_DEFAULT bool
var TSExecuteStatementResp_OperationType_DEFAULT string
var TSExecuteStatementResp_QueryId_DEFAULT int64
var TSFetchMetadataReq_ColumnPath_DEFAULT string
var TSFetchMetadataResp_ColumnsList_DEFAULT []string
var TSFetchMetadataResp_DataType_DEFAULT string
var TSFetchMetadataResp_MetadataInJson_DEFAULT string
var TSIServiceRequestStatementIdResult_Success_DEFAULT int64
var TSOpenSessionReq_Configuration_DEFAULT map[string]string
var TSOpenSessionReq_Password_DEFAULT string
var TSOpenSessionReq_Username_DEFAULT string
var TSOpenSessionResp_Configuration_DEFAULT map[string]string
var TSOpenSessionResp_SessionId_DEFAULT int64
var TSRawDataQueryReq_FetchSize_DEFAULT int32
var TSStatus_Message_DEFAULT string
var TSStatus_SubStatus_DEFAULT []*TSStatus
Functions ¶
This section is empty.
Types ¶
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"` }
Attributes:
- Version
- SupportedTimeAggregationOperations
- TimestampPrecision
var TSIServiceGetPropertiesResult_Success_DEFAULT *ServerProperties
func NewServerProperties ¶
func NewServerProperties() *ServerProperties
func (*ServerProperties) GetSupportedTimeAggregationOperations ¶
func (p *ServerProperties) GetSupportedTimeAggregationOperations() []string
func (*ServerProperties) GetTimestampPrecision ¶
func (p *ServerProperties) GetTimestampPrecision() string
func (*ServerProperties) GetVersion ¶
func (p *ServerProperties) GetVersion() string
func (*ServerProperties) ReadField1 ¶
func (p *ServerProperties) ReadField1(iprot thrift.TProtocol) error
func (*ServerProperties) ReadField2 ¶
func (p *ServerProperties) ReadField2(iprot thrift.TProtocol) error
func (*ServerProperties) ReadField3 ¶
func (p *ServerProperties) ReadField3(iprot thrift.TProtocol) error
func (*ServerProperties) String ¶
func (p *ServerProperties) String() string
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) GetQueryId ¶
func (p *TSCancelOperationReq) GetQueryId() int64
func (*TSCancelOperationReq) GetSessionId ¶
func (p *TSCancelOperationReq) GetSessionId() int64
func (*TSCancelOperationReq) Read ¶
func (p *TSCancelOperationReq) Read(iprot thrift.TProtocol) error
func (*TSCancelOperationReq) ReadField1 ¶
func (p *TSCancelOperationReq) ReadField1(iprot thrift.TProtocol) error
func (*TSCancelOperationReq) ReadField2 ¶
func (p *TSCancelOperationReq) ReadField2(iprot thrift.TProtocol) error
func (*TSCancelOperationReq) String ¶
func (p *TSCancelOperationReq) String() string
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) 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) ReadField1 ¶
func (p *TSCloseOperationReq) ReadField1(iprot thrift.TProtocol) error
func (*TSCloseOperationReq) ReadField2 ¶
func (p *TSCloseOperationReq) ReadField2(iprot thrift.TProtocol) error
func (*TSCloseOperationReq) ReadField3 ¶
func (p *TSCloseOperationReq) ReadField3(iprot thrift.TProtocol) error
func (*TSCloseOperationReq) String ¶
func (p *TSCloseOperationReq) String() string
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) GetSessionId ¶
func (p *TSCloseSessionReq) GetSessionId() int64
func (*TSCloseSessionReq) ReadField1 ¶
func (p *TSCloseSessionReq) ReadField1(iprot thrift.TProtocol) error
func (*TSCloseSessionReq) String ¶
func (p *TSCloseSessionReq) String() string
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) 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(iprot thrift.TProtocol) error
func (*TSCreateMultiTimeseriesReq) ReadField1 ¶
func (p *TSCreateMultiTimeseriesReq) ReadField1(iprot thrift.TProtocol) error
func (*TSCreateMultiTimeseriesReq) ReadField2 ¶
func (p *TSCreateMultiTimeseriesReq) ReadField2(iprot thrift.TProtocol) error
func (*TSCreateMultiTimeseriesReq) ReadField3 ¶
func (p *TSCreateMultiTimeseriesReq) ReadField3(iprot thrift.TProtocol) error
func (*TSCreateMultiTimeseriesReq) ReadField4 ¶
func (p *TSCreateMultiTimeseriesReq) ReadField4(iprot thrift.TProtocol) error
func (*TSCreateMultiTimeseriesReq) ReadField5 ¶
func (p *TSCreateMultiTimeseriesReq) ReadField5(iprot thrift.TProtocol) error
func (*TSCreateMultiTimeseriesReq) ReadField6 ¶
func (p *TSCreateMultiTimeseriesReq) ReadField6(iprot thrift.TProtocol) error
func (*TSCreateMultiTimeseriesReq) ReadField7 ¶
func (p *TSCreateMultiTimeseriesReq) ReadField7(iprot thrift.TProtocol) error
func (*TSCreateMultiTimeseriesReq) ReadField8 ¶
func (p *TSCreateMultiTimeseriesReq) ReadField8(iprot thrift.TProtocol) error
func (*TSCreateMultiTimeseriesReq) ReadField9 ¶
func (p *TSCreateMultiTimeseriesReq) ReadField9(iprot thrift.TProtocol) error
func (*TSCreateMultiTimeseriesReq) String ¶
func (p *TSCreateMultiTimeseriesReq) String() string
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) 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(iprot thrift.TProtocol) error
func (*TSCreateTimeseriesReq) ReadField1 ¶
func (p *TSCreateTimeseriesReq) ReadField1(iprot thrift.TProtocol) error
func (*TSCreateTimeseriesReq) ReadField2 ¶
func (p *TSCreateTimeseriesReq) ReadField2(iprot thrift.TProtocol) error
func (*TSCreateTimeseriesReq) ReadField3 ¶
func (p *TSCreateTimeseriesReq) ReadField3(iprot thrift.TProtocol) error
func (*TSCreateTimeseriesReq) ReadField4 ¶
func (p *TSCreateTimeseriesReq) ReadField4(iprot thrift.TProtocol) error
func (*TSCreateTimeseriesReq) ReadField5 ¶
func (p *TSCreateTimeseriesReq) ReadField5(iprot thrift.TProtocol) error
func (*TSCreateTimeseriesReq) ReadField6 ¶
func (p *TSCreateTimeseriesReq) ReadField6(iprot thrift.TProtocol) error
func (*TSCreateTimeseriesReq) ReadField7 ¶
func (p *TSCreateTimeseriesReq) ReadField7(iprot thrift.TProtocol) error
func (*TSCreateTimeseriesReq) ReadField8 ¶
func (p *TSCreateTimeseriesReq) ReadField8(iprot thrift.TProtocol) error
func (*TSCreateTimeseriesReq) ReadField9 ¶
func (p *TSCreateTimeseriesReq) ReadField9(iprot thrift.TProtocol) error
func (*TSCreateTimeseriesReq) String ¶
func (p *TSCreateTimeseriesReq) String() string
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) 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) ReadField1 ¶
func (p *TSDeleteDataReq) ReadField1(iprot thrift.TProtocol) error
func (*TSDeleteDataReq) ReadField2 ¶
func (p *TSDeleteDataReq) ReadField2(iprot thrift.TProtocol) error
func (*TSDeleteDataReq) ReadField3 ¶
func (p *TSDeleteDataReq) ReadField3(iprot thrift.TProtocol) error
func (*TSDeleteDataReq) ReadField4 ¶
func (p *TSDeleteDataReq) ReadField4(iprot thrift.TProtocol) error
func (*TSDeleteDataReq) String ¶
func (p *TSDeleteDataReq) String() string
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) GetSessionId ¶
func (p *TSExecuteBatchStatementReq) GetSessionId() int64
func (*TSExecuteBatchStatementReq) GetStatements ¶
func (p *TSExecuteBatchStatementReq) GetStatements() []string
func (*TSExecuteBatchStatementReq) Read ¶
func (p *TSExecuteBatchStatementReq) Read(iprot thrift.TProtocol) error
func (*TSExecuteBatchStatementReq) ReadField1 ¶
func (p *TSExecuteBatchStatementReq) ReadField1(iprot thrift.TProtocol) error
func (*TSExecuteBatchStatementReq) ReadField2 ¶
func (p *TSExecuteBatchStatementReq) ReadField2(iprot thrift.TProtocol) error
func (*TSExecuteBatchStatementReq) String ¶
func (p *TSExecuteBatchStatementReq) String() string
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"` }
Attributes:
- SessionId
- Statement
- StatementId
- FetchSize
var TSIServiceExecuteQueryStatementArgs_Req_DEFAULT *TSExecuteStatementReq
var TSIServiceExecuteStatementArgs_Req_DEFAULT *TSExecuteStatementReq
var TSIServiceExecuteUpdateStatementArgs_Req_DEFAULT *TSExecuteStatementReq
func NewTSExecuteStatementReq ¶
func NewTSExecuteStatementReq() *TSExecuteStatementReq
func (*TSExecuteStatementReq) GetFetchSize ¶
func (p *TSExecuteStatementReq) GetFetchSize() int32
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) IsSetFetchSize ¶
func (p *TSExecuteStatementReq) IsSetFetchSize() bool
func (*TSExecuteStatementReq) Read ¶
func (p *TSExecuteStatementReq) Read(iprot thrift.TProtocol) error
func (*TSExecuteStatementReq) ReadField1 ¶
func (p *TSExecuteStatementReq) ReadField1(iprot thrift.TProtocol) error
func (*TSExecuteStatementReq) ReadField2 ¶
func (p *TSExecuteStatementReq) ReadField2(iprot thrift.TProtocol) error
func (*TSExecuteStatementReq) ReadField3 ¶
func (p *TSExecuteStatementReq) ReadField3(iprot thrift.TProtocol) error
func (*TSExecuteStatementReq) ReadField4 ¶
func (p *TSExecuteStatementReq) ReadField4(iprot thrift.TProtocol) error
func (*TSExecuteStatementReq) String ¶
func (p *TSExecuteStatementReq) String() string
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"` }
Attributes:
- Status
- QueryId
- Columns
- OperationType
- IgnoreTimeStamp
- DataTypeList
- QueryDataSet
- NonAlignQueryDataSet
- ColumnNameIndexMap
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) 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) GetStatus ¶
func (p *TSExecuteStatementResp) GetStatus() *TSStatus
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) IsSetStatus ¶
func (p *TSExecuteStatementResp) IsSetStatus() bool
func (*TSExecuteStatementResp) Read ¶
func (p *TSExecuteStatementResp) Read(iprot thrift.TProtocol) error
func (*TSExecuteStatementResp) ReadField1 ¶
func (p *TSExecuteStatementResp) ReadField1(iprot thrift.TProtocol) error
func (*TSExecuteStatementResp) ReadField2 ¶
func (p *TSExecuteStatementResp) ReadField2(iprot thrift.TProtocol) error
func (*TSExecuteStatementResp) ReadField3 ¶
func (p *TSExecuteStatementResp) ReadField3(iprot thrift.TProtocol) error
func (*TSExecuteStatementResp) ReadField4 ¶
func (p *TSExecuteStatementResp) ReadField4(iprot thrift.TProtocol) error
func (*TSExecuteStatementResp) ReadField5 ¶
func (p *TSExecuteStatementResp) ReadField5(iprot thrift.TProtocol) error
func (*TSExecuteStatementResp) ReadField6 ¶
func (p *TSExecuteStatementResp) ReadField6(iprot thrift.TProtocol) error
func (*TSExecuteStatementResp) ReadField7 ¶
func (p *TSExecuteStatementResp) ReadField7(iprot thrift.TProtocol) error
func (*TSExecuteStatementResp) ReadField8 ¶
func (p *TSExecuteStatementResp) ReadField8(iprot thrift.TProtocol) error
func (*TSExecuteStatementResp) ReadField9 ¶
func (p *TSExecuteStatementResp) ReadField9(iprot thrift.TProtocol) error
func (*TSExecuteStatementResp) String ¶
func (p *TSExecuteStatementResp) String() string
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) 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) ReadField1 ¶
func (p *TSFetchMetadataReq) ReadField1(iprot thrift.TProtocol) error
func (*TSFetchMetadataReq) ReadField2 ¶
func (p *TSFetchMetadataReq) ReadField2(iprot thrift.TProtocol) error
func (*TSFetchMetadataReq) ReadField3 ¶
func (p *TSFetchMetadataReq) ReadField3(iprot thrift.TProtocol) error
func (*TSFetchMetadataReq) String ¶
func (p *TSFetchMetadataReq) String() string
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) 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) ReadField1 ¶
func (p *TSFetchMetadataResp) ReadField1(iprot thrift.TProtocol) error
func (*TSFetchMetadataResp) ReadField2 ¶
func (p *TSFetchMetadataResp) ReadField2(iprot thrift.TProtocol) error
func (*TSFetchMetadataResp) ReadField3 ¶
func (p *TSFetchMetadataResp) ReadField3(iprot thrift.TProtocol) error
func (*TSFetchMetadataResp) ReadField4 ¶
func (p *TSFetchMetadataResp) ReadField4(iprot thrift.TProtocol) error
func (*TSFetchMetadataResp) String ¶
func (p *TSFetchMetadataResp) String() string
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"` }
Attributes:
- SessionId
- Statement
- FetchSize
- QueryId
- IsAlign
var TSIServiceFetchResultsArgs_Req_DEFAULT *TSFetchResultsReq
func NewTSFetchResultsReq ¶
func NewTSFetchResultsReq() *TSFetchResultsReq
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) ReadField1 ¶
func (p *TSFetchResultsReq) ReadField1(iprot thrift.TProtocol) error
func (*TSFetchResultsReq) ReadField2 ¶
func (p *TSFetchResultsReq) ReadField2(iprot thrift.TProtocol) error
func (*TSFetchResultsReq) ReadField3 ¶
func (p *TSFetchResultsReq) ReadField3(iprot thrift.TProtocol) error
func (*TSFetchResultsReq) ReadField4 ¶
func (p *TSFetchResultsReq) ReadField4(iprot thrift.TProtocol) error
func (*TSFetchResultsReq) ReadField5 ¶
func (p *TSFetchResultsReq) ReadField5(iprot thrift.TProtocol) error
func (*TSFetchResultsReq) String ¶
func (p *TSFetchResultsReq) String() string
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) 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) ReadField1 ¶
func (p *TSFetchResultsResp) ReadField1(iprot thrift.TProtocol) error
func (*TSFetchResultsResp) ReadField2 ¶
func (p *TSFetchResultsResp) ReadField2(iprot thrift.TProtocol) error
func (*TSFetchResultsResp) ReadField3 ¶
func (p *TSFetchResultsResp) ReadField3(iprot thrift.TProtocol) error
func (*TSFetchResultsResp) ReadField4 ¶
func (p *TSFetchResultsResp) ReadField4(iprot thrift.TProtocol) error
func (*TSFetchResultsResp) ReadField5 ¶
func (p *TSFetchResultsResp) ReadField5(iprot thrift.TProtocol) error
func (*TSFetchResultsResp) String ¶
func (p *TSFetchResultsResp) String() string
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) GetQueryId ¶
func (p *TSGetOperationStatusReq) GetQueryId() int64
func (*TSGetOperationStatusReq) GetSessionId ¶
func (p *TSGetOperationStatusReq) GetSessionId() int64
func (*TSGetOperationStatusReq) Read ¶
func (p *TSGetOperationStatusReq) Read(iprot thrift.TProtocol) error
func (*TSGetOperationStatusReq) ReadField1 ¶
func (p *TSGetOperationStatusReq) ReadField1(iprot thrift.TProtocol) error
func (*TSGetOperationStatusReq) ReadField2 ¶
func (p *TSGetOperationStatusReq) ReadField2(iprot thrift.TProtocol) error
func (*TSGetOperationStatusReq) String ¶
func (p *TSGetOperationStatusReq) String() string
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) GetStatus ¶
func (p *TSGetTimeZoneResp) GetStatus() *TSStatus
func (*TSGetTimeZoneResp) GetTimeZone ¶
func (p *TSGetTimeZoneResp) GetTimeZone() string
func (*TSGetTimeZoneResp) IsSetStatus ¶
func (p *TSGetTimeZoneResp) IsSetStatus() bool
func (*TSGetTimeZoneResp) ReadField1 ¶
func (p *TSGetTimeZoneResp) ReadField1(iprot thrift.TProtocol) error
func (*TSGetTimeZoneResp) ReadField2 ¶
func (p *TSGetTimeZoneResp) ReadField2(iprot thrift.TProtocol) error
func (*TSGetTimeZoneResp) String ¶
func (p *TSGetTimeZoneResp) String() string
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 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 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 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: // - SessionId RequestStatementId(ctx context.Context, sessionId int64) (r int64, err 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(iprot thrift.TProtocol) error
func (*TSIServiceCancelOperationArgs) ReadField1 ¶
func (p *TSIServiceCancelOperationArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceCancelOperationArgs) String ¶
func (p *TSIServiceCancelOperationArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceCancelOperationResult) ReadField0 ¶
func (p *TSIServiceCancelOperationResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceCancelOperationResult) String ¶
func (p *TSIServiceCancelOperationResult) String() string
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) 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) CreateMultiTimeseries ¶
func (p *TSIServiceClient) CreateMultiTimeseries(ctx context.Context, req *TSCreateMultiTimeseriesReq) (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) ExecuteBatchStatement ¶
func (p *TSIServiceClient) ExecuteBatchStatement(ctx context.Context, req *TSExecuteBatchStatementReq) (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) 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) 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) OpenSession ¶
func (p *TSIServiceClient) OpenSession(ctx context.Context, req *TSOpenSessionReq) (r *TSOpenSessionResp, err error)
Parameters:
- Req
func (*TSIServiceClient) RequestStatementId ¶
func (p *TSIServiceClient) RequestStatementId(ctx context.Context, sessionId int64) (r int64, err error)
Parameters:
- SessionId
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) 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) 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
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(iprot thrift.TProtocol) error
func (*TSIServiceCloseOperationArgs) ReadField1 ¶
func (p *TSIServiceCloseOperationArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceCloseOperationArgs) String ¶
func (p *TSIServiceCloseOperationArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceCloseOperationResult) ReadField0 ¶
func (p *TSIServiceCloseOperationResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceCloseOperationResult) String ¶
func (p *TSIServiceCloseOperationResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceCloseSessionArgs) ReadField1 ¶
func (p *TSIServiceCloseSessionArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceCloseSessionArgs) String ¶
func (p *TSIServiceCloseSessionArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceCloseSessionResult) ReadField0 ¶
func (p *TSIServiceCloseSessionResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceCloseSessionResult) String ¶
func (p *TSIServiceCloseSessionResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceCreateMultiTimeseriesArgs) ReadField1 ¶
func (p *TSIServiceCreateMultiTimeseriesArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceCreateMultiTimeseriesArgs) String ¶
func (p *TSIServiceCreateMultiTimeseriesArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceCreateMultiTimeseriesResult) ReadField0 ¶
func (p *TSIServiceCreateMultiTimeseriesResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceCreateMultiTimeseriesResult) String ¶
func (p *TSIServiceCreateMultiTimeseriesResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceCreateTimeseriesArgs) ReadField1 ¶
func (p *TSIServiceCreateTimeseriesArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceCreateTimeseriesArgs) String ¶
func (p *TSIServiceCreateTimeseriesArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceCreateTimeseriesResult) ReadField0 ¶
func (p *TSIServiceCreateTimeseriesResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceCreateTimeseriesResult) String ¶
func (p *TSIServiceCreateTimeseriesResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceDeleteDataArgs) ReadField1 ¶
func (p *TSIServiceDeleteDataArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceDeleteDataArgs) String ¶
func (p *TSIServiceDeleteDataArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceDeleteDataResult) ReadField0 ¶
func (p *TSIServiceDeleteDataResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceDeleteDataResult) String ¶
func (p *TSIServiceDeleteDataResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceDeleteStorageGroupsArgs) ReadField1 ¶
func (p *TSIServiceDeleteStorageGroupsArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceDeleteStorageGroupsArgs) ReadField2 ¶
func (p *TSIServiceDeleteStorageGroupsArgs) ReadField2(iprot thrift.TProtocol) error
func (*TSIServiceDeleteStorageGroupsArgs) String ¶
func (p *TSIServiceDeleteStorageGroupsArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceDeleteStorageGroupsResult) ReadField0 ¶
func (p *TSIServiceDeleteStorageGroupsResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceDeleteStorageGroupsResult) String ¶
func (p *TSIServiceDeleteStorageGroupsResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceDeleteTimeseriesArgs) ReadField1 ¶
func (p *TSIServiceDeleteTimeseriesArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceDeleteTimeseriesArgs) ReadField2 ¶
func (p *TSIServiceDeleteTimeseriesArgs) ReadField2(iprot thrift.TProtocol) error
func (*TSIServiceDeleteTimeseriesArgs) String ¶
func (p *TSIServiceDeleteTimeseriesArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceDeleteTimeseriesResult) ReadField0 ¶
func (p *TSIServiceDeleteTimeseriesResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceDeleteTimeseriesResult) String ¶
func (p *TSIServiceDeleteTimeseriesResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceExecuteBatchStatementArgs) ReadField1 ¶
func (p *TSIServiceExecuteBatchStatementArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceExecuteBatchStatementArgs) String ¶
func (p *TSIServiceExecuteBatchStatementArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceExecuteBatchStatementResult) ReadField0 ¶
func (p *TSIServiceExecuteBatchStatementResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceExecuteBatchStatementResult) String ¶
func (p *TSIServiceExecuteBatchStatementResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceExecuteQueryStatementArgs) ReadField1 ¶
func (p *TSIServiceExecuteQueryStatementArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceExecuteQueryStatementArgs) String ¶
func (p *TSIServiceExecuteQueryStatementArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceExecuteQueryStatementResult) ReadField0 ¶
func (p *TSIServiceExecuteQueryStatementResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceExecuteQueryStatementResult) String ¶
func (p *TSIServiceExecuteQueryStatementResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceExecuteRawDataQueryArgs) ReadField1 ¶
func (p *TSIServiceExecuteRawDataQueryArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceExecuteRawDataQueryArgs) String ¶
func (p *TSIServiceExecuteRawDataQueryArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceExecuteRawDataQueryResult) ReadField0 ¶
func (p *TSIServiceExecuteRawDataQueryResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceExecuteRawDataQueryResult) String ¶
func (p *TSIServiceExecuteRawDataQueryResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceExecuteStatementArgs) ReadField1 ¶
func (p *TSIServiceExecuteStatementArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceExecuteStatementArgs) String ¶
func (p *TSIServiceExecuteStatementArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceExecuteStatementResult) ReadField0 ¶
func (p *TSIServiceExecuteStatementResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceExecuteStatementResult) String ¶
func (p *TSIServiceExecuteStatementResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceExecuteUpdateStatementArgs) ReadField1 ¶
func (p *TSIServiceExecuteUpdateStatementArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceExecuteUpdateStatementArgs) String ¶
func (p *TSIServiceExecuteUpdateStatementArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceExecuteUpdateStatementResult) ReadField0 ¶
func (p *TSIServiceExecuteUpdateStatementResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceExecuteUpdateStatementResult) String ¶
func (p *TSIServiceExecuteUpdateStatementResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceFetchMetadataArgs) ReadField1 ¶
func (p *TSIServiceFetchMetadataArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceFetchMetadataArgs) String ¶
func (p *TSIServiceFetchMetadataArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceFetchMetadataResult) ReadField0 ¶
func (p *TSIServiceFetchMetadataResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceFetchMetadataResult) String ¶
func (p *TSIServiceFetchMetadataResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceFetchResultsArgs) ReadField1 ¶
func (p *TSIServiceFetchResultsArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceFetchResultsArgs) String ¶
func (p *TSIServiceFetchResultsArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceFetchResultsResult) ReadField0 ¶
func (p *TSIServiceFetchResultsResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceFetchResultsResult) String ¶
func (p *TSIServiceFetchResultsResult) String() string
type TSIServiceGetPropertiesArgs ¶
type TSIServiceGetPropertiesArgs struct { }
func NewTSIServiceGetPropertiesArgs ¶
func NewTSIServiceGetPropertiesArgs() *TSIServiceGetPropertiesArgs
func (*TSIServiceGetPropertiesArgs) Read ¶
func (p *TSIServiceGetPropertiesArgs) Read(iprot thrift.TProtocol) error
func (*TSIServiceGetPropertiesArgs) String ¶
func (p *TSIServiceGetPropertiesArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceGetPropertiesResult) ReadField0 ¶
func (p *TSIServiceGetPropertiesResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceGetPropertiesResult) String ¶
func (p *TSIServiceGetPropertiesResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceGetTimeZoneArgs) ReadField1 ¶
func (p *TSIServiceGetTimeZoneArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceGetTimeZoneArgs) String ¶
func (p *TSIServiceGetTimeZoneArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceGetTimeZoneResult) ReadField0 ¶
func (p *TSIServiceGetTimeZoneResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceGetTimeZoneResult) String ¶
func (p *TSIServiceGetTimeZoneResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceInsertRecordArgs) ReadField1 ¶
func (p *TSIServiceInsertRecordArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceInsertRecordArgs) String ¶
func (p *TSIServiceInsertRecordArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceInsertRecordResult) ReadField0 ¶
func (p *TSIServiceInsertRecordResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceInsertRecordResult) String ¶
func (p *TSIServiceInsertRecordResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceInsertRecordsArgs) ReadField1 ¶
func (p *TSIServiceInsertRecordsArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceInsertRecordsArgs) String ¶
func (p *TSIServiceInsertRecordsArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceInsertRecordsResult) ReadField0 ¶
func (p *TSIServiceInsertRecordsResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceInsertRecordsResult) String ¶
func (p *TSIServiceInsertRecordsResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceInsertStringRecordArgs) ReadField1 ¶
func (p *TSIServiceInsertStringRecordArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceInsertStringRecordArgs) String ¶
func (p *TSIServiceInsertStringRecordArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceInsertStringRecordResult) ReadField0 ¶
func (p *TSIServiceInsertStringRecordResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceInsertStringRecordResult) String ¶
func (p *TSIServiceInsertStringRecordResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceInsertStringRecordsArgs) ReadField1 ¶
func (p *TSIServiceInsertStringRecordsArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceInsertStringRecordsArgs) String ¶
func (p *TSIServiceInsertStringRecordsArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceInsertStringRecordsResult) ReadField0 ¶
func (p *TSIServiceInsertStringRecordsResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceInsertStringRecordsResult) String ¶
func (p *TSIServiceInsertStringRecordsResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceInsertTabletArgs) ReadField1 ¶
func (p *TSIServiceInsertTabletArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceInsertTabletArgs) String ¶
func (p *TSIServiceInsertTabletArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceInsertTabletResult) ReadField0 ¶
func (p *TSIServiceInsertTabletResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceInsertTabletResult) String ¶
func (p *TSIServiceInsertTabletResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceInsertTabletsArgs) ReadField1 ¶
func (p *TSIServiceInsertTabletsArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceInsertTabletsArgs) String ¶
func (p *TSIServiceInsertTabletsArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceInsertTabletsResult) ReadField0 ¶
func (p *TSIServiceInsertTabletsResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceInsertTabletsResult) String ¶
func (p *TSIServiceInsertTabletsResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceOpenSessionArgs) ReadField1 ¶
func (p *TSIServiceOpenSessionArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceOpenSessionArgs) String ¶
func (p *TSIServiceOpenSessionArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceOpenSessionResult) ReadField0 ¶
func (p *TSIServiceOpenSessionResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceOpenSessionResult) String ¶
func (p *TSIServiceOpenSessionResult) String() string
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 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(iprot thrift.TProtocol) error
func (*TSIServiceRequestStatementIdArgs) ReadField1 ¶
func (p *TSIServiceRequestStatementIdArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceRequestStatementIdArgs) String ¶
func (p *TSIServiceRequestStatementIdArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceRequestStatementIdResult) ReadField0 ¶
func (p *TSIServiceRequestStatementIdResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceRequestStatementIdResult) String ¶
func (p *TSIServiceRequestStatementIdResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceSetStorageGroupArgs) ReadField1 ¶
func (p *TSIServiceSetStorageGroupArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceSetStorageGroupArgs) ReadField2 ¶
func (p *TSIServiceSetStorageGroupArgs) ReadField2(iprot thrift.TProtocol) error
func (*TSIServiceSetStorageGroupArgs) String ¶
func (p *TSIServiceSetStorageGroupArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceSetStorageGroupResult) ReadField0 ¶
func (p *TSIServiceSetStorageGroupResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceSetStorageGroupResult) String ¶
func (p *TSIServiceSetStorageGroupResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceSetTimeZoneArgs) ReadField1 ¶
func (p *TSIServiceSetTimeZoneArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceSetTimeZoneArgs) String ¶
func (p *TSIServiceSetTimeZoneArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceSetTimeZoneResult) ReadField0 ¶
func (p *TSIServiceSetTimeZoneResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceSetTimeZoneResult) String ¶
func (p *TSIServiceSetTimeZoneResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertRecordArgs) ReadField1 ¶
func (p *TSIServiceTestInsertRecordArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertRecordArgs) String ¶
func (p *TSIServiceTestInsertRecordArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertRecordResult) ReadField0 ¶
func (p *TSIServiceTestInsertRecordResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertRecordResult) String ¶
func (p *TSIServiceTestInsertRecordResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertRecordsArgs) ReadField1 ¶
func (p *TSIServiceTestInsertRecordsArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertRecordsArgs) String ¶
func (p *TSIServiceTestInsertRecordsArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertRecordsResult) ReadField0 ¶
func (p *TSIServiceTestInsertRecordsResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertRecordsResult) String ¶
func (p *TSIServiceTestInsertRecordsResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertStringRecordArgs) ReadField1 ¶
func (p *TSIServiceTestInsertStringRecordArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertStringRecordArgs) String ¶
func (p *TSIServiceTestInsertStringRecordArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertStringRecordResult) ReadField0 ¶
func (p *TSIServiceTestInsertStringRecordResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertStringRecordResult) String ¶
func (p *TSIServiceTestInsertStringRecordResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertStringRecordsArgs) ReadField1 ¶
func (p *TSIServiceTestInsertStringRecordsArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertStringRecordsArgs) String ¶
func (p *TSIServiceTestInsertStringRecordsArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertStringRecordsResult) ReadField0 ¶
func (p *TSIServiceTestInsertStringRecordsResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertStringRecordsResult) String ¶
func (p *TSIServiceTestInsertStringRecordsResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertTabletArgs) ReadField1 ¶
func (p *TSIServiceTestInsertTabletArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertTabletArgs) String ¶
func (p *TSIServiceTestInsertTabletArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertTabletResult) ReadField0 ¶
func (p *TSIServiceTestInsertTabletResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertTabletResult) String ¶
func (p *TSIServiceTestInsertTabletResult) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertTabletsArgs) ReadField1 ¶
func (p *TSIServiceTestInsertTabletsArgs) ReadField1(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertTabletsArgs) String ¶
func (p *TSIServiceTestInsertTabletsArgs) String() string
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(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertTabletsResult) ReadField0 ¶
func (p *TSIServiceTestInsertTabletsResult) ReadField0(iprot thrift.TProtocol) error
func (*TSIServiceTestInsertTabletsResult) String ¶
func (p *TSIServiceTestInsertTabletsResult) String() string
type TSInsertRecordReq ¶
type TSInsertRecordReq struct { SessionId int64 `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"` DeviceId string `thrift:"deviceId,2,required" db:"deviceId" json:"deviceId"` 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"` }
Attributes:
- SessionId
- DeviceId
- Measurements
- Values
- Timestamp
var TSIServiceInsertRecordArgs_Req_DEFAULT *TSInsertRecordReq
var TSIServiceTestInsertRecordArgs_Req_DEFAULT *TSInsertRecordReq
func NewTSInsertRecordReq ¶
func NewTSInsertRecordReq() *TSInsertRecordReq
func (*TSInsertRecordReq) GetDeviceId ¶
func (p *TSInsertRecordReq) GetDeviceId() string
func (*TSInsertRecordReq) GetMeasurements ¶
func (p *TSInsertRecordReq) GetMeasurements() []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) ReadField1 ¶
func (p *TSInsertRecordReq) ReadField1(iprot thrift.TProtocol) error
func (*TSInsertRecordReq) ReadField2 ¶
func (p *TSInsertRecordReq) ReadField2(iprot thrift.TProtocol) error
func (*TSInsertRecordReq) ReadField3 ¶
func (p *TSInsertRecordReq) ReadField3(iprot thrift.TProtocol) error
func (*TSInsertRecordReq) ReadField4 ¶
func (p *TSInsertRecordReq) ReadField4(iprot thrift.TProtocol) error
func (*TSInsertRecordReq) ReadField5 ¶
func (p *TSInsertRecordReq) ReadField5(iprot thrift.TProtocol) error
func (*TSInsertRecordReq) String ¶
func (p *TSInsertRecordReq) String() string
type TSInsertRecordsReq ¶
type TSInsertRecordsReq struct { SessionId int64 `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"` DeviceIds []string `thrift:"deviceIds,2,required" db:"deviceIds" json:"deviceIds"` 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"` }
Attributes:
- SessionId
- DeviceIds
- MeasurementsList
- ValuesList
- Timestamps
var TSIServiceInsertRecordsArgs_Req_DEFAULT *TSInsertRecordsReq
var TSIServiceTestInsertRecordsArgs_Req_DEFAULT *TSInsertRecordsReq
func NewTSInsertRecordsReq ¶
func NewTSInsertRecordsReq() *TSInsertRecordsReq
func (*TSInsertRecordsReq) GetDeviceIds ¶
func (p *TSInsertRecordsReq) GetDeviceIds() []string
func (*TSInsertRecordsReq) GetMeasurementsList ¶
func (p *TSInsertRecordsReq) GetMeasurementsList() [][]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) ReadField1 ¶
func (p *TSInsertRecordsReq) ReadField1(iprot thrift.TProtocol) error
func (*TSInsertRecordsReq) ReadField2 ¶
func (p *TSInsertRecordsReq) ReadField2(iprot thrift.TProtocol) error
func (*TSInsertRecordsReq) ReadField3 ¶
func (p *TSInsertRecordsReq) ReadField3(iprot thrift.TProtocol) error
func (*TSInsertRecordsReq) ReadField4 ¶
func (p *TSInsertRecordsReq) ReadField4(iprot thrift.TProtocol) error
func (*TSInsertRecordsReq) ReadField5 ¶
func (p *TSInsertRecordsReq) ReadField5(iprot thrift.TProtocol) error
func (*TSInsertRecordsReq) String ¶
func (p *TSInsertRecordsReq) String() string
type TSInsertStringRecordReq ¶
type TSInsertStringRecordReq struct { SessionId int64 `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"` DeviceId string `thrift:"deviceId,2,required" db:"deviceId" json:"deviceId"` 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"` }
Attributes:
- SessionId
- DeviceId
- Measurements
- Values
- Timestamp
var TSIServiceInsertStringRecordArgs_Req_DEFAULT *TSInsertStringRecordReq
var TSIServiceTestInsertStringRecordArgs_Req_DEFAULT *TSInsertStringRecordReq
func NewTSInsertStringRecordReq ¶
func NewTSInsertStringRecordReq() *TSInsertStringRecordReq
func (*TSInsertStringRecordReq) GetDeviceId ¶
func (p *TSInsertStringRecordReq) GetDeviceId() string
func (*TSInsertStringRecordReq) GetMeasurements ¶
func (p *TSInsertStringRecordReq) GetMeasurements() []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) Read ¶
func (p *TSInsertStringRecordReq) Read(iprot thrift.TProtocol) error
func (*TSInsertStringRecordReq) ReadField1 ¶
func (p *TSInsertStringRecordReq) ReadField1(iprot thrift.TProtocol) error
func (*TSInsertStringRecordReq) ReadField2 ¶
func (p *TSInsertStringRecordReq) ReadField2(iprot thrift.TProtocol) error
func (*TSInsertStringRecordReq) ReadField3 ¶
func (p *TSInsertStringRecordReq) ReadField3(iprot thrift.TProtocol) error
func (*TSInsertStringRecordReq) ReadField4 ¶
func (p *TSInsertStringRecordReq) ReadField4(iprot thrift.TProtocol) error
func (*TSInsertStringRecordReq) ReadField5 ¶
func (p *TSInsertStringRecordReq) ReadField5(iprot thrift.TProtocol) error
func (*TSInsertStringRecordReq) String ¶
func (p *TSInsertStringRecordReq) String() string
type TSInsertStringRecordsReq ¶
type TSInsertStringRecordsReq struct { SessionId int64 `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"` DeviceIds []string `thrift:"deviceIds,2,required" db:"deviceIds" json:"deviceIds"` 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"` }
Attributes:
- SessionId
- DeviceIds
- MeasurementsList
- ValuesList
- Timestamps
var TSIServiceInsertStringRecordsArgs_Req_DEFAULT *TSInsertStringRecordsReq
var TSIServiceTestInsertStringRecordsArgs_Req_DEFAULT *TSInsertStringRecordsReq
func NewTSInsertStringRecordsReq ¶
func NewTSInsertStringRecordsReq() *TSInsertStringRecordsReq
func (*TSInsertStringRecordsReq) GetDeviceIds ¶
func (p *TSInsertStringRecordsReq) GetDeviceIds() []string
func (*TSInsertStringRecordsReq) GetMeasurementsList ¶
func (p *TSInsertStringRecordsReq) GetMeasurementsList() [][]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) Read ¶
func (p *TSInsertStringRecordsReq) Read(iprot thrift.TProtocol) error
func (*TSInsertStringRecordsReq) ReadField1 ¶
func (p *TSInsertStringRecordsReq) ReadField1(iprot thrift.TProtocol) error
func (*TSInsertStringRecordsReq) ReadField2 ¶
func (p *TSInsertStringRecordsReq) ReadField2(iprot thrift.TProtocol) error
func (*TSInsertStringRecordsReq) ReadField3 ¶
func (p *TSInsertStringRecordsReq) ReadField3(iprot thrift.TProtocol) error
func (*TSInsertStringRecordsReq) ReadField4 ¶
func (p *TSInsertStringRecordsReq) ReadField4(iprot thrift.TProtocol) error
func (*TSInsertStringRecordsReq) ReadField5 ¶
func (p *TSInsertStringRecordsReq) ReadField5(iprot thrift.TProtocol) error
func (*TSInsertStringRecordsReq) String ¶
func (p *TSInsertStringRecordsReq) String() string
type TSInsertTabletReq ¶
type TSInsertTabletReq struct { SessionId int64 `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"` DeviceId string `thrift:"deviceId,2,required" db:"deviceId" json:"deviceId"` 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"` }
Attributes:
- SessionId
- DeviceId
- Measurements
- Values
- Timestamps
- Types
- Size
var TSIServiceInsertTabletArgs_Req_DEFAULT *TSInsertTabletReq
var TSIServiceTestInsertTabletArgs_Req_DEFAULT *TSInsertTabletReq
func NewTSInsertTabletReq ¶
func NewTSInsertTabletReq() *TSInsertTabletReq
func (*TSInsertTabletReq) GetDeviceId ¶
func (p *TSInsertTabletReq) GetDeviceId() string
func (*TSInsertTabletReq) GetMeasurements ¶
func (p *TSInsertTabletReq) GetMeasurements() []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) ReadField1 ¶
func (p *TSInsertTabletReq) ReadField1(iprot thrift.TProtocol) error
func (*TSInsertTabletReq) ReadField2 ¶
func (p *TSInsertTabletReq) ReadField2(iprot thrift.TProtocol) error
func (*TSInsertTabletReq) ReadField3 ¶
func (p *TSInsertTabletReq) ReadField3(iprot thrift.TProtocol) error
func (*TSInsertTabletReq) ReadField4 ¶
func (p *TSInsertTabletReq) ReadField4(iprot thrift.TProtocol) error
func (*TSInsertTabletReq) ReadField5 ¶
func (p *TSInsertTabletReq) ReadField5(iprot thrift.TProtocol) error
func (*TSInsertTabletReq) ReadField6 ¶
func (p *TSInsertTabletReq) ReadField6(iprot thrift.TProtocol) error
func (*TSInsertTabletReq) ReadField7 ¶
func (p *TSInsertTabletReq) ReadField7(iprot thrift.TProtocol) error
func (*TSInsertTabletReq) String ¶
func (p *TSInsertTabletReq) String() string
type TSInsertTabletsReq ¶
type TSInsertTabletsReq struct { SessionId int64 `thrift:"sessionId,1,required" db:"sessionId" json:"sessionId"` DeviceIds []string `thrift:"deviceIds,2,required" db:"deviceIds" json:"deviceIds"` 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"` }
Attributes:
- SessionId
- DeviceIds
- MeasurementsList
- ValuesList
- TimestampsList
- TypesList
- SizeList
var TSIServiceInsertTabletsArgs_Req_DEFAULT *TSInsertTabletsReq
var TSIServiceTestInsertTabletsArgs_Req_DEFAULT *TSInsertTabletsReq
func NewTSInsertTabletsReq ¶
func NewTSInsertTabletsReq() *TSInsertTabletsReq
func (*TSInsertTabletsReq) GetDeviceIds ¶
func (p *TSInsertTabletsReq) GetDeviceIds() []string
func (*TSInsertTabletsReq) GetMeasurementsList ¶
func (p *TSInsertTabletsReq) GetMeasurementsList() [][]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) ReadField1 ¶
func (p *TSInsertTabletsReq) ReadField1(iprot thrift.TProtocol) error
func (*TSInsertTabletsReq) ReadField2 ¶
func (p *TSInsertTabletsReq) ReadField2(iprot thrift.TProtocol) error
func (*TSInsertTabletsReq) ReadField3 ¶
func (p *TSInsertTabletsReq) ReadField3(iprot thrift.TProtocol) error
func (*TSInsertTabletsReq) ReadField4 ¶
func (p *TSInsertTabletsReq) ReadField4(iprot thrift.TProtocol) error
func (*TSInsertTabletsReq) ReadField5 ¶
func (p *TSInsertTabletsReq) ReadField5(iprot thrift.TProtocol) error
func (*TSInsertTabletsReq) ReadField6 ¶
func (p *TSInsertTabletsReq) ReadField6(iprot thrift.TProtocol) error
func (*TSInsertTabletsReq) ReadField7 ¶
func (p *TSInsertTabletsReq) ReadField7(iprot thrift.TProtocol) error
func (*TSInsertTabletsReq) String ¶
func (p *TSInsertTabletsReq) String() string
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) 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) ReadField1 ¶
func (p *TSOpenSessionReq) ReadField1(iprot thrift.TProtocol) error
func (*TSOpenSessionReq) ReadField2 ¶
func (p *TSOpenSessionReq) ReadField2(iprot thrift.TProtocol) error
func (*TSOpenSessionReq) ReadField3 ¶
func (p *TSOpenSessionReq) ReadField3(iprot thrift.TProtocol) error
func (*TSOpenSessionReq) ReadField4 ¶
func (p *TSOpenSessionReq) ReadField4(iprot thrift.TProtocol) error
func (*TSOpenSessionReq) ReadField5 ¶
func (p *TSOpenSessionReq) ReadField5(iprot thrift.TProtocol) error
func (*TSOpenSessionReq) String ¶
func (p *TSOpenSessionReq) String() string
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) 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) ReadField1 ¶
func (p *TSOpenSessionResp) ReadField1(iprot thrift.TProtocol) error
func (*TSOpenSessionResp) ReadField2 ¶
func (p *TSOpenSessionResp) ReadField2(iprot thrift.TProtocol) error
func (*TSOpenSessionResp) ReadField3 ¶
func (p *TSOpenSessionResp) ReadField3(iprot thrift.TProtocol) error
func (*TSOpenSessionResp) ReadField4 ¶
func (p *TSOpenSessionResp) ReadField4(iprot thrift.TProtocol) error
func (*TSOpenSessionResp) String ¶
func (p *TSOpenSessionResp) String() string
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
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) GetBitmapList ¶
func (p *TSQueryDataSet) GetBitmapList() [][]byte
func (*TSQueryDataSet) GetTime ¶
func (p *TSQueryDataSet) GetTime() []byte
func (*TSQueryDataSet) GetValueList ¶
func (p *TSQueryDataSet) GetValueList() [][]byte
func (*TSQueryDataSet) ReadField1 ¶
func (p *TSQueryDataSet) ReadField1(iprot thrift.TProtocol) error
func (*TSQueryDataSet) ReadField2 ¶
func (p *TSQueryDataSet) ReadField2(iprot thrift.TProtocol) error
func (*TSQueryDataSet) ReadField3 ¶
func (p *TSQueryDataSet) ReadField3(iprot thrift.TProtocol) error
func (*TSQueryDataSet) String ¶
func (p *TSQueryDataSet) String() string
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) GetTimeList ¶
func (p *TSQueryNonAlignDataSet) GetTimeList() [][]byte
func (*TSQueryNonAlignDataSet) GetValueList ¶
func (p *TSQueryNonAlignDataSet) GetValueList() [][]byte
func (*TSQueryNonAlignDataSet) Read ¶
func (p *TSQueryNonAlignDataSet) Read(iprot thrift.TProtocol) error
func (*TSQueryNonAlignDataSet) ReadField1 ¶
func (p *TSQueryNonAlignDataSet) ReadField1(iprot thrift.TProtocol) error
func (*TSQueryNonAlignDataSet) ReadField2 ¶
func (p *TSQueryNonAlignDataSet) ReadField2(iprot thrift.TProtocol) error
func (*TSQueryNonAlignDataSet) String ¶
func (p *TSQueryNonAlignDataSet) String() string
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"` }
Attributes:
- SessionId
- Paths
- FetchSize
- StartTime
- EndTime
- StatementId
var TSIServiceExecuteRawDataQueryArgs_Req_DEFAULT *TSRawDataQueryReq
func NewTSRawDataQueryReq ¶
func NewTSRawDataQueryReq() *TSRawDataQueryReq
func (*TSRawDataQueryReq) GetEndTime ¶
func (p *TSRawDataQueryReq) GetEndTime() int64
func (*TSRawDataQueryReq) GetFetchSize ¶
func (p *TSRawDataQueryReq) GetFetchSize() int32
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) IsSetFetchSize ¶
func (p *TSRawDataQueryReq) IsSetFetchSize() bool
func (*TSRawDataQueryReq) ReadField1 ¶
func (p *TSRawDataQueryReq) ReadField1(iprot thrift.TProtocol) error
func (*TSRawDataQueryReq) ReadField2 ¶
func (p *TSRawDataQueryReq) ReadField2(iprot thrift.TProtocol) error
func (*TSRawDataQueryReq) ReadField3 ¶
func (p *TSRawDataQueryReq) ReadField3(iprot thrift.TProtocol) error
func (*TSRawDataQueryReq) ReadField4 ¶
func (p *TSRawDataQueryReq) ReadField4(iprot thrift.TProtocol) error
func (*TSRawDataQueryReq) ReadField5 ¶
func (p *TSRawDataQueryReq) ReadField5(iprot thrift.TProtocol) error
func (*TSRawDataQueryReq) ReadField6 ¶
func (p *TSRawDataQueryReq) ReadField6(iprot thrift.TProtocol) error
func (*TSRawDataQueryReq) String ¶
func (p *TSRawDataQueryReq) String() string
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) GetSessionId ¶
func (p *TSSetTimeZoneReq) GetSessionId() int64
func (*TSSetTimeZoneReq) GetTimeZone ¶
func (p *TSSetTimeZoneReq) GetTimeZone() string
func (*TSSetTimeZoneReq) ReadField1 ¶
func (p *TSSetTimeZoneReq) ReadField1(iprot thrift.TProtocol) error
func (*TSSetTimeZoneReq) ReadField2 ¶
func (p *TSSetTimeZoneReq) ReadField2(iprot thrift.TProtocol) error
func (*TSSetTimeZoneReq) String ¶
func (p *TSSetTimeZoneReq) String() string
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"` }
Attributes:
- Code
- Message
- SubStatus
var TSExecuteStatementResp_Status_DEFAULT *TSStatus
var TSFetchMetadataResp_Status_DEFAULT *TSStatus
var TSFetchResultsResp_Status_DEFAULT *TSStatus
var TSGetTimeZoneResp_Status_DEFAULT *TSStatus
var TSIServiceCancelOperationResult_Success_DEFAULT *TSStatus
var TSIServiceCloseOperationResult_Success_DEFAULT *TSStatus
var TSIServiceCloseSessionResult_Success_DEFAULT *TSStatus
var TSIServiceCreateMultiTimeseriesResult_Success_DEFAULT *TSStatus
var TSIServiceCreateTimeseriesResult_Success_DEFAULT *TSStatus
var TSIServiceDeleteDataResult_Success_DEFAULT *TSStatus
var TSIServiceDeleteStorageGroupsResult_Success_DEFAULT *TSStatus
var TSIServiceDeleteTimeseriesResult_Success_DEFAULT *TSStatus
var TSIServiceExecuteBatchStatementResult_Success_DEFAULT *TSStatus
var TSIServiceInsertRecordResult_Success_DEFAULT *TSStatus
var TSIServiceInsertRecordsResult_Success_DEFAULT *TSStatus
var TSIServiceInsertStringRecordResult_Success_DEFAULT *TSStatus
var TSIServiceInsertStringRecordsResult_Success_DEFAULT *TSStatus
var TSIServiceInsertTabletResult_Success_DEFAULT *TSStatus
var TSIServiceInsertTabletsResult_Success_DEFAULT *TSStatus
var TSIServiceSetStorageGroupResult_Success_DEFAULT *TSStatus
var TSIServiceSetTimeZoneResult_Success_DEFAULT *TSStatus
var TSIServiceTestInsertRecordResult_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 TSOpenSessionResp_Status_DEFAULT *TSStatus
func NewTSStatus ¶
func NewTSStatus() *TSStatus