client

Documentation

Index

• func SeriesEq(i *Series, j *Series, fieldIndex int, valueType string) bool
• func TransType(value interface{}) interface{}
• type Client
  • func (c *Client) Close() error
  • func (c *Client) DoQuery(params *QueryParams) (result *common.Result, err error)
• type Debug
  • func NewDebug(sql string) *Debug
  • func (s *Debug) String() string
• type DebugInfo
  • func (s *DebugInfo) Get() map[string]interface{}
• type QueryParams
• type Series
• type SeriesArray
• type SeriesGroup
  • func Group(seriesArray SeriesArray, groupIndex []int, schema common.ColumnSchemas) (groups []*SeriesGroup)
• type SeriesSort

Functions

func SeriesEq

func SeriesEq(i *Series, j *Series, fieldIndex int, valueType string) bool

func TransType

func TransType(value interface{}) interface{}

Types

type Client

type Client struct {
	Host     string
	Port     int
	UserName string
	Password string

	DB      string
	Context context.Context
	Debug   *Debug
	// contains filtered or unexported fields
}

func (*Client) Close

func (c *Client) Close() error

func (*Client) DoQuery

func (c *Client) DoQuery(params *QueryParams) (result *common.Result, err error)

type Debug

type Debug struct {
	IP        string
	Sql       string
	QueryTime string
	QueryUUID string
	Error     string
}

func NewDebug

func NewDebug(sql string) *Debug

func (*Debug) String

func (s *Debug) String() string

type DebugInfo

type DebugInfo struct {
	Debug []Debug
}

func (*DebugInfo) Get

func (s *DebugInfo) Get() map[string]interface{}

type QueryParams

type QueryParams struct {
	Sql             string
	UseQueryCache   bool
	QueryCacheTTL   string
	Callbacks       map[string]func(result *common.Result) error
	QueryUUID       string
	ColumnSchemaMap map[string]*common.ColumnSchema
	ORGID           string
	SimpleSql       bool
}

type Series

type Series struct {
	Values []interface{}
}

type SeriesArray

type SeriesArray []*Series

type SeriesGroup

type SeriesGroup struct {
	Series      SeriesArray
	GroupIndex  []int
	GroupValues []interface{}
	Schemas     common.ColumnSchemas
}

func Group

func Group(seriesArray SeriesArray, groupIndex []int, schema common.ColumnSchemas) (groups []*SeriesGroup)

type SeriesSort

type SeriesSort struct {
	Series    SeriesArray
	SortIndex []int
	Reverse   []bool
	Schemas   common.ColumnSchemas
}