redis

package

v1.3.13 Latest Latest Go to latest Published: Oct 31, 2024 License: GPL-3.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func Destroy(messageQueue *MessageQueue)

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

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

func (messageQueue *MessageQueue) Publish(topic string, data string) error

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

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

type Option func(options *Options)

func WithConsumerNum(consumerNum int) Option

func WithMaxLen(maxLen int64) Option

type Options struct {
	MaxLen      int64
	ConsumerNum int
}