af

Documentation

Index

• type Connector
  • func NewConnector(taos unsafe.Pointer) (*Connector, error)
  • func Open(host, user, pass, db string, port int) (*Connector, error)
  • func (conn *Connector) Close() error
  • func (conn *Connector) Exec(query string, args ...driver.Value) (driver.Result, error)
  • func (conn *Connector) InfluxDBInsertLines(lines []string, precision string) error
  • func (conn *Connector) InsertStmt() *insertstmt.InsertStmt
  • func (conn *Connector) LoadTableInfo(tableNameList []string) error
  • func (conn *Connector) OpenTSDBInsertJsonPayload(payload string) error
  • func (conn *Connector) OpenTSDBInsertTelnetLines(lines []string) error
  • func (conn *Connector) Query(query string, args ...driver.Value) (driver.Rows, error)
  • func (conn *Connector) SelectDB(db string) error
  • func (conn *Connector) StmtExecute(sql string, params *param.Param) (res driver.Result, err error)
  • func (conn *Connector) StmtQuery(sql string, params *param.Param) (rows driver.Rows, err error)
  • func (conn *Connector) Subscribe(restart bool, topic string, sql string, interval time.Duration) (Subscriber, error)
• type Stmt
  • func NewStmt(taosConn unsafe.Pointer) *Stmt
  • func (s *Stmt) AddBatch() error
  • func (s *Stmt) BindRow(row *param.Param) error
  • func (s *Stmt) Close() error
  • func (s *Stmt) Execute() error
  • func (s *Stmt) GetAffectedRows() int
  • func (s *Stmt) GetResultRows() (driver.Rows, error)
  • func (s *Stmt) Prepare(sql string) error
  • func (s *Stmt) SetTableName(tableName string) error
  • func (s *Stmt) SetTableNameWithTags(tableName string, tags *param.Param) error
• type Subscriber

Types

type Connector

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

func NewConnector

func NewConnector(taos unsafe.Pointer) (*Connector, error)

func Open

func Open(host, user, pass, db string, port int) (*Connector, error)

func (*Connector) Close

func (conn *Connector) Close() error

func (*Connector) Exec

func (conn *Connector) Exec(query string, args ...driver.Value) (driver.Result, error)

func (*Connector) InfluxDBInsertLines

func (conn *Connector) InfluxDBInsertLines(lines []string, precision string) error

func (*Connector) InsertStmt

func (conn *Connector) InsertStmt() *insertstmt.InsertStmt

func (*Connector) LoadTableInfo

func (conn *Connector) LoadTableInfo(tableNameList []string) error

func (*Connector) OpenTSDBInsertJsonPayload

func (conn *Connector) OpenTSDBInsertJsonPayload(payload string) error

func (*Connector) OpenTSDBInsertTelnetLines

func (conn *Connector) OpenTSDBInsertTelnetLines(lines []string) error

func (*Connector) Query

func (conn *Connector) Query(query string, args ...driver.Value) (driver.Rows, error)

func (*Connector) SelectDB

func (conn *Connector) SelectDB(db string) error

func (*Connector) StmtExecute

func (conn *Connector) StmtExecute(sql string, params *param.Param) (res driver.Result, err error)

func (*Connector) StmtQuery

func (conn *Connector) StmtQuery(sql string, params *param.Param) (rows driver.Rows, err error)

func (*Connector) Subscribe

func (conn *Connector) Subscribe(restart bool, topic string, sql string, interval time.Duration) (Subscriber, error)

type Stmt

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

func NewStmt

func NewStmt(taosConn unsafe.Pointer) *Stmt

func (*Stmt) AddBatch

func (s *Stmt) AddBatch() error

func (*Stmt) BindRow

func (s *Stmt) BindRow(row *param.Param) error

func (*Stmt) Close

func (s *Stmt) Close() error

func (*Stmt) Execute

func (s *Stmt) Execute() error

func (*Stmt) GetAffectedRows

func (s *Stmt) GetAffectedRows() int

func (*Stmt) GetResultRows

func (s *Stmt) GetResultRows() (driver.Rows, error)

func (*Stmt) Prepare

func (s *Stmt) Prepare(sql string) error

func (*Stmt) SetTableName

func (s *Stmt) SetTableName(tableName string) error

func (*Stmt) SetTableNameWithTags

func (s *Stmt) SetTableNameWithTags(tableName string, tags *param.Param) error

type Subscriber

type Subscriber interface {
	Consume() (driver.Rows, error)
	Unsubscribe(keepProgress bool)
}