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.