wrapper

package

Go to main page

Versions in this module

v3

v3.7.8

Jan 9, 2026

v3.7.7

Dec 22, 2025

v3.7.6

Sep 25, 2025

v3.7.5

Sep 15, 2025

v3.7.4

Aug 18, 2025

Changes in this version

+ func TaosOptionsConnection(conn unsafe.Pointer, option int, value *string) int

v3.7.3

Jul 25, 2025

v3.7.2

Jul 23, 2025

v3.7.1

Jun 19, 2025

v3.7.0

Mar 25, 2025

Changes in this version

+ func TaosFetchFieldsE(result unsafe.Pointer) unsafe.Pointer

type RowsHeader

+ Precisions []int64

+ Scales []int64

v3.6.0

Dec 30, 2024

Changes in this version

+ func Stmt2ExecCallback(p unsafe.Pointer, res *C.TAOS_RES, code C.int)

+ func Stmt2ParseAllFields(num int, fields unsafe.Pointer) []*stmt.Stmt2AllField

+ func TMQGetConnect(consumer unsafe.Pointer) unsafe.Pointer

+ func TaosFetchWhitelistA(taosConnect unsafe.Pointer, caller cgo.Handle)

+ func TaosSchemalessInsertRawTTLWithReqIDTBNameKey(taosConnect unsafe.Pointer, lines string, protocol int, precision string, ...) (int32, unsafe.Pointer)

+ func TaosSetConnMode(conn unsafe.Pointer, mode int, value int) int

+ func TaosStmt2BindBinary(stmt2 unsafe.Pointer, data []byte, colIdx int32) error

+ func TaosStmt2BindParam(stmt2 unsafe.Pointer, isInsert bool, params []*stmt.TaosStmt2BindData, ...) error

+ func TaosStmt2Close(stmt2 unsafe.Pointer) int

+ func TaosStmt2Error(stmt2 unsafe.Pointer) string

+ func TaosStmt2Exec(stmt2 unsafe.Pointer) int

+ func TaosStmt2FreeFields(stmt2 unsafe.Pointer, fields unsafe.Pointer)

+ func TaosStmt2GetFields(stmt2 unsafe.Pointer) (code, count int, fields unsafe.Pointer)

+ func TaosStmt2Init(taosConnect unsafe.Pointer, reqID int64, singleStbInsert bool, ...) unsafe.Pointer

+ func TaosStmt2IsInsert(stmt2 unsafe.Pointer) (is bool, errorCode int)

+ func TaosStmt2Prepare(stmt2 unsafe.Pointer, sql string) int

+ func ToUnsafeBytes(s string) (b []byte)

+ type TaosStmt2CallbackCaller interface

+ ExecCall func(res unsafe.Pointer, affected int, code int)

v3.5.8

Sep 26, 2024

v3.5.7

Sep 6, 2024

Changes in this version

+ func TaosQueryWithReqID(taosConn unsafe.Pointer, sql string, reqID int64) unsafe.Pointer

v3.5.6

Jul 1, 2024

v3.5.5

May 22, 2024

v3.5.4

Apr 24, 2024

v3.5.3

Mar 19, 2024

v3.5.2

Feb 1, 2024

v3.5.1

Nov 20, 2023

Changes in this version

+ func TMQAutoCommitCB(consumer unsafe.Pointer, resp C.int32_t, param unsafe.Pointer)

+ func TMQCommitOffsetAsync(consumer unsafe.Pointer, topic string, vGroupID int32, offset int64, ...)

+ func TMQCommitOffsetCB(consumer unsafe.Pointer, resp C.int32_t, param unsafe.Pointer)

+ func TMQCommitOffsetSync(consumer unsafe.Pointer, topic string, vGroupID int32, offset int64) int32

+ func TMQCommitted(consumer unsafe.Pointer, topic string, vGroupID int32) int64

+ func TMQPosition(consumer unsafe.Pointer, topic string, vGroupID int32) int64

+ func TaosGetCurrentDB(conn unsafe.Pointer) (db string, err error)

+ func TaosGetServerInfo(conn unsafe.Pointer) string

+ func TaosStmtGetParam(stmt unsafe.Pointer, idx int) (dataType int, dataLength int, err error)

+ func TaosWriteRawBlockWithFieldsWithReqID(conn unsafe.Pointer, numOfRows int, pData unsafe.Pointer, tableName string, ...) int

+ func TaosWriteRawBlockWithReqID(conn unsafe.Pointer, numOfRows int, pData unsafe.Pointer, tableName string, ...) int

+ func WhitelistCallback(param unsafe.Pointer, code int, taosConnect unsafe.Pointer, ...)

+ type WhitelistResult struct

+ ErrCode int32

+ IPNets []*net.IPNet

v3.5.0

Jun 5, 2023

Changes in this version

+ func NotifyCallback(p unsafe.Pointer, ext unsafe.Pointer, notifyType C.int)

+ func TMQFreeAssignment(assignment unsafe.Pointer)

+ func TMQGetTopicAssignment(consumer unsafe.Pointer, topic string) (int32, []*tmq.Assignment)

+ func TMQGetVgroupOffset(message unsafe.Pointer) int64

+ func TMQOffsetSeek(consumer unsafe.Pointer, topic string, vGroupID int32, offset int64) int32

+ func TaosSetNotifyCB(taosConnect unsafe.Pointer, caller cgo.Handle, notifyType int) int32

v3.3.1

May 6, 2023

Changes in this version

+ func TaosStmtReclaimFields(stmt unsafe.Pointer, fields unsafe.Pointer)

v3.1.0

Jan 13, 2023

Changes in this version

+ func TaosGetTablesVgID(conn unsafe.Pointer, db string, tables []string) (vgIDs []int, code int)

v3.0.4

Dec 26, 2022

Changes in this version

+ func TaosGetTableVgID(conn unsafe.Pointer, db, table string) (vgID int, code int)

+ func TaosQueryAWithReqID(taosConn unsafe.Pointer, sql string, caller cgo.Handle, reqID int64)

+ func TaosSchemalessInsertRawTTL(taosConnect unsafe.Pointer, lines string, protocol int, precision string, ...) (int32, unsafe.Pointer)

+ func TaosSchemalessInsertRawTTLWithReqID(taosConnect unsafe.Pointer, lines string, protocol int, precision string, ...) (int32, unsafe.Pointer)

+ func TaosSchemalessInsertRawWithReqID(taosConnect unsafe.Pointer, lines string, protocol int, precision string, ...) (int32, unsafe.Pointer)

+ func TaosSchemalessInsertTTL(taosConnect unsafe.Pointer, lines []string, protocol int, precision string, ...) unsafe.Pointer

+ func TaosSchemalessInsertTTLWithReqID(taosConnect unsafe.Pointer, lines []string, protocol int, precision string, ...) unsafe.Pointer

+ func TaosSchemalessInsertWithReqID(taosConnect unsafe.Pointer, lines []string, protocol int, precision string, ...) unsafe.Pointer

+ func TaosStmtInitWithReqID(taosConn unsafe.Pointer, reqID int64) unsafe.Pointer

+ func TaosWriteRawBlockWithFields(conn unsafe.Pointer, numOfRows int, pData unsafe.Pointer, tableName string, ...) int

+ func TasoQueryWithReqID(taosConn unsafe.Pointer, sql string, reqID int64) unsafe.Pointer

v3.0.3

Oct 28, 2022

Changes in this version

+ func TaosSchemalessInsertRaw(taosConnect unsafe.Pointer, lines string, protocol int, precision string) (int32, unsafe.Pointer)

v3.0.2

Oct 17, 2022

v3.0.1

Sep 21, 2022

v3.0.0

Aug 10, 2022

Changes in this version

+ const ColInfoOffset

+ const ColInfoSize

+ const Float32Size

+ const Float64Size

+ const GroupIDOffset

+ const HasColumnSegmentOffset

+ const InfluxDBLineProtocol

+ const Int16Size

+ const Int32Size

+ const Int64Size

+ const Int8Size

+ const NumOfColsOffset

+ const NumOfRowsOffset

+ const OpenTSDBJsonFormatProtocol

+ const OpenTSDBTelnetLineProtocol

+ const PointerSize

+ const RawBlockLengthOffset

+ const RawBlockVersionOffset

+ const TSDB_SML_TIMESTAMP_HOURS

+ const TSDB_SML_TIMESTAMP_MICRO_SECONDS

+ const TSDB_SML_TIMESTAMP_MILLI_SECONDS

+ const TSDB_SML_TIMESTAMP_MINUTES

+ const TSDB_SML_TIMESTAMP_NANO_SECONDS

+ const TSDB_SML_TIMESTAMP_NOT_CONFIGURED

+ const TSDB_SML_TIMESTAMP_SECONDS

+ const UInt16Size

+ const UInt32Size

+ const UInt64Size

+ const UInt8Size

+ func BMIsNull(c byte, n int) bool

+ func BitPos(n int) int

+ func BitmapLen(n int) int

+ func BuildRawMeta(length uint32, metaType uint16, data unsafe.Pointer) unsafe.Pointer

+ func CharOffset(n int) int

+ func FetchLengths(res unsafe.Pointer, count int) []int

+ func FetchRawBlockCallback(p unsafe.Pointer, res *C.TAOS_RES, numOfRows C.int)

+ func FetchRow(row unsafe.Pointer, offset int, colType uint8, length int, arg ...interface{}) driver.Value

+ func FetchRowsCallback(p unsafe.Pointer, res *C.TAOS_RES, numOfRows C.int)

+ func IsVarDataType(colType uint8) bool

+ func ItemIsNull(pHeader uintptr, row int) bool

+ func ItemRawBlock(colType uint8, pHeader, pStart uintptr, row int, precision int, ...) driver.Value

+ func ParseJsonMeta(jsonMeta unsafe.Pointer) []byte

+ func ParseRawMeta(rawMeta unsafe.Pointer) (length uint32, metaType uint16, data unsafe.Pointer)

+ func PutTMQCommitCallbackResult(result *TMQCommitCallbackResult)

+ func QueryCallback(p unsafe.Pointer, res *C.TAOS_RES, code C.int)

+ func RawBlockGetColDataOffset(colCount int) uintptr

+ func RawBlockGetColInfo(rawBlock unsafe.Pointer, infos []RawBlockColInfo)

+ func RawBlockGetColumnLengthOffset(colCount int) uintptr

+ func RawBlockGetGroupID(rawBlock unsafe.Pointer) uint64

+ func RawBlockGetHasColumnSegment(rawBlock unsafe.Pointer) int32

+ func RawBlockGetLength(rawBlock unsafe.Pointer) int32

+ func RawBlockGetNumOfCols(rawBlock unsafe.Pointer) int32

+ func RawBlockGetNumOfRows(rawBlock unsafe.Pointer) int32

+ func RawBlockGetVersion(rawBlock unsafe.Pointer) int32

+ func ReadBlock(block unsafe.Pointer, blockSize int, colTypes []uint8, precision int) [][]driver.Value

+ func ReadBlockWithTimeFormat(block unsafe.Pointer, blockSize int, colTypes []uint8, precision int, ...) [][]driver.Value

+ func ReadRow(dest []driver.Value, block unsafe.Pointer, blockSize int, row int, ...)

+ func TMQCommitAsync(consumer unsafe.Pointer, message unsafe.Pointer, h cgo.Handle)

+ func TMQCommitCB(consumer unsafe.Pointer, resp C.int32_t, param unsafe.Pointer)

+ func TMQCommitSync(consumer unsafe.Pointer, message unsafe.Pointer) int32

+ func TMQConfDestroy(conf unsafe.Pointer)

+ func TMQConfNew() unsafe.Pointer

+ func TMQConfSet(conf unsafe.Pointer, key string, value string) int32

+ func TMQConfSetAutoCommitCB(conf unsafe.Pointer, h cgo.Handle)

+ func TMQConsumerClose(consumer unsafe.Pointer) int32

+ func TMQConsumerNew(conf unsafe.Pointer) (unsafe.Pointer, error)

+ func TMQConsumerPoll(consumer unsafe.Pointer, blockingTime int64) unsafe.Pointer

+ func TMQErr2Str(code int32) string

+ func TMQFreeJsonMeta(jsonMeta unsafe.Pointer)

+ func TMQFreeRaw(raw unsafe.Pointer)

+ func TMQGetDBName(message unsafe.Pointer) string

+ func TMQGetJsonMeta(message unsafe.Pointer) unsafe.Pointer

+ func TMQGetRaw(message unsafe.Pointer) (int32, unsafe.Pointer)

+ func TMQGetResType(message unsafe.Pointer) int32

+ func TMQGetTableName(message unsafe.Pointer) string

+ func TMQGetTopicName(message unsafe.Pointer) string

+ func TMQGetVgroupID(message unsafe.Pointer) int32

+ func TMQListAppend(list unsafe.Pointer, str string) int32

+ func TMQListDestroy(list unsafe.Pointer)

+ func TMQListGetSize(list unsafe.Pointer) int32

+ func TMQListNew() unsafe.Pointer

+ func TMQListToCArray(list unsafe.Pointer, size int) []string

+ func TMQSubscribe(consumer unsafe.Pointer, topicList unsafe.Pointer) int32

+ func TMQSubscription(consumer unsafe.Pointer) (int32, unsafe.Pointer)

+ func TMQUnsubscribe(consumer unsafe.Pointer) int32

+ func TMQWriteRaw(conn unsafe.Pointer, raw unsafe.Pointer) int32

+ func TaosAffectedRows(result unsafe.Pointer) int

+ func TaosClose(taosConnect unsafe.Pointer)

+ func TaosConnect(host, user, pass, db string, port int) (taos unsafe.Pointer, err error)

+ func TaosError(result unsafe.Pointer) int

+ func TaosErrorStr(result unsafe.Pointer) string

+ func TaosFetchBlock(result unsafe.Pointer) (int, unsafe.Pointer)

+ func TaosFetchFields(result unsafe.Pointer) unsafe.Pointer

+ func TaosFetchLengths(res unsafe.Pointer) unsafe.Pointer

+ func TaosFetchRawBlock(result unsafe.Pointer) (int, int, unsafe.Pointer)

+ func TaosFetchRawBlockA(res unsafe.Pointer, caller cgo.Handle)

+ func TaosFetchRow(result unsafe.Pointer) unsafe.Pointer

+ func TaosFetchRowsA(res unsafe.Pointer, caller cgo.Handle)

+ func TaosFieldCount(result unsafe.Pointer) int

+ func TaosFreeResult(res unsafe.Pointer)

+ func TaosGetClientInfo() string

+ func TaosGetRawBlock(result unsafe.Pointer) unsafe.Pointer

+ func TaosIsUpdateQuery(res unsafe.Pointer) bool

+ func TaosLoadTableInfo(taosConnect unsafe.Pointer, tableNameList []string) int

+ func TaosNumFields(result unsafe.Pointer) int

+ func TaosOptions(option int, value string) int

+ func TaosQuery(taosConnect unsafe.Pointer, sql string) unsafe.Pointer

+ func TaosQueryA(taosConnect unsafe.Pointer, sql string, caller cgo.Handle)

+ func TaosResetCurrentDB(taosConnect unsafe.Pointer)

+ func TaosResultPrecision(result unsafe.Pointer) int

+ func TaosSchemalessInsert(taosConnect unsafe.Pointer, lines []string, protocol int, precision string) unsafe.Pointer

+ func TaosSelectDB(taosConnect unsafe.Pointer, db string) int

+ func TaosSetConfig(params map[string]string) error

+ func TaosStmtAddBatch(stmt unsafe.Pointer) int

+ func TaosStmtAffectedRows(stmt unsafe.Pointer) int

+ func TaosStmtAffectedRowsOnce(stmt unsafe.Pointer) int

+ func TaosStmtBindParam(stmt unsafe.Pointer, params []driver.Value) int

+ func TaosStmtBindParamBatch(stmt unsafe.Pointer, multiBind [][]driver.Value, ...) int

+ func TaosStmtClose(stmt unsafe.Pointer) int

+ func TaosStmtErrStr(stmt unsafe.Pointer) string

+ func TaosStmtExecute(stmt unsafe.Pointer) int

+ func TaosStmtGetColFields(stmt unsafe.Pointer) (code, num int, fields unsafe.Pointer)

+ func TaosStmtGetTagFields(stmt unsafe.Pointer) (code, num int, fields unsafe.Pointer)

+ func TaosStmtInit(taosConnect unsafe.Pointer) unsafe.Pointer

+ func TaosStmtIsInsert(stmt unsafe.Pointer) (is bool, errorCode int)

+ func TaosStmtNumParams(stmt unsafe.Pointer) (count int, errorCode int)

+ func TaosStmtPrepare(stmt unsafe.Pointer, sql string) int

+ func TaosStmtSetSubTBName(stmt unsafe.Pointer, name string) int

+ func TaosStmtSetTBName(stmt unsafe.Pointer, name string) int

+ func TaosStmtSetTBNameTags(stmt unsafe.Pointer, name string, tags []driver.Value) int

+ func TaosStmtSetTags(stmt unsafe.Pointer, tags []driver.Value) int

+ func TaosStmtUseResult(stmt unsafe.Pointer) unsafe.Pointer

+ func TaosValidateSql(taosConnect unsafe.Pointer, sql string) int

+ func TaosWriteRawBlock(conn unsafe.Pointer, numOfRows int, pData unsafe.Pointer, tableName string) int

+ type Caller interface

+ FetchCall func(res unsafe.Pointer, numOfRows int)

+ QueryCall func(res unsafe.Pointer, code int)

+ type FormatTimeFunc func(ts int64, precision int) driver.Value

+ type RawBlockColInfo struct

+ Bytes int32

+ ColType int8

+ type RowsHeader struct

+ ColLength []int64

+ ColNames []string

+ ColTypes []uint8

+ func ReadColumn(result unsafe.Pointer, count int) (*RowsHeader, error)

+ func (rh *RowsHeader) ScanType(i int) reflect.Type

+ func (rh *RowsHeader) TypeDatabaseName(i int) string

+ type StmtField struct

+ Bytes int32

+ FieldType int8

+ Name string

+ Precision uint8

+ Scale uint8

+ func StmtParseFields(num int, fields unsafe.Pointer) []*StmtField

+ func (s *StmtField) GetType() (*taosTypes.ColumnType, error)

+ type TMQCommitCallbackResult struct

+ Consumer unsafe.Pointer

+ ErrCode int32

+ func GetTMQCommitCallbackResult(errCode int32, consumer unsafe.Pointer) *TMQCommitCallbackResult

+ func (t *TMQCommitCallbackResult) GetError() error

Other modules containing this package

github.com/taosdata/driver-go/v2

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