db

Documentation

Index

• Constants
• func ErrIsDuplicateEntryError(err error) bool
• func ErrIsLockError(err error) bool
• type Conn
  • func New(stream *health.Stream, quietStream *health.Stream, conf cfg.DB, ro bool) (*Conn, error)
  • func (c *Conn) Close(context.Context) error
  • func (c *Conn) NewQuietSession(name string, timeout time.Duration) (*dbr.Session, error)
  • func (c *Conn) NewSession(name string, timeout time.Duration) (*dbr.Session, error)
  • func (c *Conn) NewSessionForEventReceiver(er health.EventReceiver) *dbr.Session
  • func (c *Conn) SetConnMaxIdleTime(d time.Duration)
  • func (c *Conn) SetConnMaxLifetime(d time.Duration)
  • func (c *Conn) SetMaxIdleConns(n int)
  • func (c *Conn) SetMaxOpenConns(n int)

Constants

const (
	DriverMysql = "mysql"
	DriverNone  = ""
)

const (
	RemovedPassword = "[removed]"

	DeadlockDBErrorMessage = "Deadlock found when trying to get lock; try restarting transaction"
	TimeoutDBErrorMessage  = "Lock wait timeout exceeded; try restarting transaction"
)

Functions

func ErrIsDuplicateEntryError

func ErrIsDuplicateEntryError(err error) bool

func ErrIsLockError

func ErrIsLockError(err error) bool

Types

type Conn

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

Conn is a wrapper around a dbr connection and a health stream

func New

func New(stream *health.Stream, quietStream *health.Stream, conf cfg.DB, ro bool) (*Conn, error)

New creates a new DB for the given config

func (*Conn) Close

func (c *Conn) Close(context.Context) error

func (*Conn) NewQuietSession

func (c *Conn) NewQuietSession(name string, timeout time.Duration) (*dbr.Session, error)

func (*Conn) NewSession

func (c *Conn) NewSession(name string, timeout time.Duration) (*dbr.Session, error)

func (*Conn) NewSessionForEventReceiver

func (c *Conn) NewSessionForEventReceiver(er health.EventReceiver) *dbr.Session

func (*Conn) SetConnMaxIdleTime

func (c *Conn) SetConnMaxIdleTime(d time.Duration)

func (*Conn) SetConnMaxLifetime

func (c *Conn) SetConnMaxLifetime(d time.Duration)

func (*Conn) SetMaxIdleConns

func (c *Conn) SetMaxIdleConns(n int)

func (*Conn) SetMaxOpenConns

func (c *Conn) SetMaxOpenConns(n int)