config

type ElasticConfig struct {
	Url        string `yaml:"url"`
	User       string `yaml:"user"`
	Password   string `yaml:"password"`
	CaCertPath string `yaml:"caCertPath"`
	NumWorker  int    `yaml:"numWorker"`
}

type Field struct {
	Name string `yaml:"name"`
	Type string `yaml:"type"`
}

type IReader interface {
	ReadConfig() ([]byte, error)
}

type ImportConfig struct {
	PollingSeconds int           `yaml:"pollingSeconds"`
	Database       string        `yaml:"database"`
	Queries        []QueryModel  `yaml:"queries"`
	Elastic        ElasticConfig `yaml:"elastic"`
}

type JSONField struct {
	FieldName string  `yaml:"fieldName"`
	Fields    []Field `yaml:"fields"`
}

type QueryModel struct {
	Index      string      `yaml:"index"`
	Query      string      `yaml:"query"`
	UpdateDate string      `yaml:"updateDate"`
	Fields     []Field     `yaml:"fields"`
	JSONFields []JSONField `yaml:"JSONFields"`
	Id         string      `yaml:"id"`
}

type Reader struct {
	FileName string
}