proxy.golang.org : 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.
Registry
-
Source
- Documentation
- JSON
purl: pkg:golang/github.com/lytics/inflight
License: MIT
Latest release: over 1 year ago
First release: over 3 years ago
Namespace: github.com/lytics
Stars: 3 on GitHub
Forks: 0 on GitHub
See more repository details: repos.ecosyste.ms
Last synced: 3 months ago