-
Notifications
You must be signed in to change notification settings - Fork 2.9k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
nsqd: consider publicly exporting diskQueue #764
Comments
yea, we probably should |
If there is a chance of #625 (replace diskQueue with a write-ahead log) eventually getting done, it would be kinda funny to have exported the original diskQueue |
Can we get it moved out to it's own repository then, perhaps? |
I don't think #625 should conflict with this. I could be wrong here, but the interface, I'd guess, will stay mostly the same? It's more like, with #625, that diskQueue will be used a little differently by NSQ to promptly store things and give clients more assurance about that, but it shouldn't fundamentally change writing a stream of events to disk. |
What are your thoughts on possibly relocating DiskQueue into it's own external repository? |
That would seem to be the likely path if we do export it. |
Count me in as one other person that's been forking It would be super awesome if |
OK, fine |
see #847 |
@mreiferson Thank you! |
First off, thank you for DiskQueue! It's the best go implementation of a disk-backed channel-esque data structure that I've found!
I have been using it and it's great, but I'm sure you can imagine that hand-applying updates sucks!
Would you please consider making diskQueue publicly exported so it can be used as a "normal" dependency?
In case it is helpful, here is a copy of the ported
DiskQueue
I'm currently using (obviously there is a lot more stuff I ported over, including interfaces and unit-tests, etc):https://gist.github.com/jaytaylor/71ae326116d9d5492250022025a2015a
Also I am curious - is there a way to get the disk queue to delete or clear out the .dat files? I've invoked
.Empty()
which reset the metadata, but the .dat file lives on at the same size as before (even thoughDepth()==0
).The text was updated successfully, but these errors were encountered: