config

Documentation

Index

• Variables
• func Load()

Variables

var AWSRegion = "eu-west-1"

AWSRegion the AWS region to use.

var BindAddr = ":21100"

BindAddr the address to bind to.

var KafkaAddr = "localhost:9092"

KafkaAddr the Kafka address to send messages to.

var KafkaConsumerGroup = "filter-request"

KafkaConsumerGroup the consumer group to consume messages from.

var KafkaConsumerTopic = "filter-request"

KafkaConsumerTopic the name of the topic to consume messages from.

var KafkaTransformTopic = "transform-request"

KafkaTransformTopic the name of the topic to send transform request messages to.

var OutputS3Bucket = "dp-dd-csv-filter-develop/" + os.Getenv("USER") + "/filtered/"

OutputS3Bucket the name of the bucket to send filtered csv files to

Functions

func Load

func Load()