gitea/vendor/gitea.com/lunny/levelqueue
Lunny Xiao 3bdce82ce9
upgrade levelqueue to 0.1.0 ()
..
.drone.yml upgrade levelqueue to 0.1.0 ()
.gitignore upgrade levelqueue to 0.1.0 ()
LICENSE upgrade levelqueue to 0.1.0 ()
README.md upgrade levelqueue to 0.1.0 ()
error.go upgrade levelqueue to 0.1.0 ()
go.mod upgrade levelqueue to 0.1.0 ()
go.sum upgrade levelqueue to 0.1.0 ()
queue.go upgrade levelqueue to 0.1.0 ()

README.md

levelqueue

Level queue is a simple queue golang library base on go-leveldb.

Build Status

Installation

go get gitea.com/lunny/levelqueue

Usage

queue, err := levelqueue.Open("./queue")

err = queue.RPush([]byte("test"))

// pop an element from left of the queue
data, err = queue.LPop()

// if handle success, element will be pop, otherwise it will be keep
queue.LHandle(func(dt []byte) error{
    return nil
})