Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisQueue ¶
type RedisQueue struct {
// contains filtered or unexported fields
}
func NewRedisQueue ¶
func NewRedisQueue(pool *redis.Pool) *RedisQueue
func (*RedisQueue) Pop ¶
func (r *RedisQueue) Pop() ([]byte, error)
func (*RedisQueue) Push ¶
func (r *RedisQueue) Push(bytes []byte) error
func (*RedisQueue) Size ¶
func (r *RedisQueue) Size() (uint64, error)
Click to show internal directories.
Click to hide internal directories.