rest

package

v3.0.0-...-bf98e44 Latest Latest Go to latest Published: Jul 28, 2025 License: MIT Imports: 38 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/taosdata/taosadapter

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func BadRequestResponse(c *gin.Context, logger *logrus.Entry, code int)
func BadRequestResponseWithMsg(c *gin.Context, logger *logrus.Entry, code int, msg string)
func CheckAuth(c *gin.Context)
func CommonErrorResponse(c *gin.Context, logger *logrus.Entry, msg string)
func DecodeDes(auth string) (user, password string, err error)
func DoQuery(c *gin.Context, db string, location *time.Location, reqID int64, ...)
func EncodeDes(user, password string) (string, error)
func ErrorResponse(c *gin.Context, logger *logrus.Entry, httpCode, code int, msg string)
func ForbiddenResponse(c *gin.Context, logger *logrus.Entry, msg string)
func InternalErrorResponse(c *gin.Context, logger *logrus.Entry, code int, msg string)
func ServiceUnavailable(c *gin.Context, logger *logrus.Entry, msg string)
func TaosErrorResponse(c *gin.Context, logger *logrus.Entry, code int, msg string)
func TooManyRequestResponse(c *gin.Context, logger *logrus.Entry, msg string)
func UnAuthResponse(c *gin.Context, logger *logrus.Entry, code int)
type ConfigController
- func (ctl *ConfigController) Init(r gin.IRouter)
type Message
type MessageWithTiming
type ModifyConfig
type Restful
- func (ctl *Restful) Close()
- func (ctl *Restful) Init(r gin.IRouter)
type TDEngineRestfulResp
type TDEngineRestfulRespDoc

Constants ¶

View Source

const (
	UserKey     = "user"
	PasswordKey = "password"
)

View Source

const LoggerKey = "logger"

View Source

const MAXSQLLength = 1024 * 1024 * 1

View Source

const RequireTiming = "require_timing"

View Source

const StartTimeKey = "st"

Variables ¶

View Source

var (
	ExecHeader           = []byte(`{"code":0,"column_meta":[["affected_rows","INT",4]],"data":[[`)
	ExecEnd              = []byte(`]],"rows":1}`)
	ExecEndWithTiming    = []byte(`]],"rows":1,"timing":`)
	ExecObjHeader        = []byte(`{"code":0,"column_meta":[["affected_rows","INT",4]],"data":[{"affected_rows":`)
	ExecObjEnd           = []byte(`}],"rows":1}`)
	ExecObjEndWithTiming = []byte(`}],"rows":1,"timing":`)
	Query2               = []byte(`{"code":0,"column_meta":[`)
	Query3               = []byte(`],"data":[`)
	Query4               = []byte(`],"rows":`)
	Timing               = []byte(`,"timing":`)
)

Functions ¶

func BadRequestResponse ¶

func BadRequestResponse(c *gin.Context, logger *logrus.Entry, code int)

func BadRequestResponseWithMsg ¶

func BadRequestResponseWithMsg(c *gin.Context, logger *logrus.Entry, code int, msg string)

func CheckAuth ¶

func CheckAuth(c *gin.Context)

func CommonErrorResponse ¶

func CommonErrorResponse(c *gin.Context, logger *logrus.Entry, msg string)

func DecodeDes ¶

func DecodeDes(auth string) (user, password string, err error)

func DoQuery ¶

func DoQuery(c *gin.Context, db string, location *time.Location, reqID int64, returnObj bool, logger *logrus.Entry)

func EncodeDes ¶

func EncodeDes(user, password string) (string, error)

func ErrorResponse ¶

func ErrorResponse(c *gin.Context, logger *logrus.Entry, httpCode, code int, msg string)

func ForbiddenResponse ¶

func ForbiddenResponse(c *gin.Context, logger *logrus.Entry, msg string)

func InternalErrorResponse ¶

func InternalErrorResponse(c *gin.Context, logger *logrus.Entry, code int, msg string)

func ServiceUnavailable ¶

func ServiceUnavailable(c *gin.Context, logger *logrus.Entry, msg string)

func TaosErrorResponse ¶

func TaosErrorResponse(c *gin.Context, logger *logrus.Entry, code int, msg string)

func TooManyRequestResponse ¶

func TooManyRequestResponse(c *gin.Context, logger *logrus.Entry, msg string)

func UnAuthResponse ¶

func UnAuthResponse(c *gin.Context, logger *logrus.Entry, code int)

Types ¶

type ConfigController ¶

type ConfigController struct {
}

func (*ConfigController) Init ¶

func (ctl *ConfigController) Init(r gin.IRouter)

type Message ¶

type Message struct {
	Code int    `json:"code"`
	Desc string `json:"desc"`
}

type MessageWithTiming ¶

type MessageWithTiming struct {
	Code   int    `json:"code"`
	Desc   string `json:"desc"`
	Timing int64  `json:"timing"`
}

type ModifyConfig ¶

type ModifyConfig struct {
	LogLevel *string `json:"log.level"`
}

type Restful ¶

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

func (*Restful) Close ¶

func (ctl *Restful) Close()

func (*Restful) Init ¶

func (ctl *Restful) Init(r gin.IRouter)

type TDEngineRestfulResp ¶

type TDEngineRestfulResp struct {
	Code       int              `json:"code,omitempty"`
	Desc       string           `json:"desc,omitempty"`
	ColumnMeta [][]interface{}  `json:"column_meta,omitempty"`
	Data       [][]driver.Value `json:"data,omitempty"`
	Rows       int              `json:"rows,omitempty"`
}

type TDEngineRestfulRespDoc ¶

type TDEngineRestfulRespDoc struct {
	Code       int             `json:"code,omitempty"`
	Desc       string          `json:"desc,omitempty"`
	ColumnMeta [][]interface{} `json:"column_meta,omitempty"`
	Data       [][]interface{} `json:"data,omitempty"`
	Rows       int             `json:"rows,omitempty"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL