A minimal yet powerful framework for building concurrent steaming data pipelines in Golang.
Informally, a pipeline is a series of stages connected by channels, where each stage is a group of goroutines running the same function.
GoDoc is available here.