Pack a Go workflow/function into a Unix-style pipeline command.
Wiki
In Unix-like computer operating systems, a pipeline is a mechanism for inter-process communication using message passing. A pipeline is a set of processes chained together by their standard streams, so that the output text of each process (stdout) is passed directly as input (stdin) to the next one.
Use tpack
to write Go applications that act as pipeline commands.
Employ channels, goroutines, regular expressions and more to build powerful concurrent workflows.
See the ETL workflow in the examples folder.
package main
import "github.com/reugn/tpack"
func main() {
tpack.NewPackerStd(tpack.NewProcessor(
doETL,
)).Execute()
}
Test command
cat input.txt | go run *.go 2>/dev/null | wc -l
Licensed under the MIT License.