Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewConsumer ¶
Types ¶
type Config ¶
type Config struct { Producer ConfigProducer `mapstructure:"producer"` Consumer ConfigConsumer `mapstructure:"consumer"` LogLevel string `mapstructure:"log_level"` }
type ConfigConsumer ¶
type ConfigConsumer struct { Host string `mapstructure:"host"` Port int `mapstructure:"port"` MaxAttempts uint16 `mapstructure:"max_attempts"` MaxInFlight int `mapstructure:"max_in_flight"` MaxRequeueDelay time.Duration `mapstructure:"max_requeue_delay"` DefaultRequeueDelay time.Duration `mapstructure:"default_requeue_delay"` }
type ConfigProducer ¶
Click to show internal directories.
Click to hide internal directories.