A lightweight stream processing library for Go.
go-streams
provides a simple and concise DSL to build data pipelines.
Wiki In computing, a pipeline, also known as a data pipeline, is a set of data processing elements connected in series, where the output of one element is the input of the next one. The elements of a pipeline are often executed in parallel or in time-sliced fashion. Some amount of buffer storage is often inserted between elements.
Building blocks:
Implemented Flows (flow package):
Supported Connectors:
Usage samples are available in the examples directory.
Licensed under the MIT License.