postgres

README

1. clean workspace

make clean

1. start postgres

make start_postgres

1. init database

make init_db

1. test

make build
make run

Documentation

Index

• func SwitchSlave(db sqlx.DBExecutor) sqlx.DBExecutor
• type CanSlave
• type Endpoint
  • func (e *Endpoint) Init()
  • func (e Endpoint) LivenessCheck() map[string]string
  • func (e Endpoint) Name() string
  • func (e Endpoint) NewConnection() (sqlx.DBExecutor, error)
  • func (e *Endpoint) SetDefault()
  • func (e Endpoint) UseSlave() sqlx.DBExecutor

Functions

func SwitchSlave

func SwitchSlave(db sqlx.DBExecutor) sqlx.DBExecutor

Types

type CanSlave

type CanSlave interface {
	UseSlave() sqlx.DBExecutor
}

type Endpoint

type Endpoint struct {
	Master   types.Endpoint
	Slave    types.Endpoint
	Database *sqlx.Database `env:"-"`
	Retry    *retry.Retry

	Extensions      []string
	PoolSize        int
	ConnMaxLifetime types.Duration

	*sqlx.DB `env:"-"`
	// contains filtered or unexported fields
}

func (*Endpoint) Init

func (e *Endpoint) Init()

func (Endpoint) LivenessCheck

func (e Endpoint) LivenessCheck() map[string]string

func (Endpoint) Name

func (e Endpoint) Name() string

func (Endpoint) NewConnection

func (e Endpoint) NewConnection() (sqlx.DBExecutor, error)

Establish a new connection in master mode with pg

func (*Endpoint) SetDefault

func (e *Endpoint) SetDefault()

func (Endpoint) UseSlave

func (e Endpoint) UseSlave() sqlx.DBExecutor