Versions in this module Expand all Collapse all v0 v0.1.1 Mar 4, 2026 Changes in this version + const Name + func MustNewProducer(c *queue.Conf) queue.Pusher + func MustNewQueue(c *queue.Conf) queue.MessageQueue + func NewConsumer(c *queue.Conf) (queue.MessageQueue, error) + func NewProducer(c *queue.Conf) (queue.Pusher, error) + type Consumer struct + func (c *Consumer) Close() error + func (c *Consumer) Name() string + func (c *Consumer) Subscribe(topic string, handler queue.ConsumeHandle, opts ...queue.SubscribeOption) (queue.Subscriber, error) + type Producer struct + func (p *Producer) Close() error + func (p *Producer) Name() string + func (p *Producer) Push(ctx context.Context, topic string, key, value []byte) error + func (p *Producer) PushWithPartition(ctx context.Context, topic string, key, value []byte, partition int32) error
Go to main page