nsqio / go-diskqueue

A Go package providing a filesystem-backed FIFO queue
MIT License
464 stars 103 forks source link

avoid corruption when metadata is inconsistent (writePos vs write file size) #31

Closed fazalmajid closed 3 years ago

fazalmajid commented 3 years ago

…ue was not synced on previous shutdown

Example: if nsqd was forcibly killed before it could complete sync of all the diskqueues' metadata files

mreiferson commented 3 years ago

LGTM, thanks!