Versions in this module Expand all Collapse all v3 v3.30.1 Oct 10, 2024 Changes in this version + const InfluxDBLineProtocol + const OpenTSDBJsonFormatProtocol + const OpenTSDBTelnetLineProtocol + const PointerSize + 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 + func BuildRawMeta(length uint32, metaType uint16, data unsafe.Pointer) unsafe.Pointer + 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 NotifyCallback(p unsafe.Pointer, ext unsafe.Pointer, notifyType C.int) + 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 StmtParseFields(num int, fields unsafe.Pointer) []*stmt.StmtField + func TMQAutoCommitCB(consumer unsafe.Pointer, resp C.int32_t, param unsafe.Pointer) + func TMQCommitAsync(consumer unsafe.Pointer, message unsafe.Pointer, h cgo.Handle) + func TMQCommitCB(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 TMQCommitSync(consumer unsafe.Pointer, message unsafe.Pointer) int32 + func TMQCommitted(consumer unsafe.Pointer, topic string, vGroupID int32) int64 + 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 TMQFreeAssignment(assignment unsafe.Pointer) + func TMQFreeJsonMeta(jsonMeta unsafe.Pointer) + func TMQFreeRaw(raw unsafe.Pointer) + func TMQGetConnect(consumer unsafe.Pointer) 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 TMQGetTopicAssignment(consumer unsafe.Pointer, topic string) (int32, []*tmq.Assignment) + func TMQGetTopicName(message unsafe.Pointer) string + func TMQGetVgroupID(message unsafe.Pointer) int32 + func TMQGetVgroupOffset(message unsafe.Pointer) int64 + 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 TMQOffsetSeek(consumer unsafe.Pointer, topic string, vGroupID int32, offset int64) int32 + func TMQPosition(consumer unsafe.Pointer, topic string, vGroupID int32) int64 + 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 TaosFetchWhitelistA(taosConnect unsafe.Pointer, caller cgo.Handle) + func TaosFieldCount(result unsafe.Pointer) int + func TaosFreeResult(res unsafe.Pointer) + func TaosGetClientInfo() string + func TaosGetCurrentDB(conn unsafe.Pointer) (db string, err error) + func TaosGetRawBlock(result unsafe.Pointer) unsafe.Pointer + func TaosGetServerInfo(conn unsafe.Pointer) string + func TaosGetTableVgID(conn unsafe.Pointer, db, table string) (vgID int, code int) + func TaosGetTablesVgID(conn unsafe.Pointer, db string, tables []string) (vgIDs []int, code int) + 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 TaosQueryAWithReqID(taosConn unsafe.Pointer, sql string, caller cgo.Handle, reqID int64) + func TaosQueryWithReqID(taosConn unsafe.Pointer, sql string, reqID int64) unsafe.Pointer + 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 TaosSchemalessInsertRaw(taosConnect unsafe.Pointer, lines string, protocol int, precision string) (int32, unsafe.Pointer) + 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 TaosSelectDB(taosConnect unsafe.Pointer, db string) int + func TaosSetConfig(params map[string]string) error + func TaosSetConnMode(conn unsafe.Pointer, mode int, value int) int + func TaosSetNotifyCB(taosConnect unsafe.Pointer, caller cgo.Handle, notifyType int) int32 + 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 TaosStmtGetParam(stmt unsafe.Pointer, idx int) (dataType int, dataLength int, err error) + func TaosStmtGetTagFields(stmt unsafe.Pointer) (code, num int, fields unsafe.Pointer) + func TaosStmtInit(taosConnect unsafe.Pointer) unsafe.Pointer + func TaosStmtInitWithReqID(taosConn unsafe.Pointer, reqID int64) 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 TaosStmtReclaimFields(stmt unsafe.Pointer, fields unsafe.Pointer) + 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 + func TaosWriteRawBlockWithFields(conn unsafe.Pointer, numOfRows int, pData unsafe.Pointer, tableName string, ...) int + 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 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 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 TMQCommitCallbackResult struct + Consumer unsafe.Pointer + ErrCode int32 + func GetTMQCommitCallbackResult(errCode int32, consumer unsafe.Pointer) *TMQCommitCallbackResult + func (t *TMQCommitCallbackResult) GetError() error + type WhitelistResult struct + ErrCode int32 + IPNets []*net.IPNet
Go to main page