config

Documentation

Index

• func BootstrapServers() string
• func ConfigurationFile() string
• func GraylogServer() string
• func GroupID() string
• func HistoryTopic() string
• func LogLevel() log.Level
• func MetricsAddr() string
• func ScheduleGraceInterval() int
• func SchedulesTopics() []string
• func ServerAddr() string
• func SessionTimeout() int
• func SinceDelta() int
• type File
  • func ReadFile(filePath string) (File, error)
  • func (f *File) GenerateConsumerConfiguration() confluent.ConfigMap
  • func (f *File) GenerateProducerConfiguration() confluent.ConfigMap

Functions

func BootstrapServers

func BootstrapServers() string

func ConfigurationFile

func ConfigurationFile() string

func GraylogServer

func GraylogServer() string

func GroupID

func GroupID() string

func HistoryTopic

func HistoryTopic() string

func LogLevel

func LogLevel() log.Level

func MetricsAddr

func MetricsAddr() string

func ScheduleGraceInterval

func ScheduleGraceInterval() int

func SchedulesTopics

func SchedulesTopics() []string

func ServerAddr

func ServerAddr() string

func SessionTimeout

func SessionTimeout() int

func SinceDelta

func SinceDelta() int

Types

type File

type File struct {
	KafkaCommonConfiguration   confluent.ConfigMap `yaml:"kafka.common.configuration,omitempty"`
	KafkaProducerConfiguration confluent.ConfigMap `yaml:"kafka.producer.configuration,omitempty"`
	KafkaConsumerConfiguration confluent.ConfigMap `yaml:"kafka.consumer.configuration,omitempty"`
}

func ReadFile

func ReadFile(filePath string) (File, error)

func (*File) GenerateConsumerConfiguration

func (f *File) GenerateConsumerConfiguration() confluent.ConfigMap

func (*File) GenerateProducerConfiguration

func (f *File) GenerateProducerConfiguration() confluent.ConfigMap