client

package

Go to main page

Versions in this module

v1

v1.3.5

Aug 22, 2025

Changes in this version

+ const BINARY_ARRAY_COLUMN_ENCODING

+ const BYTE_ARRAY_COLUMN_ENCODING

+ const INT32_ARRAY_COLUMN_ENCODING

+ const INT64_ARRAY_COLUMN_ENCODING

+ const RLE_COLUMN_ENCODING

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

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

+ type Binary struct

+ func NewBinary(v []byte) *Binary

+ func (b *Binary) GetStringValue() string

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

+ type BinaryArrayColumnDecoder struct

+ func (_ *BinaryArrayColumnDecoder) ReadTimeColumn(_ *bytes.Reader, _ int32) (*TimeColumn, error)

+ 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 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 (_ *ByteArrayColumnDecoder) ReadTimeColumn(_ *bytes.Reader, _ int32) (*TimeColumn, error)

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

+ 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 ColumnDecoder interface

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

+ ReadTimeColumn func(reader *bytes.Reader, positionCount int32) (*TimeColumn, error)

+ type ColumnEncoding uint8

+ 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 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 Int32ArrayColumnDecoder struct

+ func (_ *Int32ArrayColumnDecoder) ReadTimeColumn(_ *bytes.Reader, _ int32) (*TimeColumn, error)

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

+ func (decoder *Int64ArrayColumnDecoder) ReadTimeColumn(reader *bytes.Reader, positionCount int32) (*TimeColumn, 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

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

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

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

+ 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 RunLengthColumnDecoder struct

+ func (_ *RunLengthColumnDecoder) ReadTimeColumn(_ *bytes.Reader, _ int32) (*TimeColumn, error)

+ 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

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

type SessionDataSet

+ 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) GetColumnTypes() []string

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

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

+ func (s *SessionDataSet) GetDoubleByIndex(columnIndex int32) (float64, 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) GetTimestampByIndex(columnIndex int32) (time.Time, error)

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

type TSDataType

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

+ 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 *TimeColumn, valueColumns ...Column) (*TsBlock, error)

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

+ func (t *TsBlock) GetEndTime() int64

+ func (t *TsBlock) GetPositionCount() int32

+ func (t *TsBlock) GetStartTime() int64

+ 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

v1.3.4

Apr 14, 2025

Changes in this version

type Session

+ func (s *Session) ExecuteGroupByQueryIntervalQuery(database *string, device, measurement string, ...) (*SessionDataSet, error)

+ func (s *Session) ExecuteStatementWithContext(ctx context.Context, sql string) (*SessionDataSet, error)

type SessionDataSet

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

v1.3.3

Nov 4, 2024

Changes in this version

type Session

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

type TSDataType

+ const BLOB

+ const DATE

+ const STRING

+ const TIMESTAMP

type TSEncoding

+ const DICTIONARY

v1.3.2

May 22, 2024

Changes in this version

+ var BitUtil = []byte

+ var UnmarkBitUtil = []byte

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

v1.3.2-fix

May 22, 2024

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)

Other modules containing this package

github.com/apache/iotdb-client-go/v2

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