Skip to content

fix some bugs and new api added

Latest
Compare
Choose a tag to compare
@jhunters jhunters released this 22 Jul 06:33
· 20 commits to master since this release

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 {