async

package

v0.0.0-...-8ca9097 Latest Latest Go to latest Published: Jan 4, 2026 License: MIT Imports: 10 Imported by: 0

Details

This section is empty.

View Source

var FetchRowError = errors.New("fetch row error")

func Init()

type Async struct {
	HandlerPool *HandlerPool
}

var GlobalAsync *Async

func NewAsync(handlerPool *HandlerPool) *Async

func (a *Async) TaosExec(taosConnect unsafe.Pointer, sql string, timeFormat parser.FormatTimeFunc) (*ExecResult, error)

func (a *Async) TaosExecWithoutResult(taosConnect unsafe.Pointer, sql string) error

func (a *Async) TaosFetchRawBlockA(res unsafe.Pointer, handler *Handler) (*Result, error)

func (a *Async) TaosQuery(taosConnect unsafe.Pointer, sql string, handler *Handler) (*Result, error)

type Caller struct {
	QueryResult chan *Result
	FetchResult chan *Result
	ExecResult  chan *Stmt2ExecResult
}

func NewCaller() *Caller

func (c *Caller) ExecCall(res unsafe.Pointer, affected int, code int)

func (c *Caller) FetchCall(res unsafe.Pointer, numOfRows int)

func (c *Caller) QueryCall(res unsafe.Pointer, code int)

type ExecResult struct {
	AffectedRows int
	FieldCount   int
	Header       *wrapper.RowsHeader
	Data         [][]driver.Value
}

type Handler struct {
	Handler cgo.Handle
	Caller  *Caller
}

type HandlerPool struct {
	// contains filtered or unexported fields
}

func NewHandlerPool(count int) *HandlerPool

func (c *HandlerPool) Get() *Handler

func (c *HandlerPool) Put(handler *Handler)

type Result struct {
	Res unsafe.Pointer
	N   int
}

type Stmt2ExecResult struct {
	Res      unsafe.Pointer
	Affected int
	Code     int
}