mq

Documentation

Index

• type MessageQueue
  • func New(c context.Context, redis *redis.Client, maxRetries int) MessageQueue
• type MsgArgs
• type QueueArgs
  • func (q *QueueArgs) Publish(topic string, msg string, delay int64) error
  • func (q *QueueArgs) Subscribe(topic string, processes int, handler func(data string))

Types

type MessageQueue

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

func New

func New(c context.Context, redis *redis.Client, maxRetries int) MessageQueue

type MsgArgs

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

type QueueArgs

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

func (*QueueArgs) Publish

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

func (*QueueArgs) Subscribe

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