umq

Documentation

Index

• type IUMq
• type RedisListPub
  • func NewRedisListQueue(ctx context.Context, redisDb *dbs.RedisDb, timeout time.Duration) *RedisListPub
  • func (q *RedisListPub) Dequeue(ctx context.Context) (string, []byte, error)
  • func (q *RedisListPub) Publish(ctx context.Context, topic string, msg string) error
  • func (q *RedisListPub) Subscribe(ctx context.Context, topics ...string) error
  • func (q *RedisListPub) UnSubscribe(ctx context.Context, topics ...string) error
• type RedisPub
  • func NewRedisQueue(ctx context.Context, redisDb *dbs.RedisDb) *RedisPub
  • func (q *RedisPub) Dequeue(ctx context.Context) (string, []byte, error)
  • func (q *RedisPub) Publish(ctx context.Context, topic string, msg string) error
  • func (q *RedisPub) Subscribe(ctx context.Context, topics ...string) error
  • func (q *RedisPub) UnSubscribe(ctx context.Context, topics ...string) error

Types

type IUMq

type IUMq interface {
	// Subscribe 订阅
	Subscribe(ctx context.Context, topics ...string) error
	// UnSubscribe 取消订阅
	UnSubscribe(ctx context.Context, topics ...string) error
	// Publish 发布
	Publish(ctx context.Context, topic string, msg string) error
	// Dequeue 获取消息
	Dequeue(ctx context.Context) (string, []byte, error)
}

type RedisListPub

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

func NewRedisListQueue

func NewRedisListQueue(ctx context.Context, redisDb *dbs.RedisDb, timeout time.Duration) *RedisListPub

func (*RedisListPub) Dequeue

func (q *RedisListPub) Dequeue(ctx context.Context) (string, []byte, error)

func (*RedisListPub) Publish

func (q *RedisListPub) Publish(ctx context.Context, topic string, msg string) error

func (*RedisListPub) Subscribe

func (q *RedisListPub) Subscribe(ctx context.Context, topics ...string) error

func (*RedisListPub) UnSubscribe

func (q *RedisListPub) UnSubscribe(ctx context.Context, topics ...string) error

type RedisPub

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

func NewRedisQueue

func NewRedisQueue(ctx context.Context, redisDb *dbs.RedisDb) *RedisPub

func (*RedisPub) Dequeue

func (q *RedisPub) Dequeue(ctx context.Context) (string, []byte, error)

func (*RedisPub) Publish

func (q *RedisPub) Publish(ctx context.Context, topic string, msg string) error

func (*RedisPub) Subscribe

func (q *RedisPub) Subscribe(ctx context.Context, topics ...string) error

func (*RedisPub) UnSubscribe

func (q *RedisPub) UnSubscribe(ctx context.Context, topics ...string) error