config

Documentation

Index

• type BaseConfig
  • func NewBaseConfig(fileName *string) *BaseConfig
  • func (bc *BaseConfig) ReadBaseConfig() error
• type DorisConfig
• type FilterConfig
• type InputConfig
• type MongoConfig
• type MysqlConfig
• type OutputConfig
• type StarrocksConfig
• type SyncParamConfig

Types

type BaseConfig

type BaseConfig struct {
	Name            string
	InputConfig     *InputConfig     `toml:"input"`
	OutputConfig    *OutputConfig    `toml:"output"`
	SyncParamConfig *SyncParamConfig `toml:"sync-param"`
	FilterConfig    []*FilterConfig  `toml:"filter"`
	FileName        *string
}

func NewBaseConfig

func NewBaseConfig(fileName *string) *BaseConfig

func (*BaseConfig) ReadBaseConfig

func (bc *BaseConfig) ReadBaseConfig() error

type DorisConfig

type DorisConfig struct {
	Host     string
	Port     int
	LoadPort int `mapstructure:"load-port"`
	UserName string
	Password string
}

type FilterConfig

type FilterConfig struct {
	Type   string                 `toml:"type"`
	Config map[string]interface{} `toml:"config"`
}

type InputConfig

type InputConfig struct {
	Type          string                 `toml:"type"`
	StartPosition string                 `toml:"start-position"`
	Config        map[string]interface{} `toml:"config"`
}

type MongoConfig

type MongoConfig struct {
	Uri      string
	UserName string
	Password string
}

type MysqlConfig

type MysqlConfig struct {
	Host     string
	Port     int
	UserName string
	Password string
}

type OutputConfig

type OutputConfig struct {
	Type   string                 `toml:"type"`
	Config map[string]interface{} `toml:"config"`
}

type StarrocksConfig

type StarrocksConfig struct {
	Host     string
	Port     int
	LoadPort int `mapstructure:"load-port"`
	UserName string
	Password string
}

type SyncParamConfig

type SyncParamConfig struct {
	ChannelSize      int `toml:"channel-size"`
	FlushDelaySecond int `toml:"flush-delay-second"`
}