pipeline
pipeline copied to clipboard
Pipeline is a package to build multi-staged concurrent workflows with a centralized logging output.
When I set up concurrent execution for the steps of a stage, I find that program always execute the last step. Looking at the source code, I found closure functions...
I'd like to use pipeline to manage my sequence tasks, in my situation, user can manually kill the task, but pipeline do not export a `Cancel` function.
hello myntra, I make pipeline to support go mod now
Incomplete PR for brainstorming.
Hey there, Thanks for the great library, the Go market really lacked it. Currently I am working on a data processing pipeline which imports data from various sources. This means...
I'm writing this PR for the `go mod` support and dependencies upgrades. The dependencies were upgrade to newer versions, also avoiding possible security risks with some older version of `golang.org/x/sys`.