r2dq

README

r2dq

Reliable redis based simple queue

Documentation

Index

• Constants
• Variables
• type Queue
  • func NewQueue(addr string, db int, prefix string) *Queue
  • func (q *Queue) Ack(val string) error
  • func (q *Queue) Close()
  • func (q *Queue) Dequeue() (string, error)
  • func (q *Queue) Len() (int64, error)
  • func (q *Queue) NAck(val string) error
  • func (q *Queue) Purge()
  • func (q *Queue) Queue(value string) error
  • func (q *Queue) StopDequeue()

Constants

const (
	WAITING_QUEUE    = "waitingQueue"
	PROCESSING_QUEUE = "processingQueue"
)

Variables

var (
	ErrNotFound   = errors.New("not found")
	ErrConnClosed = errors.New("connection closed")
)

Types

type Queue

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

func NewQueue

func NewQueue(addr string, db int, prefix string) *Queue

func (*Queue) Ack

func (q *Queue) Ack(val string) error

func (*Queue) Close

func (q *Queue) Close()

func (*Queue) Dequeue

func (q *Queue) Dequeue() (string, error)

func (*Queue) Len

func (q *Queue) Len() (int64, error)

func (*Queue) NAck

func (q *Queue) NAck(val string) error

func (*Queue) Purge

func (q *Queue) Purge()

func (*Queue) Queue

func (q *Queue) Queue(value string) error

func (*Queue) StopDequeue

func (q *Queue) StopDequeue()