Versions in this module Expand all Collapse all v1 v1.0.2 Aug 31, 2021 v1.0.1 Oct 26, 2018 Changes in this version + const KEY_JOB_POOL + const PREFIX_JOB_BUCKET + const PREFIX_READY_QUEUE + type Client struct + Conn redis.Conn + Database int + Host string + Password string + Port string + func (p *Client) BPop(topic string, timeout int) (*Message, error) + func (p *Client) Init() error + func (p *Client) Pop(topic string) (*Message, error) + func (p *Client) Push(message Message, delayTime int, readyMaxLifetime int) (bool, error) + func (p *Client) Remove(id string) (bool, error) + type Message struct + Body string + ID string + Topic string + func (p *Message) Valid() bool