config

Documentation

Index

• func NewDBConnections(cfg *Config) (*sql.DB, *pgxpool.Pool, error)
• type Config
  • func LoadConfig(filename string) (*Config, error)
• type TableConfig

Functions

func NewDBConnections

func NewDBConnections(cfg *Config) (*sql.DB, *pgxpool.Pool, error)

Types

type Config

type Config struct {
	MySQLDSN    string        `yaml:"mysql_dsn"`
	PostgresDSN string        `yaml:"postgres_dsn"`
	Concurrency int           `yaml:"concurrency"`
	Tables      []TableConfig `yaml:"tables"`
}

func LoadConfig

func LoadConfig(filename string) (*Config, error)

type TableConfig

type TableConfig struct {
	SourceTable      string `yaml:"source_table"`
	DestinationTable string `yaml:"destination_table"`
}