Function decodeAndCheckConfig

config.go:233–277

(md toml.MetaData, compCfg interface{})

}

func decodeAndCheckConfig(md toml.MetaData, compCfg interface{}) error {
	var (
		cfg  *toml.Primitive // config
		dcfg interface{}     // decoded config
		name string          // component name
		typ  string          // component type
	)

	switch t := compCfg.(type) {
	case ConfigInput:
		cfg, dcfg = t.Config, t.DecodedConfig
		name, typ = t.Name, "input"
	case ConfigFilter:
		cfg, dcfg = t.Config, t.DecodedConfig
		name, typ = t.Name, "filter"
	case ConfigOutput:
		cfg, dcfg = t.Config, t.DecodedConfig
		name, typ = t.Name, "output"
	case ConfigUpload:
		cfg, dcfg = t.Config, t.DecodedConfig
		name, typ = t.Name, "upload"
	case ConfigMetrics:
		cfg, dcfg = t.Config, t.DecodedConfig
		name, typ = t.Name, "metrics"
	default:
		panic(fmt.Sprintf("unexpected type %#v", cfg))
	}

	if cfg == nil {
		// No config section was given in the TOML, so we create a pointer to
		// the zero value of our config struct to check required field
		tcfg := reflect.TypeOf(dcfg).Elem()
		dcfg = reflect.New(tcfg).Interface()
	} else {
		if err := md.PrimitiveDecode(*cfg, dcfg); err != nil {
			return fmt.Errorf("%s %q: error parsing config: %v", typ, name, err)
		}
	}

	if req := CheckRequiredFields(dcfg); req != "" {
		return fmt.Errorf("%s %q: %w", typ, name, ErrorRequiredField{req})
	}

	return nil
}

// NewConfigFromToml creates a Config from a reader reading from a TOML
// configuration. comp describes all the existing components.