Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Listener string `yaml:"listener"`
Logger zap.Config `yaml:"logger"`
DataPath string `yaml:"data_path"`
Sources []Source `yaml:"sources"`
}
func DefaultConfig ¶
func DefaultConfig() *Config
type Source ¶
type Source struct {
Enabled bool `yaml:"enabled"`
FileConfig *sources.FileSourceConfig `yaml:"file-config,omitempty"`
KafkaConfig *sources.KafkaSourceConfig `yaml:"kafka-config,omitempty"`
CsvParser []*parsers.CsvParserConfig `yaml:"csv-parsers,omitempty"`
JsonParser []*parsers.JsonParserConfig `yaml:"json-parsers,omitempty"`
}
Click to show internal directories.
Click to hide internal directories.