pubsub

Documentation

Index

• func DefaultConsumerConfig() *sarama.Config
• func DefaultProducerConfig(clientID string) *sarama.Config
• type KafkaPublisher
  • func NewKafkaPublisher(brokers []string, config *sarama.Config) (KafkaPublisher, error)
• type KafkaSubscriber
  • func NewKafkaSubscriber(brokers []string, config *sarama.Config, logger log.Logger) KafkaSubscriber
• type OnKafkaMessage

Functions

func DefaultConsumerConfig

func DefaultConsumerConfig() *sarama.Config

func DefaultProducerConfig

func DefaultProducerConfig(clientID string) *sarama.Config

Types

type KafkaPublisher

type KafkaPublisher interface {
	Publish(messages []*sarama.ProducerMessage) error
	PublishMetric(topic, measurement string, tags map[string]string, fields map[string]interface{}, tm time.Time) error
	Close() error
}

func NewKafkaPublisher

func NewKafkaPublisher(brokers []string, config *sarama.Config) (KafkaPublisher, error)

type KafkaSubscriber

type KafkaSubscriber interface {
	Subscribe(topics []string, consumerGroup string, onMessage OnKafkaMessage) error
	Close()
}

func NewKafkaSubscriber

func NewKafkaSubscriber(brokers []string, config *sarama.Config, logger log.Logger) KafkaSubscriber

type OnKafkaMessage

type OnKafkaMessage func(message *sarama.ConsumerMessage)