query

Documentation

Index

• Constants
• type QueryController
  • func NewQueryController() *QueryController
  • func (s *QueryController) Init(ctl gin.IRouter)
• type Result
  • func (r *Result) FreeResult(logger *logrus.Entry)
• type Taos
  • func NewTaos(session *melody.Session, logger *logrus.Entry) *Taos
  • func (t *Taos) Close()
  • func (t *Taos) FreeResult(element *list.Element, logger *logrus.Entry)
• type WSAction
• type WSConnectReq
• type WSConnectResp
• type WSErrorResp
• type WSFetchBlockReq
• type WSFetchReq
• type WSFetchResp
• type WSFreeResultReq
• type WSQueryReq
• type WSQueryResult
• type WSTMQErrorResp
• type WSVersionResp
• type WSWriteMetaResp
• type WSWriteRawBlockResp
• type WSWriteRawBlockWithFieldsResp

Constants

const (
	WSConnect                 = "conn"
	WSQuery                   = "query"
	WSFetch                   = "fetch"
	WSFetchBlock              = "fetch_block"
	WSFreeResult              = "free_result"
	WSWriteRaw                = "write_raw"
	WSWriteRawBlock           = "write_raw_block"
	WSWriteRawBlockWithFields = "write_raw_block_with_fields"
)

const (
	TMQRawMessage             = 3
	RawBlockMessage           = 4
	RawBlockMessageWithFields = 5
)

const TaosSessionKey = "taos"

Types

type QueryController

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

func NewQueryController

func NewQueryController() *QueryController

func (*QueryController) Init

func (s *QueryController) Init(ctl gin.IRouter)

type Result

type Result struct {
	TaosResult  unsafe.Pointer
	FieldsCount int
	Header      *wrapper.RowsHeader
	Lengths     []int
	Size        int
	Block       unsafe.Pointer

	sync.Mutex
	// contains filtered or unexported fields
}

func (*Result) FreeResult

func (r *Result) FreeResult(logger *logrus.Entry)

type Taos

type Taos struct {
	Results *list.List

	sync.Mutex
	// contains filtered or unexported fields
}

func NewTaos

func NewTaos(session *melody.Session, logger *logrus.Entry) *Taos

func (*Taos) Close

func (t *Taos) Close()

func (*Taos) FreeResult

func (t *Taos) FreeResult(element *list.Element, logger *logrus.Entry)

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 WSErrorResp

type WSErrorResp 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 WSQueryResult

type WSQueryResult 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   jsontype.JsonUint8 `json:"fields_types"`
	FieldsLengths []int64            `json:"fields_lengths"`
	Precision     int                `json:"precision"`
}

type WSTMQErrorResp

type WSTMQErrorResp struct {
	Code      int     `json:"code"`
	Message   string  `json:"message"`
	Action    string  `json:"action"`
	ReqID     uint64  `json:"req_id"`
	Timing    int64   `json:"timing"`
	MessageID *uint64 `json:"message_id,omitempty"`
}

type WSVersionResp

type WSVersionResp struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Action  string `json:"action"`
	Version string `json:"version"`
}

type WSWriteMetaResp

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

type WSWriteRawBlockResp

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

type WSWriteRawBlockWithFieldsResp

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