message_queue

Documentation

Index

• Variables
• type Client
  • func New() *Client
  • func (client *Client) Consume(ctx context.Context, queueName string, handler func(data []byte) error) error
  • func (client *Client) GetListeners(queueName string) (int, error)
  • func (client *Client) Publish(queueName string, jsonData interface{}) error

Variables

var (
	// ErrQueueNotFound is returned when a queue is not found.
	ErrQueueNotFound = fmt.Errorf("queue not found")
)

Types

type Client

type Client struct {
	RedisClient *redis.Client
}

Client is used to manage key-value pairs in Redis.

func New

func New() *Client

New returns a new key-value client.

func (*Client) Consume

func (client *Client) Consume(ctx context.Context, queueName string, handler func(data []byte) error) error

Consume starts consuming messages from the given queue. It is non-blocking and will run in a separate goroutine.

func (*Client) GetListeners

func (client *Client) GetListeners(queueName string) (int, error)

GetListeners returns the number of listeners for the given queue.

func (*Client) Publish

func (client *Client) Publish(queueName string, jsonData interface{}) error

Publish sends a message to the given queue.