nsqio go-diskqueue issues

nsqio / go-diskqueue

A Go package providing a filesystem-backed FIFO queue

MIT License

460 stars 103 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Close() may cause data lose

#44 trash-boy opened 7 months ago
1
Eof edge case fix

#43 jonasfreyr opened 9 months ago
0
Consistent EOF error when reading immediately after write rolls files

#42 jonasfreyr opened 9 months ago
1
check current file against maxBytesPerFile

#41 mreiferson opened 2 years ago
2
Peek multiple

#40 baryluk opened 2 years ago
1
new release with PeekChan?

#39 baryluk closed 2 years ago
1
.bad files are created when r/w operations happen alternately until queue file is rolled

#38 lootek opened 2 years ago
1
Added test for reproduction of rolling failure

#37 lootek closed 1 year ago
1
tag new release

#36 ploxiln closed 2 years ago
4
GitHub actions fixup

#35 ploxiln closed 2 years ago
0
switch to next file before maxBytesPerFile is reached

#34 ploxiln closed 2 years ago
3
CI: switch from Travis-CI to GitHub Actions

#33 ploxiln closed 2 years ago
2
Inaccurate depth count after readError on "current" file

#32 kev1n80 closed 2 years ago
3
avoid corruption when metadata is inconsistent (writePos vs write file size)

#31 fazalmajid closed 3 years ago
1
maxBytesPerFile acts like minBytesPerFile

#30 kev1n80 closed 2 years ago
1
Inaccurate depth count after readError on "current" file

#29 kev1n80 closed 2 years ago
4
Possible data loss and/or corruption if disk queue metadata is out of sync

#28 fazalmajid closed 3 years ago
3
Configurable total size limit and delete old data when exceeded

#27 leonzz opened 3 years ago
5
an extra read after we finish reading a file

#26 xianxueniao150 closed 3 years ago
1
Added linter config for non-checked error block.

#25 yusufpapurcu closed 3 years ago
3
Add PeekChan function

#24 StoneYunZhao closed 2 years ago
6
proper handling of maxBytesPerFile for reads

#23 mreiferson closed 3 years ago
2
add minMsgSize log info

#22 wziww closed 3 years ago
1
diskqueue: support a callback when the disk queue is empty

#21 jehiah opened 3 years ago
1
format code and handle err

#20 Howie59 closed 3 years ago
0
asynchronous persistence

#19 Chaiyq closed 3 years ago
3
Asynchronous persistence

#18 Chaiyq closed 4 years ago
2
Asynchronous persistence

#17 Chaiyq closed 4 years ago
0
asynchronous

#16 Chaiyq closed 4 years ago
1
maxBytesPerFile read check off-by-one

#15 xkeyideal closed 3 years ago
5
maxBytesPerFile read check off-by-one

#14 xkeyideal closed 4 years ago
3
it'll be better if supports async delete interface

#13 vinllen closed 2 years ago
0
fix blocking Depth() call on the closed queue

#12 mgurevin closed 4 years ago
6
synchronized Depth call

#11 ploxiln closed 4 years ago
2
change dq.Depth() to request & response model

#10 SwanSpouse closed 4 years ago
3
Support go modules

#9 jehiah closed 4 years ago
1
write to next file if writePos == maxBytesPerFile

#8 SwanSpouse closed 4 years ago
2
change ReadChan to return receive-only chan

#7 bitpeng closed 4 years ago
3
add peek function

#6 xiezhenye closed 2 years ago
7
fix go test

#5 qinhao closed 6 years ago
0
Licensing: MIT?

#4 bangert closed 6 years ago
3
confused about the depth field assignment way when retrieveMetaData()

#3 carbin-gun closed 6 years ago
1
make New() take nsq-like log func instead of Logger

#2 ploxiln closed 6 years ago
3
Files marked .bad after "Too many open files" read error

#1 rdingwall opened 7 years ago
3