config

Documentation

Index

• func ValidateConfig(config Config) error
• type Config
  • func LoadConfig(cmd *cobra.Command) (Config, error)

Functions

func ValidateConfig

func ValidateConfig(config Config) error

Types

type Config

type Config struct {
	Loader            redshiftloader.LoaderConfig `yaml:"loader"`
	ConsumerGroups    []kafka.ConsumerGroupConfig `yaml:"consumerGroups"`
	S3Sink            s3sink.Config               `yaml:"s3sink"`
	SchemaRegistryURL string                      `yaml:"schemaRegistryURL"`
	PrometheusURL     string                      `yaml:"prometheusURL"`
	Redshift          redshift.RedshiftConfig     `yaml:"redshift"`
	RedshiftGroup     *string                     `yaml:"redshiftGroup,omitempty"`
	RedshiftMetrics   bool                        `yaml:"redshiftMetrics"`
	Rsk               string                      `yaml:"rsk,omitempty"`
	SinkGroup         string                      `yaml:"sinkGroup,omitempty"`
}

func LoadConfig

func LoadConfig(cmd *cobra.Command) (Config, error)