database

type BalancingMode string

type ClusterConfig struct {
	IsGaleraCluster *bool               `yaml:"is_galera_cluster" json:"is_galera_cluster" mapstructure:"is_galera_cluster" validate:"required"`
	BalancingMode   BalancingMode       `yaml:"balancing_mode" json:"balancing_mode" mapstructure:"balancing_mode" validate:"required,oneof=random ordered"`
	User            string              `yaml:"user" json:"user" mapstructure:"user" validate:"required"`
	Password        string              `yaml:"password" json:"password" mapstructure:"password" validate:"required"`
	Database        string              `yaml:"database" json:"database" mapstructure:"database" validate:"required"`
	Connections     []*ConnectionConfig `yaml:"connections" json:"connections" mapstructure:"connections" validate:"gte=1,dive,required"`
}

type ConnectionConfig struct {
	Host string `yaml:"host" json:"host" mapstructure:"host" validate:"required"`
	Port int    `yaml:"port" json:"port" mapstructure:"port" validate:"required"`
}

type MigrationConfig struct {
	MigrationDir string `yaml:"migration_dir" json:"migration_dir" mapstructure:"migration_dir" validate:"required"` // Directory for SQL migration files
}

type MysqlConnection struct {
	Name   string
	Dsn    string
	Config *MysqlConnectionOptions
	// DB and IsActive are written by the health-check goroutine and read concurrently
	// by request goroutines via GetConnection/getActive, so both are accessed atomically
	// rather than under Mutex to stay race-free without holding a lock across network I/O.
	DB       atomic.Pointer[sql.DB]
	IsActive atomic.Bool
}

type MysqlConnectionOptions struct {
	User     string
	Password string
	Database string
	Host     string
	Port     int
}

type MysqlConnectionPool struct {
	Connections []*MysqlConnection
	Mutex       *sync.Mutex
	PingsTicker *time.Ticker
	PingsDone   chan bool
	Config      *ClusterConfig
}