db

Documentation

Index

• func Establish(module container.Module) (*gorm.DB, error)
• func NewBigQueryModule(projectId, dataset string) (container.Module, error)
• func NewMysqlModule(host string, port int, username, password, database string) (container.Module, error)
• func NewPgModule(host string, port int, username, password, database string) (container.Module, error)
• func NewPgModuleWithSsl(host string, port int, username, password, database string) (container.Module, error)
• func NewPgPoolModule(host string, port int, username, password, database string) (container.Module, error)
• func NewPgPoolModuleWithSsl(host string, port int, username, password, database string) (container.Module, error)
• type Db
  • func NewBigQuery(projectId, dataset string, timeout time.Duration) (Db, error)
  • func NewMysql(host string, port int, username, password, database string, ...) (Db, error)
  • func NewPg(host string, port int, username, password, database string, ...) (Db, error)

Functions

func Establish

func Establish(module container.Module) (*gorm.DB, error)

func NewBigQueryModule

func NewBigQueryModule(
	projectId, dataset string,
) (container.Module, error)

func NewMysqlModule

func NewMysqlModule(
	host string,
	port int,
	username, password, database string,
) (container.Module, error)

func NewPgModule

func NewPgModule(
	host string,
	port int,
	username, password, database string,
) (container.Module, error)

func NewPgModuleWithSsl

func NewPgModuleWithSsl(
	host string,
	port int,
	username, password, database string,
) (container.Module, error)

func NewPgPoolModule

func NewPgPoolModule(
	host string,
	port int,
	username, password, database string,
) (container.Module, error)

func NewPgPoolModuleWithSsl

func NewPgPoolModuleWithSsl(
	host string,
	port int,
	username, password, database string,
) (container.Module, error)

Types

type Db

type Db interface {
	Establish() *gorm.DB
	Disconnect() error
}

func NewBigQuery

func NewBigQuery(
	projectId, dataset string,
	timeout time.Duration,
) (Db, error)

func NewMysql

func NewMysql(
	host string,
	port int,
	username, password, database string,
	timeout time.Duration,
	usePreparedStatement bool,
) (Db, error)

func NewPg

func NewPg(
	host string,
	port int,
	username, password, database string,
	timeout time.Duration,
	sslMode string,
	usePreparedStatement bool,
) (Db, error)