Skip to content

Releases: jhunters/bigqueue

fix some bugs and new api added

22 Jul 06:33
Compare
Choose a tag to compare

new api added
func (q *FileQueue) PeekAll() ([][]byte, []int64, error) {
func (q *FileQueue) PeekPagination(page, pagesize uint64) ([][]byte, []int64, error) {
// Status get status info from current queue
func (q *FileQueue) Status() *QueueFilesStatus {

Add fanout queue supports

21 Sep 05:25
Compare
Choose a tag to compare

fix some bugs and add queue api docs

09 Sep 02:34
Compare
Choose a tag to compare

Fix to correct to work under golang 1.2 and lower compiler

01 Jul 02:11
Compare
Choose a tag to compare