mysql

Documentation

Index

• Constants
• 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) RegisterMetricsCallbacks(ctx context.Context, db *gorm.DB)
  • func (c *Client) RegisterTraceCallbacks(db *gorm.DB)
  • func (c *Client) Stats()
  • func (c *Client) Trace(ctx context.Context, db *gorm.DB) *TraceClient
  • func (c *Client) TraceWithSpanContext(ctx opentracing.SpanContext, db *gorm.DB) *TraceClient
• type DbConfig
• type Option
  • func WithDB(db *sql.DB) Option
  • func WithDbConfig(dbConfigs []DbConfig) Option
  • func WithStateTicker(stateTicker time.Duration) Option
• type TraceClient
• type TraceContext
  • func (ctx *TraceContext) StartSpan(name string, tags ...opentracing.StartSpanOption) opentracing.Span

Constants

const (
	OpenTracingContextKey     = "gorm:opentracing_context"
	OpenTracingSpanContextKey = "gorm:opentracing_spanner"
)

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) RegisterMetricsCallbacks

func (c *Client) RegisterMetricsCallbacks(ctx context.Context, db *gorm.DB)

func (*Client) RegisterTraceCallbacks

func (c *Client) RegisterTraceCallbacks(db *gorm.DB)

func (*Client) Stats

func (c *Client) Stats()

func (*Client) Trace

func (c *Client) Trace(ctx context.Context, db *gorm.DB) *TraceClient

func (*Client) TraceWithSpanContext

func (c *Client) TraceWithSpanContext(ctx opentracing.SpanContext, db *gorm.DB) *TraceClient

type DbConfig

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

type Option

type Option func(c *Client)

func WithDB

func WithDB(db *sql.DB) Option

func WithDbConfig

func WithDbConfig(dbConfigs []DbConfig) Option

func WithStateTicker

func WithStateTicker(stateTicker time.Duration) Option

type TraceClient

type TraceClient struct {
	*gorm.DB
	// contains filtered or unexported fields
}

type TraceContext

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

func (*TraceContext) StartSpan

func (ctx *TraceContext) StartSpan(name string, tags ...opentracing.StartSpanOption) opentracing.Span