delayqueue

Documentation

Index

• type Config
• type DealFunc
• type DelayQueue
  • func New(config Config) (queue DelayQueue, err error)
• type QueueByRedis
  • func (q *QueueByRedis) Consumer(dealFunc DealFunc)
  • func (q *QueueByRedis) Producer(msg string, expireTime int64) (err error)
  • func (q *QueueByRedis) Stop()

Types

type Config

type Config struct {
	Drive    string       `yaml:"drive"`    // 驱动 redis
	Name     string       `yaml:"name"`     // 队列名字
	RedisCfg redis.Config `yaml:"redisCfg"` //
}

type DealFunc

type DealFunc func(msg string) error

type DelayQueue

type DelayQueue interface {
	Producer(msg string, expireTime int64) error
	Consumer(dealFunc DealFunc)
}

func New

func New(config Config) (queue DelayQueue, err error)

type QueueByRedis

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

func (*QueueByRedis) Consumer

func (q *QueueByRedis) Consumer(dealFunc DealFunc)

func (*QueueByRedis) Producer

func (q *QueueByRedis) Producer(msg string, expireTime int64) (err error)

func (*QueueByRedis) Stop

func (q *QueueByRedis) Stop()