INNER CODE UNIT · Go

ReadPipelineConfigFromEnv

loggie-io/loggie · pkg/control/config.go:152

func ReadPipelineConfigFromEnv(key string, _ FileIgnore) (*PipelineConfig, error) {
	pipecfgs := &PipelineConfig{}
	if err := cfg.UnpackFromEnv(key, pipecfgs).Defaults().Validate().Do(); err != nil {
		// ignore invalid pipeline
		log.Error("pipeline configs invalid: %v, \n%s", err, key)
		return nil, err
	}
	return pipecfgs, nil
}

func ReadPipelineConfig(path string, configType string, ignore FileIgnore) (*PipelineConfig, error) {
	switch configType {
	case "file":
		return ReadPipelineConfigFromFile(path, ignore)
	case "env":
		return ReadPipelineConfigFromEnv(path, ignore)
	default:
		return ReadPipelineConfigFromFile(path, ignore)

View source record →