local

Documentation

Index

• type LocalQueue
  • 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 (_ *LocalQueue) MuxImplName() (name string, isDefault bool)
  • func (q *LocalQueue) Options() manager.Options
  • func (q *LocalQueue) Start(ctx context.Context) error
  • func (q *LocalQueue) WaitForCompletions(request int64)
• type Options
  • func (options *Options) EnableFlag() *bool
  • func (options *Options) Setup(fs *pflag.FlagSet)

Types

type LocalQueue

type LocalQueue struct {
	manager.MuxImplBase

	Logger  logrus.FieldLogger
	Metrics metrics.Client
	// contains filtered or unexported fields
}

func (*LocalQueue) Close

func (q *LocalQueue) Close(ctx context.Context) error

func (*LocalQueue) CreateConsumer

func (q *LocalQueue) CreateConsumer(group mq.ConsumerGroup, partition mq.PartitionId, handler mq.MessageHandler) (mq.Consumer, error)

func (*LocalQueue) CreateProducer

func (q *LocalQueue) CreateProducer() (_ mq.Producer, err error)

func (*LocalQueue) Init

func (q *LocalQueue) Init() error

func (*LocalQueue) MuxImplName

func (_ *LocalQueue) MuxImplName() (name string, isDefault bool)

func (*LocalQueue) Options

func (q *LocalQueue) Options() manager.Options

func (*LocalQueue) Start

func (q *LocalQueue) Start(ctx context.Context) error

func (*LocalQueue) WaitForCompletions

func (q *LocalQueue) WaitForCompletions(request int64)

Busy-waits until all consumers have no lagging messages at some point. Only used for testing.

type Options

type Options struct {
	PartitionByObject bool
}

func (*Options) EnableFlag

func (options *Options) EnableFlag() *bool

func (*Options) Setup

func (options *Options) Setup(fs *pflag.FlagSet)