db

Documentation

Index

• Constants
• func ErrIsDuplicateEntryError(err error) bool
• func SanitizedDSN(cfg *cfg.DB) (string, string, error)
• type Conn
  • func New(stream *health.Stream, conf cfg.DB, ro bool) (*Conn, error)
  • func (c *Conn) Close(context.Context) error
  • func (c *Conn) NewSession(name string, timeout time.Duration) (*dbr.Session, error)
  • func (c *Conn) NewSessionForEventReceiver(er health.EventReceiver) *dbr.Session

Constants

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

const (
	RemovedPassword = "[removed]"
)

Functions

func ErrIsDuplicateEntryError

func ErrIsDuplicateEntryError(err error) bool

func SanitizedDSN

func SanitizedDSN(cfg *cfg.DB) (string, string, error)

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