README ¶ Q Q is a simple persistent message/task queue. It is written in Golang. It has the following features: Message confirmation and retry Message persistent Messages in Q are very safe. They exist until the consumer confirms clearly, otherwise messages would be recycled and added back to queue again. Expand ▾ Collapse ▴ Documentation ¶ Index ¶ type Queue func NewQueue(path string) (*Queue, error) func NewQueueWithRetryLimit(path string, limit int) (*Queue, error) func (q *Queue) Close() func (q *Queue) Confirm(key string) error func (q *Queue) Dequeue(timeout int64) (string, string, error) func (q *Queue) Drop() func (q *Queue) Enqueue(data string) error func (q *Queue) Peek() (string, error) func (q *Queue) Status() map[string]interface{} Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type Queue ¶ type Queue struct { Path string `json:"path"` // contains filtered or unexported fields } func NewQueue ¶ func NewQueue(path string) (*Queue, error) func NewQueueWithRetryLimit ¶ func NewQueueWithRetryLimit(path string, limit int) (*Queue, error) func (*Queue) Close ¶ func (q *Queue) Close() func (*Queue) Confirm ¶ func (q *Queue) Confirm(key string) error func (*Queue) Dequeue ¶ func (q *Queue) Dequeue(timeout int64) (string, string, error) func (*Queue) Drop ¶ func (q *Queue) Drop() func (*Queue) Enqueue ¶ func (q *Queue) Enqueue(data string) error func (*Queue) Peek ¶ func (q *Queue) Peek() (string, error) func (*Queue) Status ¶ func (q *Queue) Status() map[string]interface{} Source Files ¶ View all Source files queue.go Directories ¶ Show internal Expand all Path Synopsis qserver Click to show internal directories. Click to hide internal directories.