Top 7.0% forks on proxy.golang.org
proxy.golang.org : github.com/splunk/pipelines
Package pipelines provides helper functions for constructing concurrent processing pipelines. Each pipeline stage represents a single stage in a parallel computation, with an input channel and an output channel. Generally, pipeline stages have signatures starting with a context and input channel as their first arguments, and returning a channel, as below: The return value from a pipeline stage is referred to as the stage's 'output' channel. Each stage is a non-blocking call which starts one or more goroutines which listen on the input channel and send results to the output channel. Goroutines started by each stage respond to context cancellation or closure of the input channel by closing its output channel and cleaning up all goroutines started. Many pipeline stages take a function as an argument, which transform the input and output in some way. By default, each pipeline starts the minimum number of threads required for its operation, and returns an unbuffered channel. These defaults can be modified by passing the result of WithBuffer or WithPool as optional arguments.
Registry
-
Source
- Documentation
- JSON
purl: pkg:golang/github.com/splunk/pipelines
Keywords:
concurrency
, functional-programming
, go
, golang
, pipelines
License: MIT
Latest release: almost 3 years ago
First release: about 3 years ago
Namespace: github.com/splunk
Stars: 20 on GitHub
Forks: 6 on GitHub
See more repository details: repos.ecosyste.ms
Last synced: 12 days ago