Awesome

Diskqueue: Disk storage Message Queue package refer from NSQ

What is this "Disk Queue"

Diskqueue is a submodule of NSQ which to use Disk to store message queue.

Disclaimer

This is a going project, during I learn the program about NSQ. Until all ToDo item done, please use this under your own risk.

If you really need disk queue, please use NSQ: Diskqueue source code in your production consideration.

Currently Features

Basic Queue handle
One messsage into single file

ToDo Features

Seek handle
- One file store not only one message
- Seek write/read handle
Gracefully handle for file R/W
- Message size validation (min/max message size)

Installation and Usage

Install

go get github.com/kkdai/diskqueue

Usage

Following is sample code:


package main

import (
	"fmt"
    "github.com/kkdai/diskqueue"
)

func main() {

	//Create a disk queue, please note the path must exist
	dq := NewDiskqueue("workqueue", "./test")

	//First put data
	err = dq.Put([]byte("00"))
	//Second data put
	err = dq.Put([]byte("111"))

	//Read data from queue, it is unbuffered channel
	data := <-dq.ReadChan()
	
	//Close this queue
	dq.Close()
}