mq

Documentation

Index

• type MessageQueue
  • func New(redis *redis.Pool, maxRetries int) MessageQueue
• type MsgArgs
• type QueueArgs
  • func (q *QueueArgs) Publish(topic string, msg string) error
  • func (q *QueueArgs) Subscribe(topic string, processes int, handler func(data string))

Types

type MessageQueue

type MessageQueue interface {
	Publish(topic string, msg string) error
	Subscribe(topic string, processes int, handler func(msg string))
}

func New

func New(redis *redis.Pool, maxRetries int) MessageQueue

type MsgArgs

type MsgArgs struct {
	Msg   string `json:"msg"`
	Retry int    `json:"retry"`
}

type QueueArgs

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

func (*QueueArgs) Publish

func (q *QueueArgs) Publish(topic string, msg string) error

func (*QueueArgs) Subscribe

func (q *QueueArgs) Subscribe(topic string, processes int, handler func(data string))