config

Documentation

Index

• type Config
  • func DefaultConfig() *Config
  • func NewConfig(path string) (*Config, error)
• type Source

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

func NewConfig

func NewConfig(path string) (*Config, error)

NewConfig returns a new decoded Config struct

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"`
}