Versions in this module Expand all Collapse all v0 v0.2.5 May 24, 2024 Changes in this version + type LocalQueue struct + Logger logrus.FieldLogger + Metrics metrics.Client + func (_ *LocalQueue) MuxImplName() (name string, isDefault bool) + func (q *LocalQueue) Close(ctx context.Context) error + func (q *LocalQueue) CreateConsumer(group mq.ConsumerGroup, partition mq.PartitionId, handler mq.MessageHandler) (mq.Consumer, error) + func (q *LocalQueue) CreateProducer() (_ mq.Producer, err error) + func (q *LocalQueue) Init() error + func (q *LocalQueue) Options() manager.Options + func (q *LocalQueue) Start(ctx context.Context) error + func (q *LocalQueue) WaitForCompletions(request int64) + type Options struct + PartitionByObject bool + func (options *Options) EnableFlag() *bool + func (options *Options) Setup(fs *pflag.FlagSet)