Diskqueue implement in Golang refer from NSQ diskqueue - View it on GitHub