proxy.golang.org : github.com/Sora233/pipeline/v2
Pipeline is a go library that helps you build pipelines without worrying about channel management and concurrency. It contains common fan-in and fan-out operations as well as useful utility funcs for batch processing and scaling. If you have another common use case you would like to see covered by this package, please (open a feature request) https://github.com/deliveryhero/pipeline/issues. * (How to run a pipeline until the container is killed) https://github.com/deliveryhero/pipeline#PipelineShutsDownWhenContainerIsKilled * (How to shut down a pipeline when there is a error) https://github.com/deliveryhero/pipeline#PipelineShutsDownOnError * (How to shut down a pipeline after it has finished processing a batch of data) https://github.com/deliveryhero/pipeline#PipelineShutsDownWhenInputChannelIsClosed The following example shows how you can shutdown a pipeline gracefully when it receives an error message This example demonstrates a pipline that runs until the os / container the pipline is running in kills it The following example demonstrates a pipeline that naturally finishes its run when the input channel is closed
Registry
-
Source
- Documentation
- JSON
purl: pkg:golang/github.com/%21sora233/pipeline/v2
License: MIT
Latest release: about 3 years ago
First release: about 3 years ago
Namespace: github.com/Sora233/pipeline
Stars: 0 on GitHub
Forks: 0 on GitHub
See more repository details: repos.ecosyste.ms
Last synced: 1 day ago