mq

Documentation

Index

• type Consumer
  • func NewConsumer(cfg ConsumerConfig) Consumer
• type ConsumerConfig
• type KafkaHandler
• type Message
• type Producer
  • func NewProducer(cfg ProducerConfig) Producer
• type ProducerConfig

Types

type Consumer

type Consumer interface {
	ReceiveAndHandle(h KafkaHandler) error
}

func NewConsumer

func NewConsumer(cfg ConsumerConfig) Consumer

type ConsumerConfig

type ConsumerConfig struct {
	Brokers []string
	Topic   string
	GroupID string
	Debug   bool
}

type KafkaHandler

type KafkaHandler interface {
	Handle(ctx context.Context, msg *Message) error
}

type Message

type Message = kafka.Message

type Producer

type Producer interface {
	Publish(ctx context.Context, key, payload []byte) error
}

func NewProducer

func NewProducer(cfg ProducerConfig) Producer

type ProducerConfig

type ProducerConfig struct {
	Brokers []string
	Topic   string
	Debug   bool
}