configs

Documentation

Index

• func GetEsConfig(job Job) pkg.EsConfig
• type Column
• type Config
  • func NewConfig() Config
• type Connection
• type Content
• type Job
• type JobList
• type Reader
• type ReaderParameter
• type Setting
• type Speed
• type SynchronousConfig
  • func JobNameGetESConfig(jobName string) (pkg.EsConfig, SynchronousConfig, bool)
  • func JobNameGetSynchronousConfig(jobName string) (SynchronousConfig, bool)
  • func NewSynchronousConfig(configName string) SynchronousConfig
• type Writer
• type WriterParameter

Functions

func GetEsConfig

func GetEsConfig(job Job) pkg.EsConfig

Types

type Column

type Column struct {
	Name            string
	Type            string
	Analyzer        string
	Search_analyzer string
	Format          string
	Array           string
}

type Config

type Config struct {
	Title   string
	Port    int
	JobList []JobList
}

func NewConfig

func NewConfig() Config

type Connection

type Connection struct {
	QuerySql    string
	JdbcUrl     string
	BoundarySql string
	Increment   string
}

type Content

type Content struct {
	Reader Reader
	Writer Writer
}

type Job

type Job struct {
	Setting Setting
	Content Content
}

type JobList

type JobList struct {
	Name     string
	FilePath string
}

type Reader

type Reader struct {
	Name      string
	Parameter ReaderParameter
}

----- Reader ------

type ReaderParameter

type ReaderParameter struct {
	Username   string
	Password   string
	Host       string
	DbName     string
	Connection Connection
}

type Setting

type Setting struct {
	Speed Speed
}

type Speed

type Speed struct {
	Channel int
}

type SynchronousConfig

type SynchronousConfig struct {
	Job Job
}

func JobNameGetESConfig

func JobNameGetESConfig(jobName string) (pkg.EsConfig, SynchronousConfig, bool)

* 根据顶层配置文件 配置名称 返回 es 配置信息

func JobNameGetSynchronousConfig

func JobNameGetSynchronousConfig(jobName string) (SynchronousConfig, bool)

* 根据顶层配置文件 配置名称 返回 详细的配置文件信息

func NewSynchronousConfig

func NewSynchronousConfig(configName string) SynchronousConfig

type Writer

type Writer struct {
	Name      string
	Parameter WriterParameter
}

type WriterParameter

type WriterParameter struct {
	Endpoint            string
	AccessId            string
	AccessKey           string
	Index               string
	Types               string
	BatchSize           int
	Splitter            string
	Column              []Column
	Dsl                 string
	VersionGreaterThan8 bool `json:"versionGreaterThan8"`
}