config

type Config struct {
	Listener  ListenerCfg  // 数据库监控器配置
	Database  DatabaseCfg  // 数据库连接配置
	Publisher PublisherCfg // 事件发布器配置
	Dumper    DumperCfg    // Dumper 配置
	Logger    LoggerCfg    // 日志配置
}

type DatabaseCfg struct {
	Host     string `valid:"required"`
	Port     uint16 `valid:"required"`
	Name     string `valid:"required"`
	User     string `valid:"required"`
	Password string `valid:"required"`
	Schema   string
	Filter   FilterStruct
}

type DumperCfg struct {
	Handler  string // Dump Handler: event,sql,es 默认event, 适合历史数据较少情况
	FileSize int    // Dump 文件大小字节: 0 使用默认 1 MB, -1 不限制文件大小,最大文件20GB
	Path     string // pg_dump 路径
}

type FilterStruct struct {
	Tables map[string][]string
}

type ListenerCfg struct {
	SlotName          string        `valid:"required"`
	PubName           string        // 发布名称
	Dump              bool          // 是否导出复制槽快照数据
	AckTimeout        time.Duration `valid:"required"`
	RefreshConnection time.Duration `valid:"required"`
	HeartbeatInterval time.Duration `valid:"required"`
}

type LoggerCfg struct {
	Caller        bool
	Level         string
	HumanReadable bool
}

type PublisherCfg struct {
	Type        string `valid:"required"`
	Address     string `valid:"required"`
	ClusterID   string `valid:"required"`
	ClientID    string `valid:"required"`
	TopicPrefix string `valid:"required"`
}