client

package

Go to main page

Versions in this module

v2

v2.0.10

Aug 21, 2026

Changes in this version

type ClusterConfig

+ TLSConfig *TLSConfig

type Config

+ TLSConfig *TLSConfig

+ type Option func(*Options)

+ func WithCtx(ctx context.Context) Option

+ type Options struct

+ func ApplyOptions(opts ...Option) Options

type PoolConfig

+ TLSConfig *TLSConfig

type Session

+ func (s *Session) Ping(ctx context.Context) error

+ type TLSConfig struct

+ CAFile string

+ CertFile string

+ Config *tls.Config

+ KeyFile string

type TSDataType

+ const OBJECT

type Tablet

+ func (t *Tablet) SetObjectValueAt(isEOF bool, offset int64, content []byte, columnIndex, rowIndex int) error

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

v2.0.8

Mar 12, 2026

Changes in this version

+ const ATTRIBUTE

+ const ActiveTriggerInstanceError

+ const AddConfignodeError

+ const AliasAlreadyExist

+ const AlignedTimeseriesError

+ const AlreadyHasPrivilege

+ const AuthIoException

+ const BINARY_ARRAY_COLUMN_ENCODING

+ const BYTE_ARRAY_COLUMN_ENCODING

+ const CanNotConnectDatanode

+ const ClearPermissionCacheError

+ const CloseOperationError

+ 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 DEFAULT_TIME_FORMAT

+ const DEFAULT_VERSION

+ const DatabaseAlreadyExists

+ const DatabaseNotExist

+ const DatanodeAlreadyRegistered

+ const DatanodeNotExist

+ const DatanodeStopError

+ const DataregionProcessError

+ const DefaultConnectRetryMax

+ const DefaultFetchSize

+ const DefaultTimeZone

+ const DeleteRegionError

+ const DeserializePieceOfTsfileError

+ const DifferentTemplate

+ const DiskSpaceInsufficient

+ const DropTriggerError

+ const DropTriggerInstanceError

+ const DropUdfOnDatanodeError

+ const DuplicatedTemplate

+ const ExecuteStatementError

+ const FIELD

+ const GenerateTimeZoneError

+ const INT32_ARRAY_COLUMN_ENCODING

+ const INT64_ARRAY_COLUMN_ENCODING

+ const IllegalParameter

+ const IllegalPath

+ const IncompatibleVersion

+ const InitAuthError

+ const InternalRequestRetryError

+ const InternalRequestTimeOut

+ const InternalServerError

+ const LoadFileError

+ const LoadPieceOfTsfileError

+ const LogicalOperatorError

+ const LogicalOptimizeError

+ const MICROSECOND

+ const MILLISECOND

+ const MetadataError

+ const MigrateRegionError

+ const MppMemoryNotEnough

+ const MultipleError

+ const NANOSECOND

+ const NoAvailableRegionGroup

+ const NoEnoughDatanode

+ const NoPermission

+ const NoSuchCq

+ const NotHasPrivilege

+ const NotLogin

+ const OutOfTtl

+ const OverlapWithExistingTask

+ const OversizeRecord

+ const PageOutOfSpace

+ const PartitionCacheUpdateError

+ const PathAlreadyExist

+ const PathNotExist

+ const PipeError

+ const PipeserverError

+ const QueryNotAllowed

+ const QueryProcessError

+ const RLE_COLUMN_ENCODING

+ const RecordDuplicated

+ const RedirectionRecommend

+ const RegionLeaderChangeError

+ const RegisterRemovedDatanode

+ const RemoveConfignodeError

+ const RemoveDatanodeError

+ const RoleAlreadyExist

+ const RoleNotExist

+ const SchemaFileNotExists

+ const SchemaFileRedoLogBroken

+ const SegmentNotFound

+ const SegmentOutOfSpace

+ const SemanticError

+ const SeriesOverflow

+ const SetTimeZoneError

+ const ShutDownError

+ const SqlParseError

+ const StartUpError

+ const StorageEngineError

+ const StorageEngineNotReady

+ const SuccessStatus

+ const SyncConnectionError

+ const SyncFileError

+ const SyncFileRedirectionError

+ const SystemReadOnly

+ const TAG

+ const TIME_PRECISION

+ const TableSqlDialect

+ const TemplateIncompatible

+ const TemplateIsInUse

+ const TemplateNotActivated

+ const TemplateNotSet

+ const TimeseriesAlreadyExist

+ const TimeseriesInBlackList

+ const TimestampColumnName

+ const TreeSqlDialect

+ const TriggerDownloadError

+ const TriggerFireError

+ const TriggerLoadClassError

+ const TsblockSerializeError

+ const TsfileProcessorError

+ const UdfDownloadError

+ const UdfLoadClassError

+ const UndefinedTemplate

+ const UnknownAuthPrivilege

+ const UnsupportedAuthOperation

+ const UnsupportedFillType

+ const UnsupportedOperation

+ const UpdateTriggerLocationError

+ const UserAlreadyExist

+ const UserAlreadyHasRole

+ const UserNotExist

+ const UserNotHasRole

+ const V_0_12

+ const V_0_13

+ const V_1_0

+ const VerifyMetadataError

+ const WalError

+ const WriteProcessError

+ const WriteProcessReject

+ const WrongLoginPassword

+ var BitUtil = []byte

+ var ErrTableSessionClosed = errors.New("table session has been closed")

+ var UnmarkBitUtil = []byte

+ func DateToInt32(localDate time.Time) (int32, error)

+ func Int32ToDate(val int32) (time.Time, error)

+ func VerifySuccess(status *common.TSStatus) error

+ type BatchError struct

+ Message string

+ func (e *BatchError) Error() string

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

+ type Binary struct

+ func NewBinary(v []byte) *Binary

+ func (b *Binary) GetStringValue() string

+ func (b *Binary) GetValues() []byte

+ type BinaryArrayColumnDecoder struct

+ func (decoder *BinaryArrayColumnDecoder) ReadColumn(reader *bytes.Reader, dataType TSDataType, positionCount int32) (Column, error)

+ type BinaryColumn struct

+ func NewBinaryColumn(arrayOffset int32, positionCount int32, valueIsNull []bool, values []*Binary) (*BinaryColumn, error)

+ func (c *BinaryColumn) GetBinaries() ([]*Binary, error)

+ func (c *BinaryColumn) GetBinary(position int32) (*Binary, error)

+ func (c *BinaryColumn) GetBoolean(_ int32) (bool, error)

+ func (c *BinaryColumn) GetBooleans() ([]bool, error)

+ func (c *BinaryColumn) GetDataType() TSDataType

+ func (c *BinaryColumn) GetDouble(_ int32) (float64, error)

+ func (c *BinaryColumn) GetDoubles() ([]float64, error)

+ func (c *BinaryColumn) GetEncoding() ColumnEncoding

+ func (c *BinaryColumn) GetFloat(_ int32) (float32, error)

+ func (c *BinaryColumn) GetFloats() ([]float32, error)

+ func (c *BinaryColumn) GetInt(_ int32) (int32, error)

+ func (c *BinaryColumn) GetInts() ([]int32, error)

+ func (c *BinaryColumn) GetLong(_ int32) (int64, error)

+ func (c *BinaryColumn) GetLongs() ([]int64, error)

+ func (c *BinaryColumn) GetObject(position int32) (interface{}, error)

+ func (c *BinaryColumn) GetObjects() ([]interface{}, error)

+ func (c *BinaryColumn) GetPositionCount() int32

+ func (c *BinaryColumn) IsNull(position int32) bool

+ func (c *BinaryColumn) IsNulls() []bool

+ func (c *BinaryColumn) MayHaveNull() bool

+ type BitMap struct

+ func NewBitMap(size int) *BitMap

+ func (b *BitMap) GetBits() []byte

+ func (b *BitMap) IsAllUnmarked() bool

+ func (b *BitMap) IsMarked(position int) bool

+ func (b *BitMap) Mark(position int)

+ func (b *BitMap) UnMark(position int)

+ type BooleanColumn struct

+ func NewBooleanColumn(arrayOffset int32, positionCount int32, valueIsNull []bool, values []bool) (*BooleanColumn, error)

+ func (c *BooleanColumn) GetBinaries() ([]*Binary, error)

+ func (c *BooleanColumn) GetBinary(_ int32) (*Binary, error)

+ func (c *BooleanColumn) GetBoolean(position int32) (bool, error)

+ func (c *BooleanColumn) GetBooleans() ([]bool, error)

+ func (c *BooleanColumn) GetDataType() TSDataType

+ func (c *BooleanColumn) GetDouble(_ int32) (float64, error)

+ func (c *BooleanColumn) GetDoubles() ([]float64, error)

+ func (c *BooleanColumn) GetEncoding() ColumnEncoding

+ func (c *BooleanColumn) GetFloat(_ int32) (float32, error)

+ func (c *BooleanColumn) GetFloats() ([]float32, error)

+ func (c *BooleanColumn) GetInt(_ int32) (int32, error)

+ func (c *BooleanColumn) GetInts() ([]int32, error)

+ func (c *BooleanColumn) GetLong(_ int32) (int64, error)

+ func (c *BooleanColumn) GetLongs() ([]int64, error)

+ func (c *BooleanColumn) GetObject(position int32) (interface{}, error)

+ func (c *BooleanColumn) GetObjects() ([]interface{}, error)

+ func (c *BooleanColumn) GetPositionCount() int32

+ func (c *BooleanColumn) IsNull(position int32) bool

+ func (c *BooleanColumn) IsNulls() []bool

+ func (c *BooleanColumn) MayHaveNull() bool

+ type ByteArrayColumnDecoder struct

+ func (decoder *ByteArrayColumnDecoder) ReadColumn(reader *bytes.Reader, dataType TSDataType, positionCount int32) (Column, error)

+ type ClusterConfig struct

+ ConnectRetryMax int

+ Database string

+ FetchSize int32

+ NodeUrls []string

+ Password string

+ TimeZone string

+ UserName string

+ type Column interface

+ GetBinaries func() ([]*Binary, error)

+ GetBinary func(position int32) (*Binary, error)

+ GetBoolean func(position int32) (bool, error)

+ GetBooleans func() ([]bool, error)

+ GetDataType func() TSDataType

+ GetDouble func(position int32) (float64, error)

+ GetDoubles func() ([]float64, error)

+ GetEncoding func() ColumnEncoding

+ GetFloat func(position int32) (float32, error)

+ GetFloats func() ([]float32, error)

+ GetInt func(position int32) (int32, error)

+ GetInts func() ([]int32, error)

+ GetLong func(position int32) (int64, error)

+ GetLongs func() ([]int64, error)

+ GetObject func(position int32) (interface{}, error)

+ GetObjects func() ([]interface{}, error)

+ GetPositionCount func() int32

+ IsNull func(position int32) bool

+ IsNulls func() []bool

+ MayHaveNull func() bool

+ type ColumnCategory int8

+ type ColumnDecoder interface

+ ReadColumn func(reader *bytes.Reader, dataType TSDataType, positionCount int32) (Column, error)

+ type ColumnEncoding uint8

+ type Config struct

+ ConnectRetryMax int

+ Database string

+ FetchSize int32

+ Host string

+ Password string

+ Port string

+ TimeZone string

+ UserName string

+ Version Version

+ type DoubleColumn struct

+ func NewDoubleColumn(arrayOffset int32, positionCount int32, valueIsNull []bool, values []float64) (*DoubleColumn, error)

+ func (c *DoubleColumn) GetBinaries() ([]*Binary, error)

+ func (c *DoubleColumn) GetBinary(_ int32) (*Binary, error)

+ func (c *DoubleColumn) GetBoolean(_ int32) (bool, error)

+ func (c *DoubleColumn) GetBooleans() ([]bool, error)

+ func (c *DoubleColumn) GetDataType() TSDataType

+ func (c *DoubleColumn) GetDouble(position int32) (float64, error)

+ func (c *DoubleColumn) GetDoubles() ([]float64, error)

+ func (c *DoubleColumn) GetEncoding() ColumnEncoding

+ func (c *DoubleColumn) GetFloat(_ int32) (float32, error)

+ func (c *DoubleColumn) GetFloats() ([]float32, error)

+ func (c *DoubleColumn) GetInt(_ int32) (int32, error)

+ func (c *DoubleColumn) GetInts() ([]int32, error)

+ func (c *DoubleColumn) GetLong(_ int32) (int64, error)

+ func (c *DoubleColumn) GetLongs() ([]int64, error)

+ func (c *DoubleColumn) GetObject(position int32) (interface{}, error)

+ func (c *DoubleColumn) GetObjects() ([]interface{}, error)

+ func (c *DoubleColumn) GetPositionCount() int32

+ func (c *DoubleColumn) IsNull(position int32) bool

+ func (c *DoubleColumn) IsNulls() []bool

+ func (c *DoubleColumn) MayHaveNull() bool

+ type ExecutionError struct

+ Code int32

+ Message string

+ func (e *ExecutionError) Error() 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 FloatColumn struct

+ func NewFloatColumn(arrayOffset int32, positionCount int32, valueIsNull []bool, values []float32) (*FloatColumn, error)

+ func (c *FloatColumn) GetBinaries() ([]*Binary, error)

+ func (c *FloatColumn) GetBinary(_ int32) (*Binary, error)

+ func (c *FloatColumn) GetBoolean(_ int32) (bool, error)

+ func (c *FloatColumn) GetBooleans() ([]bool, error)

+ func (c *FloatColumn) GetDataType() TSDataType

+ func (c *FloatColumn) GetDouble(_ int32) (float64, error)

+ func (c *FloatColumn) GetDoubles() ([]float64, error)

+ func (c *FloatColumn) GetEncoding() ColumnEncoding

+ func (c *FloatColumn) GetFloat(position int32) (float32, error)

+ func (c *FloatColumn) GetFloats() ([]float32, error)

+ func (c *FloatColumn) GetInt(_ int32) (int32, error)

+ func (c *FloatColumn) GetInts() ([]int32, error)

+ func (c *FloatColumn) GetLong(_ int32) (int64, error)

+ func (c *FloatColumn) GetLongs() ([]int64, error)

+ func (c *FloatColumn) GetObject(position int32) (interface{}, error)

+ func (c *FloatColumn) GetObjects() ([]interface{}, error)

+ func (c *FloatColumn) GetPositionCount() int32

+ func (c *FloatColumn) IsNull(position int32) bool

+ func (c *FloatColumn) IsNulls() []bool

+ func (c *FloatColumn) MayHaveNull() bool

+ type ITableSession interface

+ Close func() (err error)

+ ExecuteNonQueryStatement func(sql string) error

+ ExecuteQueryStatement func(sql string, timeoutInMs *int64) (*SessionDataSet, error)

+ Insert func(tablet *Tablet) error

+ func NewClusterTableSession(clusterConfig *ClusterConfig, enableRPCCompression bool) (ITableSession, error)

+ func NewTableSession(config *Config, enableRPCCompression bool, connectionTimeoutInMs int) (ITableSession, error)

+ type Int32ArrayColumnDecoder struct

+ func (decoder *Int32ArrayColumnDecoder) ReadColumn(reader *bytes.Reader, dataType TSDataType, positionCount int32) (Column, error)

+ type Int64ArrayColumnDecoder struct

+ func (decoder *Int64ArrayColumnDecoder) ReadColumn(reader *bytes.Reader, dataType TSDataType, positionCount int32) (Column, error)

+ type IntColumn struct

+ func NewIntColumn(arrayOffset int32, positionCount int32, valueIsNull []bool, values []int32) (*IntColumn, error)

+ func (c *IntColumn) GetBinaries() ([]*Binary, error)

+ func (c *IntColumn) GetBinary(_ int32) (*Binary, error)

+ func (c *IntColumn) GetBoolean(_ int32) (bool, error)

+ func (c *IntColumn) GetBooleans() ([]bool, error)

+ func (c *IntColumn) GetDataType() TSDataType

+ func (c *IntColumn) GetDouble(_ int32) (float64, error)

+ func (c *IntColumn) GetDoubles() ([]float64, error)

+ func (c *IntColumn) GetEncoding() ColumnEncoding

+ func (c *IntColumn) GetFloat(_ int32) (float32, error)

+ func (c *IntColumn) GetFloats() ([]float32, error)

+ func (c *IntColumn) GetInt(position int32) (int32, error)

+ func (c *IntColumn) GetInts() ([]int32, error)

+ func (c *IntColumn) GetLong(_ int32) (int64, error)

+ func (c *IntColumn) GetLongs() ([]int64, error)

+ func (c *IntColumn) GetObject(position int32) (interface{}, error)

+ func (c *IntColumn) GetObjects() ([]interface{}, error)

+ func (c *IntColumn) GetPositionCount() int32

+ func (c *IntColumn) IsNull(position int32) bool

+ func (c *IntColumn) IsNulls() []bool

+ func (c *IntColumn) MayHaveNull() bool

+ type IoTDBRpcDataSet struct

+ func NewIoTDBRpcDataSet(sql string, columnNameList []string, columnTypeList []string, ...) (rpcDataSet *IoTDBRpcDataSet, err error)

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

+ func (s *IoTDBRpcDataSet) GetColumnNameTypeList() []string

+ func (s *IoTDBRpcDataSet) GetColumnSize() int32

+ func (s *IoTDBRpcDataSet) GetColumnTypeList() []string

+ func (s *IoTDBRpcDataSet) GetCurrentRowTime() int64

+ func (s *IoTDBRpcDataSet) GetDate(columnName string) (time.Time, error)

+ func (s *IoTDBRpcDataSet) GetDateByIndex(columnIndex int32) (time.Time, error)

+ func (s *IoTDBRpcDataSet) GetDateByTsBlockColumnIndex(tsBlockColumnIndex int32) (time.Time, error)

+ func (s *IoTDBRpcDataSet) GetFetchSize() int32

+ func (s *IoTDBRpcDataSet) GetValueColumnStartIndex() int32

+ func (s *IoTDBRpcDataSet) HasCachedRecord() bool

+ func (s *IoTDBRpcDataSet) IsClosed() bool

+ func (s *IoTDBRpcDataSet) IsIgnoreTimestamp() bool

+ func (s *IoTDBRpcDataSet) IsLastReadWasNull() bool

+ func (s *IoTDBRpcDataSet) Next() (result bool, err error)

+ func (s *IoTDBRpcDataSet) SetFetchSize(fetchSize int32)

+ func (s *IoTDBRpcDataSet) SetHasCachedRecord(hasCachedRecord bool)

+ type LongColumn struct

+ func NewLongColumn(arrayOffset int32, positionCount int32, valueIsNull []bool, values []int64) (*LongColumn, error)

+ func (c *LongColumn) GetBinaries() ([]*Binary, error)

+ func (c *LongColumn) GetBinary(_ int32) (*Binary, error)

+ func (c *LongColumn) GetBoolean(_ int32) (bool, error)

+ func (c *LongColumn) GetBooleans() ([]bool, error)

+ func (c *LongColumn) GetDataType() TSDataType

+ func (c *LongColumn) GetDouble(_ int32) (float64, error)

+ func (c *LongColumn) GetDoubles() ([]float64, error)

+ func (c *LongColumn) GetEncoding() ColumnEncoding

+ func (c *LongColumn) GetFloat(_ int32) (float32, error)

+ func (c *LongColumn) GetFloats() ([]float32, error)

+ func (c *LongColumn) GetInt(_ int32) (int32, error)

+ func (c *LongColumn) GetInts() ([]int32, error)

+ func (c *LongColumn) GetLong(position int32) (int64, error)

+ func (c *LongColumn) GetLongs() ([]int64, error)

+ func (c *LongColumn) GetObject(position int32) (interface{}, error)

+ func (c *LongColumn) GetObjects() ([]interface{}, error)

+ func (c *LongColumn) GetPositionCount() int32

+ func (c *LongColumn) IsNull(position int32) bool

+ func (c *LongColumn) IsNulls() []bool

+ func (c *LongColumn) MayHaveNull() bool

+ type MeasurementSchema struct

+ DataType TSDataType

+ Measurement string

+ type PoolConfig struct

+ ConnectRetryMax int

+ Database string

+ FetchSize int32

+ Host string

+ NodeUrls []string

+ Password string

+ Port string

+ TimeZone string

+ UserName string

+ type PooledTableSession struct

+ func (s *PooledTableSession) Close() error

+ func (s *PooledTableSession) ExecuteNonQueryStatement(sql string) error

+ func (s *PooledTableSession) ExecuteQueryStatement(sql string, timeoutInMs *int64) (*SessionDataSet, error)

+ func (s *PooledTableSession) Insert(tablet *Tablet) error

+ type RowRecord struct

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

+ func (r *RowRecord) GetTimestamp() int64

+ type RunLengthColumnDecoder struct

+ func (decoder *RunLengthColumnDecoder) ReadColumn(reader *bytes.Reader, dataType TSDataType, positionCount int32) (Column, error)

+ type RunLengthEncodedColumn struct

+ func NewRunLengthEncodedColumn(value Column, positionCount int32) (*RunLengthEncodedColumn, error)

+ func (c *RunLengthEncodedColumn) GetBinaries() ([]*Binary, error)

+ func (c *RunLengthEncodedColumn) GetBinary(_ int32) (*Binary, error)

+ func (c *RunLengthEncodedColumn) GetBoolean(_ int32) (bool, error)

+ func (c *RunLengthEncodedColumn) GetBooleans() ([]bool, error)

+ func (c *RunLengthEncodedColumn) GetDataType() TSDataType

+ func (c *RunLengthEncodedColumn) GetDouble(_ int32) (float64, error)

+ func (c *RunLengthEncodedColumn) GetDoubles() ([]float64, error)

+ func (c *RunLengthEncodedColumn) GetEncoding() ColumnEncoding

+ func (c *RunLengthEncodedColumn) GetFloat(_ int32) (float32, error)

+ func (c *RunLengthEncodedColumn) GetFloats() ([]float32, error)

+ func (c *RunLengthEncodedColumn) GetInt(_ int32) (int32, error)

+ func (c *RunLengthEncodedColumn) GetInts() ([]int32, error)

+ func (c *RunLengthEncodedColumn) GetLong(_ int32) (int64, error)

+ func (c *RunLengthEncodedColumn) GetLongs() ([]int64, error)

+ func (c *RunLengthEncodedColumn) GetObject(_ int32) (interface{}, error)

+ func (c *RunLengthEncodedColumn) GetObjects() ([]interface{}, error)

+ func (c *RunLengthEncodedColumn) GetPositionCount() int32

+ func (c *RunLengthEncodedColumn) GetValue() Column

+ func (c *RunLengthEncodedColumn) IsNull(_ int32) bool

+ func (c *RunLengthEncodedColumn) IsNulls() []bool

+ func (c *RunLengthEncodedColumn) MayHaveNull() bool

+ type Session struct

+ func NewClusterSession(clusterConfig *ClusterConfig) (Session, error)

+ func NewSession(config *Config) Session

+ func (s *Session) Close() error

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

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

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

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

+ func (s *Session) DeleteStorageGroup(storageGroupId string) error

+ func (s *Session) DeleteStorageGroups(storageGroupIds ...string) error

+ func (s *Session) DeleteTimeseries(paths []string) error

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

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

+ func (s *Session) ExecuteBatchStatement(inserts []string) error

+ func (s *Session) ExecuteFastLastDataQueryForOnePrefixPath(prefixes []string, timeoutMs *int64) (*SessionDataSet, error)

+ func (s *Session) ExecuteNonQueryStatement(sql string) 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) ExecuteStatementWithContext(ctx context.Context, 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) InsertAlignedRecord(deviceId string, measurements []string, dataTypes []TSDataType, ...) error

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

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

+ func (s *Session) InsertAlignedTablet(tablet *Tablet, sorted bool) error

+ func (s *Session) InsertAlignedTablets(tablets []*Tablet, sorted bool) error

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

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

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

+ func (s *Session) InsertStringRecord(deviceId string, measurements []string, values []string, timestamp int64) error

+ func (s *Session) InsertTablet(tablet *Tablet, sorted bool) error

+ func (s *Session) InsertTablets(tablets []*Tablet, sorted bool) error

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

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

+ func (s *Session) SetFetchSize(fetchSize int32)

+ func (s *Session) SetStorageGroup(storageGroupId string) error

+ func (s *Session) SetTimeZone(timeZone string) error

+ type SessionDataSet struct

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

+ func (s *SessionDataSet) Close() error

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

+ func (s *SessionDataSet) GetBlob(columnName string) (*Binary, error)

+ func (s *SessionDataSet) GetBlobByIndex(columnIndex int32) (*Binary, error)

+ func (s *SessionDataSet) GetBoolean(columnName string) (bool, error)

+ func (s *SessionDataSet) GetBooleanByIndex(columnIndex int32) (bool, error)

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

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

+ func (s *SessionDataSet) GetCurrentRowTime() time.Time

+ func (s *SessionDataSet) GetDate(columnName string) (time.Time, error)

+ func (s *SessionDataSet) GetDateByIndex(columnIndex int32) (time.Time, error)

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

+ func (s *SessionDataSet) GetDoubleByIndex(columnIndex int32) (float64, error)

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

+ func (s *SessionDataSet) GetFloatByIndex(columnIndex int32) (float32, error)

+ func (s *SessionDataSet) GetInt(columnName string) (int32, error)

+ func (s *SessionDataSet) GetIntByIndex(columnIndex int32) (int32, error)

+ func (s *SessionDataSet) GetLong(columnName string) (int64, error)

+ func (s *SessionDataSet) GetLongByIndex(columnIndex int32) (int64, error)

+ func (s *SessionDataSet) GetObject(columnName string) (interface{}, error)

+ func (s *SessionDataSet) GetObjectByIndex(columnIndex int32) (interface{}, error)

+ func (s *SessionDataSet) GetString(columnName string) (string, error)

+ func (s *SessionDataSet) GetStringByIndex(columnIndex int32) (string, error)

+ func (s *SessionDataSet) GetTimestamp(columnName string) (time.Time, error)

+ func (s *SessionDataSet) GetTimestampByIndex(columnIndex int32) (time.Time, error)

+ func (s *SessionDataSet) IsNull(columnName string) (bool, error)

+ func (s *SessionDataSet) IsNullByIndex(columnIndex int32) (bool, error)

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

+ 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 TSCompressionType uint8

+ const GZIP

+ const LZ4

+ const LZMA2

+ const SNAPPY

+ const UNCOMPRESSED

+ const ZSTD

+ type TSDataType int8

+ const BLOB

+ const BOOLEAN

+ const DATE

+ const DOUBLE

+ const FLOAT

+ const INT32

+ const INT64

+ const STRING

+ const TEXT

+ const TIMESTAMP

+ const UNKNOWN

+ func GetDataTypeByStr(name string) (TSDataType, error)

+ type TSEncoding uint8

+ const BITMAP

+ const CHIMP

+ const DICTIONARY

+ const DIFF

+ const FREQ

+ const GORILLA

+ const GORILLA_V1

+ const PLAIN

+ const REGULAR

+ const RLBE

+ const RLE

+ const SPRINTZ

+ const TS_2DIFF

+ const ZIGZAG

+ type TableSession struct

+ func (s *TableSession) Close() error

+ func (s *TableSession) ExecuteNonQueryStatement(sql string) error

+ func (s *TableSession) ExecuteQueryStatement(sql string, timeoutInMs *int64) (*SessionDataSet, error)

+ func (s *TableSession) Insert(tablet *Tablet) error

+ type TableSessionPool struct

+ func NewTableSessionPool(conf *PoolConfig, ...) TableSessionPool

+ func (spool *TableSessionPool) Close()

+ func (spool *TableSessionPool) GetSession() (ITableSession, error)

+ type Tablet struct

+ RowSize int

+ func NewRelationalTablet(tableName string, measurementSchemas []*MeasurementSchema, ...) (*Tablet, error)

+ func NewTablet(insertTargetName string, measurementSchemas []*MeasurementSchema, ...) (*Tablet, error)

+ func (t *Tablet) GetMaxRowNumber() int

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

+ 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) Reset()

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

+ type TimeColumn struct

+ func NewTimeColumn(arrayOffset int32, positionCount int32, values []int64) (*TimeColumn, error)

+ func (c *TimeColumn) GetBinaries() ([]*Binary, error)

+ func (c *TimeColumn) GetBinary(_ int32) (*Binary, error)

+ func (c *TimeColumn) GetBoolean(_ int32) (bool, error)

+ func (c *TimeColumn) GetBooleans() ([]bool, error)

+ func (c *TimeColumn) GetDouble(_ int32) (float64, error)

+ func (c *TimeColumn) GetDoubles() ([]float64, error)

+ func (c *TimeColumn) GetFloat(_ int32) (float32, error)

+ func (c *TimeColumn) GetFloats() ([]float32, error)

+ func (c *TimeColumn) GetInt(_ int32) (int32, error)

+ func (c *TimeColumn) GetInts() ([]int32, error)

+ func (c *TimeColumn) GetObject(_ int32) (interface{}, error)

+ func (c *TimeColumn) GetObjects() ([]interface{}, error)

+ func (tc *TimeColumn) GetDataType() TSDataType

+ func (tc *TimeColumn) GetEncoding() ColumnEncoding

+ func (tc *TimeColumn) GetEndTime() int64

+ func (tc *TimeColumn) GetLong(position int32) (int64, error)

+ func (tc *TimeColumn) GetLongs() ([]int64, error)

+ func (tc *TimeColumn) GetPositionCount() int32

+ func (tc *TimeColumn) GetStartTime() int64

+ func (tc *TimeColumn) GetTimes() []int64

+ func (tc *TimeColumn) IsNull(_ int32) bool

+ func (tc *TimeColumn) IsNulls() []bool

+ func (tc *TimeColumn) MayHaveNull() bool

+ type TsBlock struct

+ func DeserializeTsBlock(data []byte) (*TsBlock, error)

+ func NewTsBlock(positionCount int32, timeColumn Column, valueColumns ...Column) (*TsBlock, error)

+ func (t *TsBlock) GetColumn(columnIndex int32) Column

+ func (t *TsBlock) GetEndTime() (int64, error)

+ func (t *TsBlock) GetPositionCount() int32

+ func (t *TsBlock) GetStartTime() (int64, error)

+ func (t *TsBlock) GetTimeByIndex(index int32) (int64, error)

+ func (t *TsBlock) GetTimeColumn() Column

+ func (t *TsBlock) GetValueColumnCount() int32

+ func (t *TsBlock) GetValueColumns() *[]Column

+ func (t *TsBlock) IsEmpty() bool

+ type Version string

v2.0.3-1

Jun 20, 2025

Other modules containing this package

github.com/apache/iotdb-client-go

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