mq

Documentation

Index

• type Queue
  • func NewNatsMQ(conn *nats.Conn, subject string) Queue
  • func NewRedisMQ(client *redis.Client, channel string) Queue

Types

type Queue

type Queue interface {
	Publish(ctx context.Context, payload []byte) error
	Subscribe(ctx context.Context, handler func([]byte))
	Close()
}

Queue 消息队列

func NewNatsMQ

func NewNatsMQ(conn *nats.Conn, subject string) Queue

NewNatsMQ 构造函数

func NewRedisMQ

func NewRedisMQ(client *redis.Client, channel string) Queue

NewRedisMQ 构造函数

client 可以使用 *redis.Client 或者 *redis.ClusterClient

当使用ClusterClient时，会采用sharded channel