mq

type Consumer any

type ConsumerGroup string

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

type PartitionId int32

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

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