config

type Config struct {
	BindAddr                          string        `envconfig:"BIND_ADDR"`
	EnableTopicTagging                bool          `envconfig:"TOPIC_TAGGING_ENABLED"`
	TopicCacheUpdateInterval          time.Duration `envconfig:"TOPIC_CACHE_UPDATE_INTERVAL"`
	TopicAPIURL                       string        `envconfig:"TOPIC_API_URL"`
	GracefulShutdownTimeout           time.Duration `envconfig:"GRACEFUL_SHUTDOWN_TIMEOUT"`
	HealthCheckInterval               time.Duration `envconfig:"HEALTHCHECK_INTERVAL"`
	HealthCheckCriticalTimeout        time.Duration `envconfig:"HEALTHCHECK_CRITICAL_TIMEOUT"`
	EnableZebedeeCallbacks            bool          `envconfig:"ENABLE_ZEBEDEE_CALLBACKS"`
	EnableDatasetAPICallbacks         bool          `envconfig:"ENABLE_DATASET_API_CALLBACKS"`
	EnableSearchContentUpdatedHandler bool          `envconfig:"ENABLE_SEARCH_CONTENT_UPDATED_HANDLER"`
	ZebedeeURL                        string        `envconfig:"ZEBEDEE_URL"`
	KeywordsLimit                     int           `envconfig:"KEYWORDS_LIMITS"`
	DatasetAPIURL                     string        `envconfig:"DATASET_API_URL"`
	ServiceAuthToken                  string        `envconfig:"SERVICE_AUTH_TOKEN"            json:"-"`
	StopConsumingOnUnhealthy          bool          `envconfig:"STOP_CONSUMING_ON_UNHEALTHY"`
	Kafka                             *Kafka
}

type Kafka struct {
	ContentUpdatedGroup       string   `envconfig:"KAFKA_CONTENT_UPDATED_GROUP"`
	ContentUpdatedTopic       string   `envconfig:"KAFKA_CONTENT_UPDATED_TOPIC"`
	SearchContentTopic        string   `envconfig:"KAFKA_SEARCH_CONTENT_UPDATED_TOPIC"`
	SearchDataImportedTopic   string   `envconfig:"KAFKA_SEARCH_IMPORT_PRODUCER_TOPIC"`
	SearchContentDeletedTopic string   `envconfig:"KAFKA_SEARCH_DELETED_PRODUCER_TOPIC"`
	Addr                      []string `envconfig:"KAFKA_ADDR"`
	Version                   string   `envconfig:"KAFKA_VERSION"`
	OffsetOldest              bool     `envconfig:"KAFKA_OFFSET_OLDEST"`
	NumWorkers                int      `envconfig:"KAFKA_NUM_WORKERS"`
	SecProtocol               string   `envconfig:"KAFKA_SEC_PROTO"`
	SecCACerts                string   `envconfig:"KAFKA_SEC_CA_CERTS"            json:"-"`
	SecClientCert             string   `envconfig:"KAFKA_SEC_CLIENT_CERT"         json:"-"`
	SecClientKey              string   `envconfig:"KAFKA_SEC_CLIENT_KEY"          json:"-"`
	SecSkipVerify             bool     `envconfig:"KAFKA_SEC_SKIP_VERIFY"`
	MaxBytes                  int      `envconfig:"KAFKA_MAX_BYTES"`
	ConsumerMinBrokersHealthy int      `envconfig:"KAFKA_CONSUMER_MIN_BROKERS_HEALTHY"`
	ProducerMinBrokersHealthy int      `envconfig:"KAFKA_PRODUCER_MIN_BROKERS_HEALTHY"`
}