config

Documentation

Index

• type BaseConfig
  • func NewBaseConfig(fileName *string) *BaseConfig
  • func (bc *BaseConfig) ReadBaseConfig() error
• type DorisConfig
  • func (dc *DorisConfig) GetOutputTargetConfig() interface{}
  • func (dc *DorisConfig) NewOutputTargetConfig(config map[string]interface{})
• type FilterConfig
• type InputConfig
• type InputSourceConfig
• type MongoConfig
  • func (mc *MongoConfig) GetInputSourceConfig() interface{}
  • func (mc *MongoConfig) NewInputSourceConfig(config map[string]interface{})
• type MysqlConfig
  • func (mc *MysqlConfig) GetInputSourceConfig() interface{}
  • func (mc *MysqlConfig) NewInputSourceConfig(config map[string]interface{})
• type OutputConfig
• type OutputTargetConfig
• type StarrocksConfig
  • func (sc *StarrocksConfig) GetOutputTargetConfig() interface{}
  • func (sc *StarrocksConfig) NewOutputTargetConfig(config map[string]interface{})
• 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
}

func (*DorisConfig) GetOutputTargetConfig

func (dc *DorisConfig) GetOutputTargetConfig() interface{}

func (*DorisConfig) NewOutputTargetConfig

func (dc *DorisConfig) NewOutputTargetConfig(config map[string]interface{})

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 InputSourceConfig

type InputSourceConfig interface {
	NewInputSourceConfig(config map[string]interface{})
	GetInputSourceConfig() interface{}
}

type MongoConfig

type MongoConfig struct {
	Uri      string
	UserName string
	Password string
}

func (*MongoConfig) GetInputSourceConfig

func (mc *MongoConfig) GetInputSourceConfig() interface{}

func (*MongoConfig) NewInputSourceConfig

func (mc *MongoConfig) NewInputSourceConfig(config map[string]interface{})

type MysqlConfig

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

func (*MysqlConfig) GetInputSourceConfig

func (mc *MysqlConfig) GetInputSourceConfig() interface{}

func (*MysqlConfig) NewInputSourceConfig

func (mc *MysqlConfig) NewInputSourceConfig(config map[string]interface{})

type OutputConfig

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

type OutputTargetConfig

type OutputTargetConfig interface {
	NewOutputTargetConfig(config map[string]interface{})
	GetOutputTargetConfig() interface{}
}

type StarrocksConfig

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

func (*StarrocksConfig) GetOutputTargetConfig

func (sc *StarrocksConfig) GetOutputTargetConfig() interface{}

func (*StarrocksConfig) NewOutputTargetConfig

func (sc *StarrocksConfig) NewOutputTargetConfig(config map[string]interface{})

type SyncParamConfig

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