config

Documentation

Overview

Package config contains logic for building project configuration

Index

• type KafkaConsumerConfig
  • func KafkaConsumer() (*KafkaConsumerConfig, error)
• type KafkaProducerConfig
  • func KafkaProducer() (*KafkaProducerConfig, error)

Types

type KafkaConsumerConfig

type KafkaConsumerConfig struct {
	PostgresConnString string        `env:"POSTGRES_URL"`
	BrokerAddr         string        `env:"KAFKA_BROKER_ADDR"`
	Topic              string        `env:"KAFKA_TOPIC"`
	Partition          int           `env:"KAFKA_TOPIC_PARTITION" envDefault:"0"`
	BatchMinBytes      int           `env:"KAFKA_BATCH_MIN_BYTES" envDefault:"1000"`
	BatchMaxBytes      int           `env:"KAFKA_BATCH_MAX_BYTES" envDefault:"5000000"`
	CommitInterval     time.Duration `env:"KAFKA_COMMIT_INTERVAL" envDefault:"1s"`
}

KafkaConsumerConfig is configuration for kafka consumer

func KafkaConsumer

func KafkaConsumer() (*KafkaConsumerConfig, error)

KafkaConsumer builds config for kafka consumer

type KafkaProducerConfig

type KafkaProducerConfig struct {
	BrokerAddr string `env:"KAFKA_BROKER_ADDR"`
	Topic      string `env:"KAFKA_TOPIC"`
	Partition  int    `env:"KAFKA_TOPIC_PARTITION" envDefault:"0"`
	BatchSize  int    `env:"KAFKA_BATCH_SIZE" envDefault:"2000"`
}

KafkaProducerConfig is configuration for kafka producer

func KafkaProducer

func KafkaProducer() (*KafkaProducerConfig, error)

KafkaProducer builds config for kafka producer