tidb

Documentation

Index

• Variables
• type Forwarder
  • func NewForwarder(config *ForwarderConfig, etcdProvider pd.EtcdProvider) *Forwarder
  • func (f *Forwarder) Close() error
  • func (f *Forwarder) GetDBConnProps() (host string, port int, err error)
  • func (f *Forwarder) Open() error
  • func (f *Forwarder) OpenTiDB(user string, pass string) (*gorm.DB, error)
• type ForwarderConfig
  • func NewForwarderConfig(tlsConfig *tls.Config) *ForwarderConfig

Variables

var (
	ErrorNS           = errorx.NewNamespace("error.tidb")
	ErrPDAccessFailed = ErrorNS.NewType("pd_access_failed")
	ErrNoAliveTiDB    = ErrorNS.NewType("no_alive_tidb")
	ErrTiDBConnFailed = ErrorNS.NewType("tidb_conn_failed")
	ErrTiDBAuthFailed = ErrorNS.NewType("tidb_auth_failed")
)

Types

type Forwarder

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

func NewForwarder

func NewForwarder(config *ForwarderConfig, etcdProvider pd.EtcdProvider) *Forwarder

func (*Forwarder) Close

func (f *Forwarder) Close() error

func (*Forwarder) GetDBConnProps

func (f *Forwarder) GetDBConnProps() (host string, port int, err error)

func (*Forwarder) Open

func (f *Forwarder) Open() error

TODO: Requires load balancing and health checks.

func (*Forwarder) OpenTiDB

func (f *Forwarder) OpenTiDB(user string, pass string) (*gorm.DB, error)

type ForwarderConfig

type ForwarderConfig struct {
	TiDBRetrieveTimeout time.Duration
	TLSConfig           *tls.Config
}

func NewForwarderConfig

func NewForwarderConfig(tlsConfig *tls.Config) *ForwarderConfig