database

Documentation

Index

• Constants
• func GetMongoClient(url string) *mongo.Client
• type Client
  • func (c *Client) MongoConnect() (mc *mongo.Client, err error)
• type DB
  • func (d *DB) Connect(driver string) error
  • func (d *DB) ConnectAndMonitor(driver string) error
• type DBConfig
• type DSNConfig
• type Database
  • func MongoConnectClient(c *Client) *Database
• type Options
• type Store
  • func New(cfg DBConfig, dbDriver string) *Store
  • func (s *Store) GetMaster() *sqlx.DB
  • func (s *Store) GetSlave() *sqlx.DB

Constants

const (
	DriverMySQL    = "mysql"
	DriverPostgres = "postgres"
)

Driver list

Functions

func GetMongoClient

func GetMongoClient(url string) *mongo.Client

Types

type Client

type Client struct {
	URI     string `json:"uri" mapstructure:"uri"`
	DB      string `json:"database" mapstructure:"database"`
	AppName string `json:"name" mapstructure:"name"`
	// on second
	ConnectTimeout time.Duration
	// on second
	PingTimeout time.Duration
}

func (*Client) MongoConnect

func (c *Client) MongoConnect() (mc *mongo.Client, err error)

type DB

type DB struct {
	DBConnection    *sqlx.DB
	DBString        string
	RetryInterval   int
	MaxIdleConn     int
	MaxConn         int
	ConnMaxLifetime time.Duration
	// contains filtered or unexported fields
}

DB configuration

var (
	Master *DB
	Slave  *DB
)

Db object

func (*DB) Connect

func (d *DB) Connect(driver string) error

Connect to database

func (*DB) ConnectAndMonitor

func (d *DB) ConnectAndMonitor(driver string) error

ConnectAndMonitor to database

type DBConfig

type DBConfig struct {
	SlaveDSN        string `json:"slave_dsn" mapstructure:"slave_dsn"`
	MasterDSN       string `json:"master_dsn" mapstructure:"master_dsn"`
	RetryInterval   int    `json:"retry_interval" mapstructure:"retry_interval"`
	MaxIdleConn     int    `json:"max_idle" mapstructure:"max_idle"`
	MaxConn         int    `json:"max_con" mapstructure:"max_con"`
	ConnMaxLifetime string `json:"conn_max_lifetime" mapstructure:"conn_max_lifetime"`
}

DBConfig for databases configuration

type DSNConfig

type DSNConfig struct {
	DSN string
}

DSNConfig for database source name

type Database

type Database struct {
	Database *mongo.Database
}

func MongoConnectClient

func MongoConnectClient(c *Client) *Database

type Options

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

type Store

type Store struct {
	Master *sqlx.DB
	Slave  *sqlx.DB
}

func New

func New(cfg DBConfig, dbDriver string) *Store

func (*Store) GetMaster

func (s *Store) GetMaster() *sqlx.DB

func (*Store) GetSlave

func (s *Store) GetSlave() *sqlx.DB