config

Documentation

Index

• type Config
  • func Get() (*Config, error)

Types

type Config

type Config struct {
	BindAddr                   string        `envconfig:"BIND_ADDR"`
	GracefulShutdownTimeout    time.Duration `envconfig:"GRACEFUL_SHUTDOWN_TIMEOUT"`
	HealthCheckInterval        time.Duration `envconfig:"HEALTHCHECK_INTERVAL"`
	HealthCheckCriticalTimeout time.Duration `envconfig:"HEALTHCHECK_CRITICAL_TIMEOUT"`
	KafkaAddr                  []string      `envconfig:"KAFKA_ADDR"                     json:"-"`
	KafkaVersion               string        `envconfig:"KAFKA_VERSION"`
	KafkaOffsetOldest          bool          `envconfig:"KAFKA_OFFSET_OLDEST"`
	KafkaNumWorkers            int           `envconfig:"KAFKA_NUM_WORKERS"`
	HelloCalledGroup           string        `envconfig:"HELLO_CALLED_GROUP"`
	HelloCalledTopic           string        `envconfig:"HELLO_CALLED_TOPIC"`
	OutputFilePath             string        `envconfig:"OUTPUT_FILE_PATH"`
}

TODO: remove hello call config options Config represents service configuration for dp-import-cantabular-dataset

func Get

func Get() (*Config, error)

Get returns the default config with any modifications through environment variables