queue

package

v0.0.16 Latest Latest Go to latest Published: Jul 1, 2016 License: GPL-3.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

func Drop(queue string) error

Drop drops queue and all it's items

func Get(queue, _id string) (interface{}, error)

Get returns item from queue without removing from queue

func Init(file string)

Init is a main entry point for package

func Length(queue string) uint64

Length returns queue length

func Push(queue string, data interface{}) (err error)

Push adds item to queue

func Remove(queue string, _id string) error

Remove removes item from queue by provided string _id property

func Unshift(queue string) (interface{}, error)

Unshift returns item from queue with FIFO algorythm

This section is empty.