taosWS

Documentation

Index

• Constants
• Variables
• type BadConnError
  • func NewBadConnError(err error) *BadConnError
  • func NewBadConnErrorWithCtx(err error, ctx string) *BadConnError
  • func (e *BadConnError) Error() string
  • func (*BadConnError) Unwrap() error
• type TDengineDriver
  • func (d TDengineDriver) Open(dsn string) (driver.Conn, error)
• type WSAction
• type WSConnectReq
• type WSConnectResp
• type WSFetchBlockReq
• type WSFetchReq
• type WSFetchResp
• type WSFreeResultReq
• type WSQueryReq
• type WSQueryResp

Constants

const (
	WSConnect    = "conn"
	WSQuery      = "query"
	WSFetch      = "fetch"
	WSFetchBlock = "fetch_block"
	WSFreeResult = "free_result"
)

Variables

var (
	NotQueryError    = errors.New("sql is an update statement not a query statement")
	ReadTimeoutError = errors.New("read timeout")
)

Types

type BadConnError

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

func NewBadConnError

func NewBadConnError(err error) *BadConnError

func NewBadConnErrorWithCtx

func NewBadConnErrorWithCtx(err error, ctx string) *BadConnError

func (*BadConnError) Error

func (e *BadConnError) Error() string

func (*BadConnError) Unwrap

func (*BadConnError) Unwrap() error

type TDengineDriver

type TDengineDriver struct{}

TDengineDriver is exported to make the driver directly accessible. In general the driver is used via the database/sql package.

func (TDengineDriver) Open

func (d TDengineDriver) Open(dsn string) (driver.Conn, error)

Open new Connection. the DSN string is formatted

type WSAction

type WSAction struct {
	Action string          `json:"action"`
	Args   json.RawMessage `json:"args"`
}

type WSConnectReq

type WSConnectReq struct {
	ReqID    uint64 `json:"req_id"`
	User     string `json:"user"`
	Password string `json:"password"`
	DB       string `json:"db"`
}

type WSConnectResp

type WSConnectResp struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Action  string `json:"action"`
	ReqID   uint64 `json:"req_id"`
	Timing  int64  `json:"timing"`
}

type WSFetchBlockReq

type WSFetchBlockReq struct {
	ReqID uint64 `json:"req_id"`
	ID    uint64 `json:"id"`
}

type WSFetchReq

type WSFetchReq struct {
	ReqID uint64 `json:"req_id"`
	ID    uint64 `json:"id"`
}

type WSFetchResp

type WSFetchResp struct {
	Code      int    `json:"code"`
	Message   string `json:"message"`
	Action    string `json:"action"`
	ReqID     uint64 `json:"req_id"`
	Timing    int64  `json:"timing"`
	ID        uint64 `json:"id"`
	Completed bool   `json:"completed"`
	Lengths   []int  `json:"lengths"`
	Rows      int    `json:"rows"`
}

type WSFreeResultReq

type WSFreeResultReq struct {
	ReqID uint64 `json:"req_id"`
	ID    uint64 `json:"id"`
}

type WSQueryReq

type WSQueryReq struct {
	ReqID uint64 `json:"req_id"`
	SQL   string `json:"sql"`
}

type WSQueryResp

type WSQueryResp struct {
	Code          int      `json:"code"`
	Message       string   `json:"message"`
	Action        string   `json:"action"`
	ReqID         uint64   `json:"req_id"`
	Timing        int64    `json:"timing"`
	ID            uint64   `json:"id"`
	IsUpdate      bool     `json:"is_update"`
	AffectedRows  int      `json:"affected_rows"`
	FieldsCount   int      `json:"fields_count"`
	FieldsNames   []string `json:"fields_names"`
	FieldsTypes   []uint8  `json:"fields_types"`
	FieldsLengths []int64  `json:"fields_lengths"`
	Precision     int      `json:"precision"`
}