postgresqldb

Documentation

Index

• func StartMonitoring(cluster *DBCluster, interval time.Duration)
• type DBCluster
  • func InitDBCluster(ctx context.Context, cfg *config.DatabaseConfig) (*DBCluster, error)
  • func NewDBCluster(masterDB *sql.DB, replicaDBs []*sql.DB) *DBCluster
  • func (c *DBCluster) Close() error
  • func (cluster *DBCluster) GetDB(opType OperationType) (*sql.DB, error)
• type OperationType

Functions

func StartMonitoring

func StartMonitoring(cluster *DBCluster, interval time.Duration)

StartMonitoring начинает мониторинг для master и реплик в DBCluster с заданным интервалом

Types

type DBCluster

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

func InitDBCluster

func InitDBCluster(ctx context.Context, cfg *config.DatabaseConfig) (*DBCluster, error)

func NewDBCluster

func NewDBCluster(masterDB *sql.DB, replicaDBs []*sql.DB) *DBCluster

NewDBCluster создает новый кластер базы данных

func (*DBCluster) Close

func (c *DBCluster) Close() error

func (*DBCluster) GetDB

func (cluster *DBCluster) GetDB(opType OperationType) (*sql.DB, error)

GetDB возвращает подходящий экземпляр базы данных в зависимости от типа операции

type OperationType

type OperationType int

const (
	Read OperationType = iota
	ReadWrite
)