client

package

Go to main page

Versions in this module

v1

v1.2.0-tsbs

May 29, 2023

v1.1.7

Apr 25, 2023

Changes in this version

type Session

+ func (s *Session) FastInsertRecords(deviceIds []string, dataTypes [][]TSDataType, values [][]interface{}, ...) (r *common.TSStatus, err error)

v1.1.6

Apr 24, 2023

v1.1.5

Apr 12, 2023

Changes in this version

type Session

+ func (s *Session) ExecuteAggregationQuery(paths []string, aggregations []common.TAggregationType, startTime *int64, ...) (*SessionDataSet, error)

v1.1.1

Jun 28, 2023

Changes in this version

type TSCompressionType

+ const LZMA2

type TSEncoding

+ const CHIMP

+ const FREQ

+ const RLBE

+ const SPRINTZ

+ const ZIGZAG

type Tablet

+ RowSize int

+ func (t *Tablet) Reset()

v1.1.1-tsbs

May 15, 2023

v1.1.0

Mar 21, 2023

Changes in this version

+ const AlreadyHasPrivilege

+ const AuthIoException

+ const InitAuthError

+ const NotHasPrivilege

+ const RoleAlreadyExist

+ const UnknownAuthPrivilege

+ const UnsupportedAuthOperation

+ const UserAlreadyExist

+ const UserAlreadyHasRole

+ const UserNotHasRole

type TSCompressionType

+ const ZSTD

v1.1.0-tsbs

May 17, 2023

v1.0.0

Dec 2, 2022

Changes in this version

+ const ActiveTriggerInstanceError

+ const AddConfignodeError

+ const AliasAlreadyExist

+ const AlignedTimeseriesError

+ const AuthenticationError

+ const CanNotConnectDatanode

+ const ClearPermissionCacheError

+ const CompactionError

+ const ConfigurationError

+ const ConsensusNotInitialized

+ const CqAlreadyActive

+ const CqAlreadyExist

+ const CqUpdateLastExecTimeError

+ const CreatePipeSinkError

+ const CreateRegionError

+ const CreateTemplateError

+ const CreateTriggerError

+ const CreateTriggerInstanceError

+ const CreateUdfOnDatanodeError

+ const DatabaseAlreadyExists

+ const DatabaseNotExist

+ const DatanodeAlreadyRegistered

+ const DatanodeNotExist

+ const DatanodeStopError

+ const DataregionProcessError

+ const DefualtConnectRetryMax

+ const DeleteRegionError

+ const DeserializePieceOfTsfileError

+ const DifferentTemplate

+ const DiskSpaceInsufficient

+ const DropTriggerError

+ const DropTriggerInstanceError

+ const DropUdfOnDatanodeError

+ const DuplicatedTemplate

+ const IllegalParameter

+ const IllegalPath

+ const InternalRequestRetryError

+ const InternalRequestTimeOut

+ const LoadPieceOfTsfileError

+ const MigrateRegionError

+ const MppMemoryNotEnough

+ const NoAvailableRegionGroup

+ const NoEnoughDatanode

+ const NoPermission

+ const NoSuchCq

+ const NotLogin

+ const OutOfTtl

+ const OverlapWithExistingTask

+ const OversizeRecord

+ const PageOutOfSpace

+ const PartitionCacheUpdateError

+ const PathAlreadyExist

+ const PathNotExist

+ const PipeError

+ const PipeserverError

+ const RecordDuplicated

+ const RedirectionRecommend

+ const RegionLeaderChangeError

+ const RegisterRemovedDatanode

+ const RemoveConfignodeError

+ const RemoveDatanodeError

+ const RoleNotExist

+ const SchemaFileNotExists

+ const SchemaFileRedoLogBroken

+ const SegmentNotFound

+ const SegmentOutOfSpace

+ const SemanticError

+ const SeriesOverflow

+ const SqlParseError

+ const StorageEngineNotReady

+ const SyncConnectionError

+ const SyncFileError

+ const SyncFileRedirectionError

+ const SystemReadOnly

+ const TemplateIncompatible

+ const TemplateIsInUse

+ const TemplateNotActivated

+ const TemplateNotSet

+ const TimeseriesAlreadyExist

+ const TimeseriesInBlackList

+ const TriggerDownloadError

+ const TriggerFireError

+ const TriggerLoadClassError

+ const TsblockSerializeError

+ const UdfDownloadError

+ const UdfLoadClassError

+ const UndefinedTemplate

+ const UnsupportedFillType

+ const UpdateTriggerLocationError

+ const UserNotExist

+ const VerifyMetadataError

+ const WalError

+ const WrongLoginPassword

type Session

+ func (s *Session) ExecuteNonQueryStatement(sql string) (r *rpc.TSStatus, err error)

v0

v0.14.0-preview1

Nov 2, 2022

v0.13.1

Mar 9, 2023

Changes in this version

+ const DefaultConnectRetryMax

type ClusterConfig

+ ConnectRetryMax int

type Config

+ ConnectRetryMax int

+ type PoolConfig struct

+ ConnectRetryMax int

+ FetchSize int32

+ Host string

+ NodeUrls []string

+ Password string

+ Port string

+ TimeZone string

+ UserName string

+ type SessionPool struct

+ func NewSessionPool(conf *PoolConfig, ...) SessionPool

+ func (spool *SessionPool) Close()

+ func (spool *SessionPool) ConstructSession(config *PoolConfig) (session Session, err error)

+ func (spool *SessionPool) GetSession() (session Session, err error)

+ func (spool *SessionPool) PutBack(session Session)

type TSDataType

+ const UNKNOWN

v0.13.0

Sep 14, 2022

Changes in this version

type Session

+ func (s *Session) CreateAlignedTimeseries(prefixPath string, measurements []string, dataTypes []TSDataType, ...) (r *rpc.TSStatus, err error)

+ func (s *Session) InsertAlignedRecord(deviceId string, measurements []string, dataTypes []TSDataType, ...) (r *rpc.TSStatus, err error)

+ func (s *Session) InsertAlignedRecords(deviceIds []string, measurements [][]string, dataTypes [][]TSDataType, ...) (r *rpc.TSStatus, err error)

+ func (s *Session) InsertAlignedRecordsOfOneDevice(deviceId string, timestamps []int64, measurementsSlice [][]string, ...) (r *rpc.TSStatus, err error)

+ func (s *Session) InsertAlignedTablet(tablet *Tablet, sorted bool) (r *rpc.TSStatus, err error)

+ func (s *Session) InsertAlignedTablets(tablets []*Tablet, sorted bool) (r *rpc.TSStatus, err error)

v0.12.1

Jul 20, 2022

Changes in this version

+ type ClusterConfig struct

+ FetchSize int32

+ NodeUrls []string

+ Password string

+ TimeZone string

+ UserName string

+ type ClusterSession struct

type Session

+ func NewClusterSession(ClusterConfig *ClusterConfig) Session

+ func (s *Session) OpenCluster(enableRPCCompression bool) error

v0.12.0

Apr 7, 2021

Changes in this version

+ const AliasAlreadyExistError

+ const AstFormatError

+ const CloseOperationError

+ const ConfigAdjuster

+ const ConsistencyFailure

+ const DefaultFetchSize

+ const DefaultTimeZone

+ const DiskSpaceInsufficientError

+ const ExecuteStatementError

+ const GenerateTimeZoneError

+ const IncompatibleVersion

+ const InternalServerError

+ const InvalidHandleStatus

+ const LoadFileError

+ const LogicalOperatorError

+ const LogicalOptimizeError

+ const MergeError

+ const MetadataError

+ const MultipleError

+ const NeedRedirection

+ const NoConnection

+ const NoLeader

+ const NoPermissionError

+ const NodeDeleteFailedError

+ const NodeReadOnly

+ const NotLoginError

+ const NotStorageGroupError

+ const OutOfTTLError

+ const PartitionNotReady

+ const PathAlreadyExistError

+ const PathErroRint32

+ const PathIllegal

+ const PathNotExistError

+ const QueryNotAllowed

+ const QueryProcessError

+ const ReadOnlySystemError

+ const SQLParseError

+ const SetTimeZoneError

+ const ShutDownError

+ const StartUpError

+ const StillExecutingStatus

+ const StorageEngineError

+ const StorageGroupError

+ const StorageGroupNotReady

+ const StorageGroupProcessorError

+ const SuccessStatus

+ const SyncConnectionException

+ const SyncDeviceOwnerConflictError

+ const SystemCheckError

+ const TimeOut

+ const TimeseriesNotExist

+ const TimestampColumnName

+ const TsfileProcessorError

+ const UninitializedAuthError

+ const UnsupportedFetchMetadataOperationError

+ const UnsupportedFillTypeError

+ const UnsupportedIndexFuncError

+ const UnsupportedIndexTypeError

+ const UnsupportedOperation

+ const WriteProcessError

+ const WriteProcessReject

+ const WrongLoginPasswordError

+ func VerifySuccess(status *rpc.TSStatus) error

+ type BatchError struct

+ func NewBatchError(statuses []*rpc.TSStatus) *BatchError

+ func (e *BatchError) Error() string

+ func (e *BatchError) GetStatuses() []*rpc.TSStatus

+ type Config struct

+ FetchSize int32

+ Host string

+ Password string

+ Port string

+ TimeZone string

+ UserName string

+ type Field struct

+ func (f *Field) GetDataType() TSDataType

+ func (f *Field) GetFloat32() float32

+ func (f *Field) GetFloat64() float64

+ func (f *Field) GetInt32() int32

+ func (f *Field) GetInt64() int64

+ func (f *Field) GetName() string

+ func (f *Field) GetText() string

+ func (f *Field) GetValue() interface{}

+ func (f *Field) IsNull() bool

+ type IoTDBRpcDataSet struct

+ func NewIoTDBRpcDataSet(sql string, columnNameList []string, columnTypes []string, ...) *IoTDBRpcDataSet

+ func (s *IoTDBRpcDataSet) Close() (err error)

+ func (s *IoTDBRpcDataSet) GetTimestamp() int64

+ func (s *IoTDBRpcDataSet) IsClosed() bool

+ type MeasurementSchema struct

+ Compressor TSCompressionType

+ DataType TSDataType

+ Encoding TSEncoding

+ Measurement string

+ Properties map[string]string

+ type RowRecord struct

+ func (r *RowRecord) GetFields() []*Field

+ func (r *RowRecord) GetTimestamp() int64

+ type Session struct

+ func NewSession(config *Config) *Session

+ func (s *Session) Close() (r *rpc.TSStatus, err error)

+ func (s *Session) CreateMultiTimeseries(paths []string, dataTypes []TSDataType, encodings []TSEncoding, ...) (r *rpc.TSStatus, err error)

+ func (s *Session) CreateTimeseries(path string, dataType TSDataType, encoding TSEncoding, ...) (r *rpc.TSStatus, err error)

+ func (s *Session) DeleteData(paths []string, startTime int64, endTime int64) (r *rpc.TSStatus, err error)

+ func (s *Session) DeleteStorageGroup(storageGroupId string) (r *rpc.TSStatus, err error)

+ func (s *Session) DeleteStorageGroups(storageGroupIds ...string) (r *rpc.TSStatus, err error)

+ func (s *Session) DeleteTimeseries(paths []string) (r *rpc.TSStatus, err error)

+ func (s *Session) ExecuteBatchStatement(inserts []string) (r *rpc.TSStatus, err error)

+ func (s *Session) ExecuteQueryStatement(sql string, timeoutMs int64) (*SessionDataSet, error)

+ func (s *Session) ExecuteRawDataQuery(paths []string, startTime int64, endTime int64) (*SessionDataSet, error)

+ func (s *Session) ExecuteStatement(sql string) (*SessionDataSet, error)

+ func (s *Session) ExecuteUpdateStatement(sql string) (*SessionDataSet, error)

+ func (s *Session) GetSessionId() int64

+ func (s *Session) GetTimeZone() (string, error)

+ func (s *Session) InsertRecord(deviceId string, measurements []string, dataTypes []TSDataType, ...) (r *rpc.TSStatus, err error)

+ func (s *Session) InsertRecords(deviceIds []string, measurements [][]string, dataTypes [][]TSDataType, ...) (r *rpc.TSStatus, err error)

+ func (s *Session) InsertRecordsOfOneDevice(deviceId string, timestamps []int64, measurementsSlice [][]string, ...) (r *rpc.TSStatus, err error)

+ func (s *Session) InsertStringRecord(deviceId string, measurements []string, values []string, timestamp int64) (r *rpc.TSStatus, err error)

+ func (s *Session) InsertTablet(tablet *Tablet, sorted bool) (r *rpc.TSStatus, err error)

+ func (s *Session) InsertTablets(tablets []*Tablet, sorted bool) (r *rpc.TSStatus, err error)

+ func (s *Session) Open(enableRPCCompression bool, connectionTimeoutInMs int) error

+ func (s *Session) SetStorageGroup(storageGroupId string) (r *rpc.TSStatus, err error)

+ func (s *Session) SetTimeZone(timeZone string) (r *rpc.TSStatus, err error)

+ type SessionDataSet struct

+ func NewSessionDataSet(sql string, columnNameList []string, columnTypeList []string, ...) *SessionDataSet

+ func (s *SessionDataSet) Close() error

+ func (s *SessionDataSet) GetBool(columnName string) bool

+ func (s *SessionDataSet) GetColumnCount() int

+ func (s *SessionDataSet) GetColumnDataType(columnIndex int) TSDataType

+ func (s *SessionDataSet) GetColumnName(columnIndex int) string

+ func (s *SessionDataSet) GetColumnNames() []string

+ func (s *SessionDataSet) GetDouble(columnName string) float64

+ func (s *SessionDataSet) GetFloat(columnName string) float32

+ func (s *SessionDataSet) GetInt32(columnName string) int32

+ func (s *SessionDataSet) GetInt64(columnName string) int64

+ func (s *SessionDataSet) GetRowRecord() (*RowRecord, error)

+ func (s *SessionDataSet) GetText(columnName string) string

+ func (s *SessionDataSet) GetTimestamp() int64

+ func (s *SessionDataSet) GetValue(columnName string) interface{}

+ func (s *SessionDataSet) IsClosed() bool

+ func (s *SessionDataSet) IsIgnoreTimeStamp() bool

+ func (s *SessionDataSet) Next() (bool, error)

+ func (s *SessionDataSet) Scan(dest ...interface{}) error

+ type TSCompressionType uint8

+ const GZIP

+ const LZ4

+ const LZO

+ const PAA

+ const PLA

+ const SDT

+ const SNAPPY

+ const UNCOMPRESSED

+ type TSDataType int8

+ const BOOLEAN

+ const DOUBLE

+ const FLOAT

+ const INT32

+ const INT64

+ const TEXT

+ const UNKNOW

+ type TSEncoding uint8

+ const BITMAP

+ const DIFF

+ const GORILLA

+ const GORILLA_V1

+ const PLAIN

+ const PLAIN_DICTIONARY

+ const REGULAR

+ const RLE

+ const TS_2DIFF

+ type Tablet struct

+ func NewTablet(deviceId string, measurementSchemas []*MeasurementSchema, rowCount int) (*Tablet, error)

+ func (t *Tablet) GetMeasurements() []string

+ func (t *Tablet) GetRowCount() int

+ func (t *Tablet) GetTimestampBytes() []byte

+ func (t *Tablet) GetValueAt(columnIndex, rowIndex int) (interface{}, error)

+ func (t *Tablet) Len() int

+ func (t *Tablet) Less(i, j int) bool

+ func (t *Tablet) SetTimestamp(timestamp int64, rowIndex int)

+ func (t *Tablet) SetValueAt(value interface{}, columnIndex, rowIndex int) error

+ func (t *Tablet) Sort() error

+ func (t *Tablet) Swap(i, j int)

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