config

Documentation

Index

• Constants
• type Config
  • func Get() (*Config, error)
• type KafkaConfig
• type MongoConfig

Constants

const (
	JobsCollection  = "JobsCollection"
	LocksCollection = "LocksCollection"
	TasksCollection = "TasksCollection"
)

Types

type Config

type Config struct {
	BindAddr                   string        `envconfig:"BIND_ADDR"`
	DefaultLimit               int           `envconfig:"DEFAULT_LIMIT"`
	DefaultMaxLimit            int           `envconfig:"DEFAULT_MAXIMUM_LIMIT"`
	DefaultOffset              int           `envconfig:"DEFAULT_OFFSET"`
	GracefulShutdownTimeout    time.Duration `envconfig:"GRACEFUL_SHUTDOWN_TIMEOUT"`
	HealthCheckCriticalTimeout time.Duration `envconfig:"HEALTHCHECK_CRITICAL_TIMEOUT"`
	HealthCheckInterval        time.Duration `envconfig:"HEALTHCHECK_INTERVAL"`
	LatestVersion              string        `envconfig:"LATEST_VERSION"`
	MaxReindexJobRuntime       time.Duration `envconfig:"MAX_REINDEX_JOB_RUNTIME"`
	SearchAPIURL               string        `envconfig:"SEARCH_API_URL"`
	ServiceAuthToken           string        `envconfig:"SERVICE_AUTH_TOKEN"   json:"-"`
	TaskNameValues             string        `envconfig:"TASK_NAME_VALUES"`
	ZebedeeURL                 string        `envconfig:"ZEBEDEE_URL"`
	KafkaConfig                KafkaConfig
	MongoConfig                MongoConfig
}

Config represents service configuration for dp-search-reindex-api

func Get

func Get() (*Config, error)

Get returns the default config with any modifications through environment variables

type KafkaConfig

type KafkaConfig struct {
	Brokers               []string `envconfig:"KAFKA_ADDR"                            json:"-"`
	Version               string   `envconfig:"KAFKA_VERSION"`
	SecProtocol           string   `envconfig:"KAFKA_SEC_PROTO"`
	SecCACerts            string   `envconfig:"KAFKA_SEC_CA_CERTS"`
	SecClientKey          string   `envconfig:"KAFKA_SEC_CLIENT_KEY"                  json:"-"`
	SecClientCert         string   `envconfig:"KAFKA_SEC_CLIENT_CERT"`
	SecSkipVerify         bool     `envconfig:"KAFKA_SEC_SKIP_VERIFY"`
	ReindexRequestedTopic string   `envconfig:"KAFKA_REINDEX_REQUESTED_TOPIC"`
}

KafkaConfig contains the config required to connect to Kafka

type MongoConfig

type MongoConfig struct {
	mongodriver.MongoDriverConfig
}

MongoConfig contains the config required to connect to DocumentDB.