config

type Config struct {
	Etcd            Etcd            `yaml:"etcd"`
	Runtime         *Runtime        `yaml:"runtime"`
	FileConnectors  FileConnectors  `yaml:"file-connector"`
	HttpConnectors  HttpConnectors  `yaml:"http-connector"`
	MysqlConnectors MysqlConnectors `yaml:"mysql-connector"`
	Worker          Worker          `yaml:"worker"`
	Coordinator     Coordinator     `yaml:"coordinator"`
}

type Coordinator struct {
	HttpPort int `yaml:"http-port"`
}

type Etcd struct {
	Endpoint             []string `yaml:"endpoint"`
	DialTimeout          int      `yaml:"dial-timeout"`
	DialKeepAliveTimeout int      `yaml:"dial-keepalive-timeout"`
	Username             string   `yaml:"username"`
	Password             string   `yaml:"password"`
}

type FileConnector struct {
	Catalog     string   `yaml:"catalog"`
	Schema      string   `yaml:"schema"`
	Table       string   `yaml:"table"`
	FileType    string   `yaml:"file-type"`
	ColumnNames []string `yaml:"column-names"`
	ColumnTypes []string `yaml:"column-types"`
	Paths       []string `yaml:"paths"`
}

type FileConnectors map[string]*FileConnector

type HttpConnector struct {
	Catalog      string   `yaml:"catalog"`
	Schema       string   `yaml:"schema"`
	Table        string   `yaml:"table"`
	DataPath     string   `yaml:"data-path"`
	FilterColumn string   `yaml:"filter-column"`
	ResultColumn string   `yaml:"result-column"`
	ColumnNames  []string `yaml:"column-names"`
	ColumnTypes  []string `yaml:"column-types"`
}

type HttpConnectors map[string]*HttpConnector

type MysqlConnector struct {
	Catalog     string   `yaml:"catalog"`
	Schema      string   `yaml:"schema"`
	Table       string   `yaml:"table"`
	Host        string   `yaml:"host"`
	Port        string   `yaml:"port"`
	User        string   `yaml:"user"`
	Password    string   `yaml:"password"`
	ColumnNames []string `yaml:"column-names"`
	ColumnTypes []string `yaml:"column-types"`
}

type MysqlConnectors map[string]*MysqlConnector

type Runtime struct {
	Catalog        string `yaml:"catalog"`
	Schema         string `yaml:"schema"`
	Table          string `yaml:"table"`
	ParallelNumber int    `yaml:"parallel-number"`
}

type Worker struct {
	Host    string `yaml:"host"`
	TCPPort int    `yaml:"tcp-port"`
	RPCPort int    `yaml:"rpc-port"`
}