message_queue

Documentation

Index

• type MessageQueueClient
  • func NewMessageQueueClient(client *redis.Client) *MessageQueueClient
  • func (mq *MessageQueueClient) Options() *redis.Options
  • func (mq *MessageQueueClient) Publish(channel string, message any) error
  • func (mq *MessageQueueClient) Subscribe(ctx context.Context, onMessage func(*redis.Message), channels ...string) (string, error)
  • func (mq *MessageQueueClient) UnSubscribe(subscribeId string)

Types

type MessageQueueClient

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

func NewMessageQueueClient

func NewMessageQueueClient(client *redis.Client) *MessageQueueClient

func (*MessageQueueClient) Options

func (mq *MessageQueueClient) Options() *redis.Options

func (*MessageQueueClient) Publish

func (mq *MessageQueueClient) Publish(channel string, message any) error

func (*MessageQueueClient) Subscribe

func (mq *MessageQueueClient) Subscribe(ctx context.Context, onMessage func(*redis.Message), channels ...string) (string, error)

func (*MessageQueueClient) UnSubscribe

func (mq *MessageQueueClient) UnSubscribe(subscribeId string)