INNER CODE UNIT · Go

NewConfig

ozontech/file.d · cfg/config.go:99

func NewConfig() *Config {
	return &Config{
		Pipelines: make(map[string]*PipelineConfig, 20),
	}
}

func NewConfigFromFiles(paths []string) *Config {
	mergedConfig := make(map[any]any, len(paths))

	for _, path := range paths {
		logger.Infof("reading config %q", path)
		yamlContents, err := os.ReadFile(path)
		if err != nil {
			logger.Fatalf("can't read config file %q: %s", path, err)
		}
		var currentConfig map[any]any
		if err := yaml.Unmarshal(yamlContents, &currentConfig); err != nil {
			logger.Fatalf("can't parse config file yaml %q: %s", path, err)

View source record →