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 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 JSONFields []struct {
	FieldName  string `yaml:"fieldName"`
	Attributes struct {
		AttributeName string `yaml:"attributeName"`
		AttributeType string `yaml:"attributeType"`
	} `yaml:"attributes"`
}

type QueryModel struct {
	Index      string     `yaml:"index"`
	Query      string     `yaml:"query"`
	UpdateDate string     `yaml:"updateDate"`
	JSONFields JSONFields `yaml:"JSONFields"`
	Id         string     `yaml:"id"`
}

type Reader struct {
	FileName string
}