config

Documentation

Index

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

Constants

const KafkaTLSProtocolFlag = "TLS"

KafkaTLSProtocolFlag informs service to use TLS protocol for kafka

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"`
	DefaultRequestTimeout        time.Duration `envconfig:"DEFAULT_REQUEST_TIMEOUT"`
	ServiceAuthToken             string        `envconfig:"SERVICE_AUTH_TOKEN"         json:"-"`
	CantabularURL                string        `envconfig:"CANTABULAR_URL"`
	CantabularExtURL             string        `envconfig:"CANTABULAR_EXT_API_URL"`
	DatasetAPIURL                string        `envconfig:"DATASET_API_URL"`
	DownloadServiceURL           string        `envconfig:"DOWNLOAD_SERVICE_URL"`
	CantabularHealthcheckEnabled bool          `envconfig:"CANTABULAR_HEALTHCHECK_ENABLED"`
	AWSRegion                    string        `envconfig:"AWS_REGION"`
	UploadBucketName             string        `envconfig:"UPLOAD_BUCKET_NAME"`
	PrivateUploadBucketName      string        `envconfig:"PRIVATE_UPLOAD_BUCKET_NAME"`
	LocalObjectStore             string        `envconfig:"LOCAL_OBJECT_STORE"`
	MinioAccessKey               string        `envconfig:"MINIO_ACCESS_KEY"`
	MinioSecretKey               string        `envconfig:"MINIO_SECRET_KEY"`
	VaultToken                   string        `envconfig:"VAULT_TOKEN"                   json:"-"`
	VaultAddress                 string        `envconfig:"VAULT_ADDR"`
	VaultPath                    string        `envconfig:"VAULT_PATH"`
	ComponentTestUseLogFile      bool          `envconfig:"COMPONENT_TEST_USE_LOG_FILE"`
	EncryptionDisabled           bool          `envconfig:"ENCRYPTION_DISABLED"`
	StopConsumingOnUnhealthy     bool          `envconfig:"STOP_CONSUMING_ON_UNHEALTHY"`
	KafkaConfig                  KafkaConfig
}

Config represents service configuration for dp-cantabular-csv-exporter

func Get

func Get() (*Config, error)

Get returns the default config with any modifications through environment variables

type KafkaConfig

type KafkaConfig struct {
	Addr                  []string `envconfig:"KAFKA_ADDR"                            json:"-"`
	Version               string   `envconfig:"KAFKA_VERSION"`
	OffsetOldest          bool     `envconfig:"KAFKA_OFFSET_OLDEST"`
	NumWorkers            int      `envconfig:"KAFKA_NUM_WORKERS"`
	MaxBytes              int      `envconfig:"KAFKA_MAX_BYTES"`
	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"`
	InstanceCompleteGroup string   `envconfig:"INSTANCE_COMPLETE_GROUP"`
	InstanceCompleteTopic string   `envconfig:"INSTANCE_COMPLETE_TOPIC"`
	CsvCreatedTopic       string   `envconfig:"CSV_CREATED_TOPIC"`
}

KafkaConfig contains the config required to connect to Kafka