proxy.golang.org : github.com/rickb777/boltqueue
Package boltqueue provides a persistent priority queue based on BoltDB (https://github.com/boltdb/bolt) The PQueue type represents a priority queue. Messages may be inserted into the queue at a numeric priority. Higher numbered priorities take precedence over lower numbered ones. Messages are dequeued following priority order, then time ordering, with the oldest messages of the highest priority emerging first. There is no practical limit on the number of priorities, but a smaller number will typically give better performance than a larger number. The IChan type represents an unbounded channel with one priority, backed by a PQueue. As with ordinary channels, messages are inserted into one end and received from the other end in the same order. The size of the channel's buffer is limited only by space on the fiing system. The sending end provides a choice: messages can be directly inserted into the channel using the Send() and SendString() methods. Or they can be channel-communicated using SendEnd() to obtain a normal channel. The latter is a nicer abstraction but requires one extra goroutine. If you care more about performance, use Send() and SendString() instead. You cannot use both methods on the same IChan (it will panic if you do). This is to keep shutdown behaviour predictable.
Registry
-
Source
- Documentation
- JSON
purl: pkg:golang/github.com/rickb777/boltqueue
License: MIT
Latest release: 12 days ago
First release: about 4 years ago
Namespace: github.com/rickb777
Stars: 0 on GitHub
Forks: 0 on GitHub
See more repository details: repos.ecosyste.ms
Last synced: 11 days ago