github.com/lytics/inflight
Package inflight provides primitives(data strutures) for managing inflight operations that are being processed in a distributed system. CallGroup spawns off a group of operations for each call to Add() and calls the CallGroupCompletion func when the last operation have completed. The CallGroupCompletion func can be thought of as a finalizer where one can gather errors and/or results from the function calls. OpQueue is a thread-safe duplicate operation suppression queue, that combines duplicate operations (queue entires) into sets that will be dequeued togather.
Ecosystem
proxy.golang.org
proxy.golang.org
Latest Release
over 2 years ago
v0.0.0-20231208151346-8d7d896506db
over 2 years ago
Versions
3
3
Loading...
Readme
Loading...
Links
| Registry | proxy.golang.org |
| Source | Repository |
| Docs | Documentation |
| JSON API | View JSON |
| CodeMeta | codemeta.json |
Package Details
| PURL |
pkg:golang/github.com/lytics/inflight
spec |
| License | MIT |
| Namespace | github.com/lytics |
| First Release | over 4 years ago |
| Last Synced | 23 days ago |
Keywords
lio-dependency
lio-dependency
Repository
| Stars | 3 on GitHub |
| Forks | 0 on GitHub |
Rankings on proxy.golang.org
Overall
Top 8.2%