psql

Documentation

Index

• type Config
• type Migration
• type Pool
• type Psql
  • func NewPsql(ctx context.Context, cfg *Config, stop <-chan struct{}, log *logrus.Logger) (*Psql, error)
  • func (p *Psql) GetDatabaseName() string
  • func (p *Psql) GetDatabaseURL(options ...string) string
  • func (p *Psql) GetMigrationAttempts() (int, time.Duration)
  • func (p *Psql) GetMigrationSource() string
  • func (p *Psql) GetPool() *pgxpool.Pool
  • func (p *Psql) GetQueryBuilder() *squirrel.StatementBuilderType
  • func (p *Psql) IsMigrationEnabled() bool

Types

type Config

type Config struct {
	URLEnvKey           string    `yaml:"url_env_key" default:"PG_URL"`
	DBNameEnvKey        string    `yaml:"db_name_env_key" default:"PG_DATABASE"`
	URLParametersEnvKey string    `yaml:"url_parameters_env_key" default:"PG_URL_PARAMETERS"`
	Migration           Migration `yaml:"migration"`
	Pool                Pool      `yaml:"pool"`
	Host                string    `yaml:"host"`
	Port                string    `yaml:"port"`
	SSLMode             string    `yaml:"sslmode"`
}

Config - Postgresql config

type Migration

type Migration struct {
	Source          string `yaml:"source"`
	Attempts        int    `yaml:"attempts"`
	AttemptsTimeout int    `yaml:"attempts_timeout"`
	Enable          bool   `yaml:"enable"`
}

type Pool

type Pool struct {
	MaxPoolSize        int `yaml:"max_pool_size"`
	MinPoolSize        int `yaml:"min_pool_size"`
	ConnectionAttempts int `yaml:"connection_attempts"`
	ConnectionTimeout  int `yaml:"connection_timeout"`
}

Pool - Pool config

type Psql

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

func NewPsql

func NewPsql(ctx context.Context, cfg *Config, stop <-chan struct{}, log *logrus.Logger) (*Psql, error)

func (*Psql) GetDatabaseName

func (p *Psql) GetDatabaseName() string

func (*Psql) GetDatabaseURL

func (p *Psql) GetDatabaseURL(options ...string) string

func (*Psql) GetMigrationAttempts

func (p *Psql) GetMigrationAttempts() (int, time.Duration)

func (*Psql) GetMigrationSource

func (p *Psql) GetMigrationSource() string

func (*Psql) GetPool

func (p *Psql) GetPool() *pgxpool.Pool

func (*Psql) GetQueryBuilder

func (p *Psql) GetQueryBuilder() *squirrel.StatementBuilderType

func (*Psql) IsMigrationEnabled

func (p *Psql) IsMigrationEnabled() bool