postgres

Documentation

Index

• type PGStorage
  • func NewPGStorage(logger *zap.Logger, cfg StorageConfig) (*PGStorage, error)
  • func (s *PGStorage) Close() error
  • func (s *PGStorage) Master() *sqlx.DB
  • func (s *PGStorage) Slave() *sqlx.DB
• type StorageConfig
  • func (c *StorageConfig) Validate() error

Types

type PGStorage

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

func NewPGStorage

func NewPGStorage(logger *zap.Logger, cfg StorageConfig) (*PGStorage, error)

NewPGStorage TODO: write mock

func (*PGStorage) Close

func (s *PGStorage) Close() error

func (*PGStorage) Master

func (s *PGStorage) Master() *sqlx.DB

func (*PGStorage) Slave

func (s *PGStorage) Slave() *sqlx.DB

type StorageConfig

type StorageConfig struct {
	EnableMock            bool          `yaml:"enable_mock"`
	Hosts                 []string      `yaml:"hosts"`
	Port                  int           `yaml:"port"`
	Database              string        `yaml:"database"`
	Username              string        `yaml:"username"`
	Password              string        `yaml:"password" env:"DB_PASSWORD"`
	SSLMode               string        `yaml:"ssl_mode"`
	ConnectionAttempts    int           `yaml:"connection_attempts"`
	InitializationTimeout time.Duration `yaml:"initialization_timeout"`
}

func (*StorageConfig) Validate

func (c *StorageConfig) Validate() error