confpostgres

Documentation

Index

• func SwitchSlave(executor sqlx.DBExecutor) sqlx.DBExecutor
• type CanSlave
• type Postgres
  • func (m *Postgres) Init()
  • func (m *Postgres) LivenessCheck() map[string]string
  • func (m *Postgres) SetDefaults()
  • func (m *Postgres) UseSlave() sqlx.DBExecutor
• type PostgresEndpoint
  • func (m *PostgresEndpoint) Init()
  • func (m *PostgresEndpoint) LivenessCheck() map[string]string
  • func (m *PostgresEndpoint) SetDefaults()
• type Retry
  • func (r Retry) Do(exec func() error) (err error)
  • func (r *Retry) SetDefaults()

Functions

func SwitchSlave

func SwitchSlave(executor sqlx.DBExecutor) sqlx.DBExecutor

Types

type CanSlave

type CanSlave interface {
	UseSlave() sqlx.DBExecutor
}

type Postgres

type Postgres struct {
	Host            string
	SlaveHost       string
	Port            int
	User            string
	Password        envconfig.Password
	Extra           string
	Extensions      []string
	PoolSize        int
	ConnMaxLifetime envconfig.Duration
	Database        *sqlx.Database `ignored:"true"`

	*sqlx.DB `ignored:"true"`
	// contains filtered or unexported fields
}

func (*Postgres) Init

func (m *Postgres) Init()

func (*Postgres) LivenessCheck

func (m *Postgres) LivenessCheck() map[string]string

func (*Postgres) SetDefaults

func (m *Postgres) SetDefaults()

func (*Postgres) UseSlave

func (m *Postgres) UseSlave() sqlx.DBExecutor

type PostgresEndpoint

type PostgresEndpoint struct {
	Endpoint envconfig.Endpoint `env:""`
	Database *sqlx.Database     `env:"-"`

	Extensions      []string
	PoolSize        int
	ConnMaxLifetime envconfig.Duration

	*sqlx.DB `env:"-"`
}

func (*PostgresEndpoint) Init

func (m *PostgresEndpoint) Init()

func (*PostgresEndpoint) LivenessCheck

func (m *PostgresEndpoint) LivenessCheck() map[string]string

func (*PostgresEndpoint) SetDefaults

func (m *PostgresEndpoint) SetDefaults()

type Retry

type Retry struct {
	Repeats  int
	Interval envconfig.Duration
}

func (Retry) Do

func (r Retry) Do(exec func() error) (err error)

func (*Retry) SetDefaults

func (r *Retry) SetDefaults()