dque
dque copied to clipboard
joncrlsn
dque is a fast, embedded, durable queue for Go
For the sake of discussion, I'm considering adding batch uploads from a queue consumer, but would require a batch read API. Suggested API: ```go // BatchPeek returns a slice of...
I've been trying to figure this out for a while but it's super hard to reproduce. Occasionally, I get the following error: ```go Caused by: error deleting queue segment /tmp/ripple/600f5b80f62ab2ff24e82005/hb-queue/0000000000001.dque....
If input objects share some underlying data structure, they may broken while enqueueing. The patch fix this case. However, enqueue will be much slower than before because of the extra...
Although the current state works great, think about changing DQue as the return of New() to an interface. This makes it much easier for testing purposes. A dummy implementation of...
I took an example_test.go and just run two goroutines one enqueueing consecutive integers, another doing blocking dequeue and just print them from time to time. Segment size 50, then switches...
Hi I get following error if I include following in my go.mod file. `github.com/joncrlsn/dque v2.2.0` The error I get is ``` #12 0.387 go: errors parsing go.mod: #12 0.387 /edge/go.mod:11:2:...
Hi, I was trying a simple program to enqueue and dequeue 10 elements. with segment size 5 its failing with below error main.go and go.mod files attached PS C:\Sai_laptop_backup\workspace\golang\dque_test> .\main.exe...
``` package event import ( "testing" "github.com/davecgh/go-spew/spew" "github.com/joncrlsn/dque" ) func TestName(t *testing.T) { q, err := dque.NewOrOpen("q", ".", 2, func() interface{} { return new(string) }) if err != nil {...
for some reason, load() may fail when we init dque. the lock should be releases that we could reinitialize dque if err := q.lock(); err != nil { return nil,...
