Versions in this module Expand all Collapse all v0 v0.1.0 May 22, 2025 Changes in this version + const Proto + type Consumer struct + DeadLetterQueue string + EnableDeadLetter bool + func NewConsumer(proto string, configName string, config config.Config) (consumer *Consumer, err error) + func (consumer *Consumer) Close() error + func (consumer *Consumer) Connect() (err error) + func (consumer *Consumer) Consume(task queue.TaskInfo, callback queue.ConsumeCallback) (err error) + func (consumer *Consumer) ServerURL() string + func (consumer *Consumer) Start() error + func (consumer *Consumer) Unconsume(queue string) + type Producer struct + func NewProducer(config config.Config, opts ...queue.Option) (m *Producer, err error) + func (c *Producer) Close() error + func (c *Producer) DelayPush(ctx context.Context, key string, msg queue.Message, delaySeconds int64) error + func (c *Producer) Name() string + func (c *Producer) Push(ctx context.Context, key string, msg queue.Message) error + func (p *Producer) BatchPush(ctx context.Context, key string, msgList ...queue.Message) error + type ProductOptions struct + DelayInterval int + type QueueItem struct + BlockTimeout int + Concurrency int + QueueName string
Go to main page