proxy.golang.org : github.com/alicebob/qr
Package qr is an in process queue with disk based overflow. Element order is not strictly preserved. When everything is fine elements flow over Qr.q. This is a simple channel connecting the producer(s) and the consumer(s). If that channel is full elements are written to the Qr.planb channel. swapout() will write all elements from Qr.planb to disk. It makes a new file every `timeout`. At the same time swapin() will deal with completed files. swapin() will open the oldest file and write the elements to Qr.q. Gob is used to serialize entries; custom types should be registered using gob.Register().
Registry
-
Source
- Documentation
- JSON
purl: pkg:golang/github.com/alicebob/qr
License: MIT
Latest release: over 9 years ago
First release: over 9 years ago
Namespace: github.com/alicebob
Stars: 11 on GitHub
Forks: 2 on GitHub
See more repository details: repos.ecosyste.ms
Last synced: 26 days ago