queueredis

package module

v0.4.1 Latest Latest Go to latest Published: Mar 17, 2023 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Queue is the Redis based implementation of blobqueue.Queue interface

func New(client *redis.Client, key string) *Queue

New returns a new Redis queue. The `key` parameter gives the key under which the queue will be stored in Redis.

func (q Queue) Empty() error

Empty implements `Queue` interface. It deletes all elements of the queue.

func (q Queue) Len() (int, error)

Len implements `Queue` interface. It returns the length of the Redis list.

func (q Queue) List() (ret [][]byte, err error)

List implements `Queue` interface. It returns all the elements of the queue.

func (q Queue) Pop() ([]byte, error)

Pop implements `Queue` interface. It removes and returns the last elem of the Redis list.

func (q Queue) Push(val []byte) error

Push implements `Queue` interface. It appends an item at the end of Redis list.

func (q Queue) Shift() ([]byte, error)

Shift implements `Queue` interface. It removes and returns the first elem of the Redis list.

func (q Queue) Unshift(val []byte) error

Unshift implements `Queue` interface. It inserts an item at the beggining of Redis list.