config

Documentation

Index

• type Config
  • func (c Config) Validate() error
• type DatabaseCfg
• type DumperCfg
• type FilterStruct
• type ListenerCfg
• type LoggerCfg
• type PublisherCfg

Types

type Config

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

Config for pg-listener/

func (Config) Validate

func (c Config) Validate() error

Validate config data.

type DatabaseCfg

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
}

DatabaseCfg path of the PostgreSQL DB config.

type DumperCfg

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

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

FilterStruct incoming WAL message filter.

type ListenerCfg

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"`
}

ListenerCfg path of the listener config.

type LoggerCfg

type LoggerCfg struct {
	Caller        bool
	Level         string
	HumanReadable bool
}

LoggerCfg path of the logger config.

type PublisherCfg

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

PublisherCfg path of the evernt publisher config.