rabbitmq

package
v0.73.54 Latest Latest
Warning

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

 Go to latest Published: Oct 30, 2025 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const MAX_RETRY_COUNT = 15
View Source 
const RETRY_INTERVAL = 2 * time.Second
View Source 
const RETRY_RESET_INTERVAL = 30 * time.Second

Variables

This section is empty.

Functions

This section is empty.

Types

type CompressionResult added in v0.73.35 

type CompressionResult struct {
	Payloads       [][]byte
	WasCompressed  bool
	OriginalSize   int
	CompressedSize int

	// CompressionRatio is the ratio of compressed size to original size (compressed / original)
	CompressionRatio float64
}

type MessageQueueImpl 

type MessageQueueImpl struct {
	// contains filtered or unexported fields
}

MessageQueueImpl implements MessageQueue interface using AMQP.

func New 

func New(fs ...MessageQueueImplOpt) (func() error, *MessageQueueImpl)

New creates a new MessageQueueImpl.

func (*MessageQueueImpl) Clone 

func (t *MessageQueueImpl) Clone() (func() error, msgqueue.MessageQueue)

func (*MessageQueueImpl) IsReady 

func (t *MessageQueueImpl) IsReady() bool

func (*MessageQueueImpl) RegisterTenant 

func (t *MessageQueueImpl) RegisterTenant(ctx context.Context, tenantId string) error

func (*MessageQueueImpl) SendMessage 

func (t *MessageQueueImpl) SendMessage(ctx context.Context, q msgqueue.Queue, msg *msgqueue.Message) error

func (*MessageQueueImpl) SetQOS 

func (t *MessageQueueImpl) SetQOS(prefetchCount int)

func (*MessageQueueImpl) Subscribe 

func (t *MessageQueueImpl) Subscribe(
	q msgqueue.Queue,
	preAck msgqueue.AckHook,
	postAck msgqueue.AckHook,
) (func() error, error)

Subscribe subscribes to the msg queue.

type MessageQueueImplOpt 

type MessageQueueImplOpt func(*MessageQueueImplOpts)

func WithDeadLetterBackoff 

func WithDeadLetterBackoff(backoff time.Duration) MessageQueueImplOpt

func WithDisableTenantExchangePubs 

func WithDisableTenantExchangePubs(disable bool) MessageQueueImplOpt

func WithGzipCompression added in v0.73.35 

func WithGzipCompression(enabled bool, threshold int) MessageQueueImplOpt

func WithLogger 

func WithLogger(l *zerolog.Logger) MessageQueueImplOpt

func WithMaxPubChannels added in v0.73.30 

func WithMaxPubChannels(maxConns int32) MessageQueueImplOpt

func WithMaxSubChannels added in v0.73.30 

func WithMaxSubChannels(maxConns int32) MessageQueueImplOpt

func WithMessageRejection added in v0.73.46 

func WithMessageRejection(enabled bool, maxDeathCount int) MessageQueueImplOpt

func WithQos 

func WithQos(qos int) MessageQueueImplOpt

func WithURL 

func WithURL(url string) MessageQueueImplOpt

type MessageQueueImplOpts 

type MessageQueueImplOpts struct {
	// contains filtered or unexported fields
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.