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 {
	Batcher           redshiftbatcher.BatcherConfig `yaml:"batcher"`
	ConsumerGroups    []kafka.ConsumerGroupConfig   `yaml:"consumerGroups"`
	S3Sink            s3sink.Config                 `yaml:"s3sink"`
	SchemaRegistryURL string                        `yaml:"schemaRegistryURL"`
	GitAccessToken    string                        `yaml:"gitAccessToken"`
	SinkGroup         string                        `yaml:"sinkGroup,omitempty"`
}

func LoadConfig

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