tidb

Documentation

Index

• Variables
• type Client
  • func NewTiDBClient(lc fx.Lifecycle, config *config.Config, etcdClient *clientv3.Client, ...) *Client
  • func (c *Client) OpenSQLConn(user string, pass string) (*gorm.DB, error)
  • func (c *Client) SendGetRequest(path string) ([]byte, error)
  • func (c *Client) WithSQLAPIAddress(host string, sqlPort int) *Client
  • func (c *Client) WithStatusAPIAddress(host string, statusPort int) *Client
• type Forwarder
  • func (f *Forwarder) Start(ctx context.Context) error

Variables

var (
	ErrTiDBConnFailed          = ErrNS.NewType("tidb_conn_failed")
	ErrTiDBAuthFailed          = ErrNS.NewType("tidb_auth_failed")
	ErrTiDBClientRequestFailed = ErrNS.NewType("client_request_failed")
)

var (
	ErrNS = errorx.NewNamespace("error.tidb")
)

var (
	ErrNoAliveTiDB = ErrNS.NewType("no_alive_tidb")
)

Types

type Client

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

func NewTiDBClient

func NewTiDBClient(lc fx.Lifecycle, config *config.Config, etcdClient *clientv3.Client, httpClient *httpc.Client) *Client

func (*Client) OpenSQLConn

func (c *Client) OpenSQLConn(user string, pass string) (*gorm.DB, error)

func (*Client) SendGetRequest

func (c *Client) SendGetRequest(path string) ([]byte, error)

func (*Client) WithSQLAPIAddress

func (c *Client) WithSQLAPIAddress(host string, sqlPort int) *Client

func (*Client) WithStatusAPIAddress

func (c *Client) WithStatusAPIAddress(host string, statusPort int) *Client

type Forwarder

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

func (*Forwarder) Start

func (f *Forwarder) Start(ctx context.Context) error