redis

package
v1.8.10 Latest Latest
Warning

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

 Go to latest Published: Jan 23, 2026 License: GPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Destroy 

func Destroy(messageQueue *MessageQueue)

Types

type MessageQueue 

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

func New 

func New(address string, userName string, password string, db int, opts ...Option) *MessageQueue

func (*MessageQueue) Publish 

func (messageQueue *MessageQueue) Publish(topic string, event *data_protocol.CloudEvent) error

func (*MessageQueue) Subscribe 

func (messageQueue *MessageQueue) Subscribe(group string, topic string, handler common.MessageHandler) error

func (*MessageQueue) UnSubscribe 

func (messageQueue *MessageQueue) UnSubscribe(group string, topic string) error

type Option added in v1.1.10 

type Option func(options *Options)

func WithConsumerNum added in v1.1.10 

func WithConsumerNum(consumerNum int) Option

func WithInFlightCount added in v1.1.25 

func WithInFlightCount(inFlightCount int) Option

func WithMaxLen added in v1.1.10 

func WithMaxLen(maxLen int64) Option

func WithVisibilityAgainSec added in v1.1.25 

func WithVisibilityAgainSec(visibilityAgainSec int) Option

type Options added in v1.1.10 

type Options struct {
	MaxLen             int64
	ConsumerNum        int
	VisibilityAgainSec int
	InFlightCount      int
}

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.