config

Documentation

Index

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

Constants

const (
	FiltersCollection = "FiltersCollection"
	OutputsCollection = "OutputsCollection"
)

Types

type Config

type Config struct {
	BindAddr                   string        `envconfig:"BIND_ADDR"`
	Brokers                    []string      `envconfig:"KAFKA_ADDR"`
	FilterOutputSubmittedTopic string        `envconfig:"FILTER_JOB_SUBMITTED_TOPIC"`
	Host                       string        `envconfig:"HOST"`
	KafkaMaxBytes              int           `envconfig:"KAFKA_MAX_BYTES"`
	KafkaVersion               string        `envconfig:"KAFKA_VERSION"`
	KafkaSecProtocol           string        `envconfig:"KAFKA_SEC_PROTO"`
	KafkaSecCACerts            string        `envconfig:"KAFKA_SEC_CA_CERTS"`
	KafkaSecClientCert         string        `envconfig:"KAFKA_SEC_CLIENT_CERT"`
	KafkaSecClientKey          string        `envconfig:"KAFKA_SEC_CLIENT_KEY"             json:"-"`
	KafkaSecSkipVerify         bool          `envconfig:"KAFKA_SEC_SKIP_VERIFY"`
	ShutdownTimeout            time.Duration `envconfig:"SHUTDOWN_TIMEOUT"`
	DatasetAPIURL              string        `envconfig:"DATASET_API_URL"`
	HealthCheckInterval        time.Duration `envconfig:"HEALTHCHECK_INTERVAL"`
	HealthCheckCriticalTimeout time.Duration `envconfig:"HEALTHCHECK_CRITICAL_TIMEOUT"`
	ServiceAuthToken           string        `envconfig:"SERVICE_AUTH_TOKEN"               json:"-"`
	ZebedeeURL                 string        `envconfig:"ZEBEDEE_URL"`
	EnablePrivateEndpoints     bool          `envconfig:"ENABLE_PRIVATE_ENDPOINTS"`
	DownloadServiceURL         string        `envconfig:"DOWNLOAD_SERVICE_URL"`
	DownloadServiceSecretKey   string        `envconfig:"DOWNLOAD_SERVICE_SECRET_KEY"      json:"-"`
	MaxRequestOptions          int           `envconfig:"MAX_REQUEST_OPTIONS"`
	MaxDatasetOptions          int           `envconfig:"MAX_DATASET_OPTIONS"`
	BatchMaxWorkers            int           `envconfig:"BATCH_MAX_WORKERS"`
	DefaultMaxLimit            int           `envconfig:"DEFAULT_MAXIMUM_LIMIT"`
	AssertDatasetType          bool          `envconfig:"ASSERT_DATASET_TYPE"`
	FilterFlexAPIURL           string        `envconfig:"FILTER_FLEX_API_URL"`
	MongoConfig
}

Config is the filing resource handler config

func Get

func Get() (*Config, error)

Get configures the application and returns the configuration

type MongoConfig

type MongoConfig struct {
	mongodriver.MongoDriverConfig

	Limit  int `envconfig:"MONGODB_LIMIT"`
	Offset int `envconfig:"MONGODB_OFFSET"`
}