adapter

Documentation

Index

• Constants
• type Adapter
  • func DefaultAdapter() *Adapter
  • func NewAdapter(c *Config, l *log.Logger) *Adapter
  • func (a *Adapter) Connect() error
  • func (a *Adapter) GetDb() *gorm.DB
  • func (a *Adapter) IsDbConnectionAvailable() (*gorm.DB, error)
• type Config
  • func DefaultConfig() *Config
  • func NewConfig(dsn *Dsn, maxAttempts int, interval time.Duration) *Config
  • func (c *Config) GetDsn() *Dsn
  • func (c *Config) GetInterval() time.Duration
  • func (c *Config) GetMaxAttempts() int
  • func (c *Config) SetInterval(interval time.Duration) *Config
  • func (c *Config) SetLogger(logger *log.Logger) *Config
  • func (c *Config) SetMaxAttempts(maxAttempts int) *Config
• type Dsn
  • func NewDsn(user string, password string, database string) *Dsn
  • func (d *Dsn) Dsn() string
  • func (d *Dsn) SetDatabase(database string) *Dsn
  • func (d *Dsn) SetHost(host string) *Dsn
  • func (d *Dsn) SetPassword(password string) *Dsn
  • func (d *Dsn) SetPort(port string) *Dsn
  • func (d *Dsn) SetUser(user string) *Dsn

Constants

const (
	DEFAULT_MYSQL_MAX_ATTEMPTS     = 5               // Default number of attempts to connect to mysql
	DEFAULT_MYSQL_ATTEMPT_INTERVAL = 5 * time.Second // Time between attempts
)

const (
	DefaultPort = "3306"
	DefaultHost = "localhost"
)

Types

type Adapter

type Adapter struct {
	IsConnected bool
	Logger      *log.Logger
	Config      *Config
	// contains filtered or unexported fields
}

func DefaultAdapter

func DefaultAdapter() *Adapter

func NewAdapter

func NewAdapter(c *Config, l *log.Logger) *Adapter

func (*Adapter) Connect

func (a *Adapter) Connect() error

func (*Adapter) GetDb

func (a *Adapter) GetDb() *gorm.DB

func (*Adapter) IsDbConnectionAvailable

func (a *Adapter) IsDbConnectionAvailable() (*gorm.DB, error)

type Config

type Config struct {
	Dsn *Dsn

	Logger *log.Logger
	// contains filtered or unexported fields
}

func DefaultConfig

func DefaultConfig() *Config

func NewConfig

func NewConfig(dsn *Dsn, maxAttempts int, interval time.Duration) *Config

func (*Config) GetDsn

func (c *Config) GetDsn() *Dsn

func (*Config) GetInterval

func (c *Config) GetInterval() time.Duration

func (*Config) GetMaxAttempts

func (c *Config) GetMaxAttempts() int

func (*Config) SetInterval

func (c *Config) SetInterval(interval time.Duration) *Config

func (*Config) SetLogger

func (c *Config) SetLogger(logger *log.Logger) *Config

func (*Config) SetMaxAttempts

func (c *Config) SetMaxAttempts(maxAttempts int) *Config

type Dsn

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

func NewDsn

func NewDsn(user string, password string, database string) *Dsn

func (*Dsn) Dsn

func (d *Dsn) Dsn() string

func (*Dsn) SetDatabase

func (d *Dsn) SetDatabase(database string) *Dsn

func (*Dsn) SetHost

func (d *Dsn) SetHost(host string) *Dsn

func (*Dsn) SetPassword

func (d *Dsn) SetPassword(password string) *Dsn

func (*Dsn) SetPort

func (d *Dsn) SetPort(port string) *Dsn

func (*Dsn) SetUser

func (d *Dsn) SetUser(user string) *Dsn