local

package
v0.0.0-...-070373f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 19, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL