mysql

Documentation

Index

• type Client
  • func NewClient(options ...Option) *Client
  • func (c *Client) Close()
  • func (c *Client) GetCtxDb(ctx context.Context, dbName string) *gorm.DB
  • func (c *Client) GetDb(dbName string) *gorm.DB
  • func (c *Client) Ping() []error
  • func (c *Client) Stats()
• type ClientOptions
  • func (ClientOptions) WithConf(conf config.Config) Option
  • func (ClientOptions) WithDbConfig(dbConfigs []DbConfig) Option
  • func (ClientOptions) WithGormConfig(gormConfig *gorm.Config) Option
  • func (ClientOptions) WithLogger(logger log.Logger) Option
  • func (ClientOptions) WithProxy(proxys ...func() interface{}) Option
  • func (ClientOptions) WithStateTicker(stateTicker time.Duration) Option
• type ConnPool
• type DbConfig
• type MonitorProxy
  • func NewMonitorProxy(options ...MonitorProxyOption) *MonitorProxy
  • func (mp *MonitorProxy) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
  • func (mp *MonitorProxy) Close() error
  • func (mp *MonitorProxy) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
  • func (mp *MonitorProxy) NextProxy(db interface{})
  • func (mp *MonitorProxy) PrepareContext(ctx context.Context, query string) (*sql.Stmt, error)
  • func (mp *MonitorProxy) ProxyName() string
  • func (mp *MonitorProxy) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
  • func (mp *MonitorProxy) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row
• type MonitorProxyOption
• type MonitorProxyOptions
  • func (MonitorProxyOptions) WithConf(conf config.Config) MonitorProxyOption
  • func (MonitorProxyOptions) WithLogger(logger log.Logger) MonitorProxyOption
  • func (MonitorProxyOptions) WithTracer(tracer opentracing2.Tracer) MonitorProxyOption
• type Option
• type SQLClose

Types

type Client

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

func NewClient

func NewClient(options ...Option) *Client

func (*Client) Close

func (c *Client) Close()

func (*Client) GetCtxDb

func (c *Client) GetCtxDb(ctx context.Context, dbName string) *gorm.DB

func (*Client) GetDb

func (c *Client) GetDb(dbName string) *gorm.DB

func (*Client) Ping

func (c *Client) Ping() []error

func (*Client) Stats

func (c *Client) Stats()

type ClientOptions

type ClientOptions struct{}

func (ClientOptions) WithConf

func (ClientOptions) WithConf(conf config.Config) Option

func (ClientOptions) WithDbConfig

func (ClientOptions) WithDbConfig(dbConfigs []DbConfig) Option

func (ClientOptions) WithGormConfig

func (ClientOptions) WithGormConfig(gormConfig *gorm.Config) Option

func (ClientOptions) WithLogger

func (ClientOptions) WithLogger(logger log.Logger) Option

func (ClientOptions) WithProxy

func (ClientOptions) WithProxy(proxys ...func() interface{}) Option

func (ClientOptions) WithStateTicker

func (ClientOptions) WithStateTicker(stateTicker time.Duration) Option

type ConnPool

type ConnPool interface {
	gorm.ConnPool

	SQLClose

	BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)
}

type DbConfig

type DbConfig struct {
	Db          string `json:"db" yaml:"db"`
	Dsn         string `json:"dns" yaml:"dsn"`
	MaxIdle     int    `json:"max_idle" yaml:"maxidle"`
	MaxOpen     int    `json:"max_open" yaml:"maxopen"`
	MaxLifetime int    `json:"max_lifetime" yaml:"maxlifetime"`
}

type MonitorProxy

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

func NewMonitorProxy

func NewMonitorProxy(options ...MonitorProxyOption) *MonitorProxy

func (*MonitorProxy) BeginTx

func (mp *MonitorProxy) BeginTx(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

func (*MonitorProxy) Close

func (mp *MonitorProxy) Close() error

func (*MonitorProxy) ExecContext

func (mp *MonitorProxy) ExecContext(ctx context.Context, query string,
	args ...interface{}) (sql.Result, error)

func (*MonitorProxy) NextProxy

func (mp *MonitorProxy) NextProxy(db interface{})

Implement Proxy interface.

func (*MonitorProxy) PrepareContext

func (mp *MonitorProxy) PrepareContext(ctx context.Context,
	query string) (*sql.Stmt, error)

func (*MonitorProxy) ProxyName

func (mp *MonitorProxy) ProxyName() string

Implement Proxy interface.

func (*MonitorProxy) QueryContext

func (mp *MonitorProxy) QueryContext(ctx context.Context, query string,
	args ...interface{}) (*sql.Rows, error)

func (*MonitorProxy) QueryRowContext

func (mp *MonitorProxy) QueryRowContext(ctx context.Context, query string,
	args ...interface{}) *sql.Row

type MonitorProxyOption

type MonitorProxyOption func(c *MonitorProxy)

type MonitorProxyOptions

type MonitorProxyOptions struct{}

func (MonitorProxyOptions) WithConf

func (MonitorProxyOptions) WithConf(conf config.Config) MonitorProxyOption

func (MonitorProxyOptions) WithLogger

func (MonitorProxyOptions) WithLogger(logger log.Logger) MonitorProxyOption

func (MonitorProxyOptions) WithTracer

func (MonitorProxyOptions) WithTracer(tracer opentracing2.Tracer) MonitorProxyOption

type Option

type Option func(c *Client)

type SQLClose

type SQLClose interface {
	Close() error
}