mq

Documentation

Index

• type Consumer
• type ConsumerGroup
• type MessageHandler
• type PartitionId
• type Producer
• type Queue

Types

type Consumer

type Consumer any

type ConsumerGroup

type ConsumerGroup string

type MessageHandler

type MessageHandler func(ctx context.Context, fieldLogger logrus.FieldLogger, key []byte, value []byte)

type PartitionId

type PartitionId int32

type Producer

type Producer interface {
	Send(partitionKey []byte, value []byte) error
}

type Queue

type Queue interface {
	CreateProducer() (Producer, error)
	CreateConsumer(group ConsumerGroup, partition PartitionId, handler MessageHandler) (Consumer, error)
}

Queue is the abstraction of a partitioned message queue.