confpostgres

Documentation

Index

• func FromContext(ctx context.Context) sqlx.DBExecutor
• func SlaveFromContext(ctx context.Context) sqlx.DBExecutor
• func SwitchSlave(executor sqlx.DBExecutor) sqlx.DBExecutor
• func WithDB(db sqlx.DBExecutor) func(ctx context.Context) context.Context
• type CanSlave
• type Postgres
  • func (m *Postgres) Commands() []*cobra.Command
  • func (m *Postgres) Get() *sqlx.DB
  • 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()
  • func (m *PostgresEndpoint) UseSlave() sqlx.DBExecutor
• type Retry
  • func (r Retry) Do(exec func() error) (err error)
  • func (r *Retry) SetDefaults()

Functions

func FromContext

func FromContext(ctx context.Context) sqlx.DBExecutor

func SlaveFromContext

func SlaveFromContext(ctx context.Context) sqlx.DBExecutor

func SwitchSlave

func SwitchSlave(executor sqlx.DBExecutor) sqlx.DBExecutor

func WithDB

func WithDB(db sqlx.DBExecutor) func(ctx context.Context) context.Context

Types

type CanSlave

type CanSlave interface {
	UseSlave() sqlx.DBExecutor
}

type Postgres

type Postgres struct {
	Ctx             context.Context
	DBName          string           `env:""`
	Host            string           `env:",upstream"`
	SlaveHost       string           `env:",upstream"`
	Port            int              `env:""`
	User            string           `env:""`
	Password        envconf.Password `env:""`
	Extra           string
	Extensions      []string
	PoolSize        int
	ConnMaxLifetime envconf.Duration
	Database        *sqlx.Database `env:"-"`
	*sqlx.DB        `env:"-"`
	// contains filtered or unexported fields
}

func (*Postgres) Commands

func (m *Postgres) Commands() []*cobra.Command

func (*Postgres) Get

func (m *Postgres) Get() *sqlx.DB

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      envconf.Endpoint `env:""`
	SlaveEndpoint envconf.Endpoint `env:""`
	DBName        string           `env:",opt"`
	Database      *sqlx.Database   `env:"-"`

	Extensions      []string
	PoolSize        int
	ConnMaxLifetime envconf.Duration

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

func (*PostgresEndpoint) Init

func (m *PostgresEndpoint) Init()

func (*PostgresEndpoint) LivenessCheck

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

func (*PostgresEndpoint) SetDefaults

func (m *PostgresEndpoint) SetDefaults()

func (*PostgresEndpoint) UseSlave

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

type Retry

type Retry struct {
	Repeats  int
	Interval envconf.Duration
}

func (Retry) Do

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

func (*Retry) SetDefaults

func (r *Retry) SetDefaults()