config

Documentation

Index

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

Constants

const KafkaTLSProtocolFlag = "TLS"

KafkaTLSProtocolFlag informs service to use TLS protocol for kafka

Types

type Config

type Config struct {
	AWSRegion                  string        `envconfig:"AWS_REGION"`
	BindAddr                   string        `envconfig:"BIND_ADDR"`
	DatasetAPIURL              string        `envconfig:"DATASET_API_URL"`
	EncryptionDisabled         bool          `envconfig:"ENCRYPTION_DISABLED"`
	GracefulShutdownTimeout    time.Duration `envconfig:"GRACEFUL_SHUTDOWN_TIMEOUT"`
	KafkaConfig                KafkaConfig
	LocalstackHost             string        `envconfig:"LOCALSTACK_HOST"`
	MaxRetries                 int           `envconfig:"REQUEST_MAX_RETRIES"`
	VaultAddr                  string        `envconfig:"VAULT_ADDR"`
	VaultToken                 string        `envconfig:"VAULT_TOKEN"                    json:"-"`
	VaultPath                  string        `envconfig:"VAULT_PATH"`
	ServiceAuthToken           string        `envconfig:"SERVICE_AUTH_TOKEN"             json:"-"`
	ZebedeeURL                 string        `envconfig:"ZEBEDEE_URL"`
	HealthCheckInterval        time.Duration `envconfig:"HEALTHCHECK_INTERVAL"`
	HealthCheckCriticalTimeout time.Duration `envconfig:"HEALTHCHECK_CRITICAL_TIMEOUT"`
	BucketNames                []string      `envconfig:"BUCKET_NAMES"                   json:"-"`
}

Config is the filing resource handler config

func Get

func Get() (*Config, error)

Get configures the application and returns the configuration

func (Config) String

func (config Config) String() string

String is implemented to prevent sensitive fields being logged. The config is returned as JSON with sensitive fields omitted.

type KafkaConfig

type KafkaConfig struct {
	BindAddr                 []string `envconfig:"KAFKA_ADDR"                            json:"-"`
	MaxBytes                 string   `envconfig:"KAFKA_MAX_BYTES"`
	Version                  string   `envconfig:"KAFKA_VERSION"`
	SecProtocol              string   `envconfig:"KAFKA_SEC_PROTO"`
	SecCACerts               string   `envconfig:"KAFKA_SEC_CA_CERTS"`
	SecClientCert            string   `envconfig:"KAFKA_SEC_CLIENT_CERT"`
	SecClientKey             string   `envconfig:"KAFKA_SEC_CLIENT_KEY"                  json:"-"`
	SecSkipVerify            bool     `envconfig:"KAFKA_SEC_SKIP_VERIFY"`
	DimensionsExtractedTopic string   `envconfig:"DIMENSIONS_EXTRACTED_TOPIC"`
	EventReporterTopic       string   `envconfig:"EVENT_REPORTER_TOPIC"`
	InputFileAvailableGroup  string   `envconfig:"INPUT_FILE_AVAILABLE_GROUP"`
	InputFileAvailableTopic  string   `envconfig:"INPUT_FILE_AVAILABLE_TOPIC"`
}

KafkaConfig contains the config required to connect to Kafka