Versions in this module Expand all Collapse all v0 v0.0.1 Feb 10, 2022 Changes in this version + type Config struct + Kafka cconfig.KafkaConfig + Log cconfig.Logger + Service Service + func (c *Config) String() string + type Delivery struct + Method string + Webhook Webhook + type Filter struct + SelectedDomains []string + type KafkaConsumer struct + Concurrency int + ConsumerGroup string + ConsumerGroupDlqTopic string + InitialOffset string + type Service struct + Metrics cconfig.Metrics + Subscribers []Subscriber + type Subscriber struct + Consumer KafkaConsumer + Delivery Delivery + Filter Filter + Name string + type Webhook struct + CallbackRequestTimeout time.Duration + MaxRetries int + RetryInterval time.Duration + URL url.URL
Go to main page