proxy.golang.org : github.com/wcharczuk/go-diskq
Package diskq provides a local filesystem streaming system similar to Kafka. A simplified example might be: Here we both initialize and open for writing a diskq producer. We then push a message into it, randomly assigning it to one of (by default, 3) partitions. We can then consume messages from outside the producing process simply by listening for filesystem write events using consumers.
Registry
-
Source
- Documentation
- JSON
purl: pkg:golang/github.com/wcharczuk/go-diskq
License: MIT
Latest release: 2 months ago
Namespace: github.com/wcharczuk
Stars: 7 on GitHub
Forks: 1 on GitHub
See more repository details: repos.ecosyste.ms
Last synced: 2 months ago