Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Payload ¶
type Payload interface { Clone() Payload MarkAsProcessed() }
Payload is implemented by values that can be sent through a pipeline
type Pipeline ¶
type Pipeline struct {
// contains filtered or unexported fields
}
func New ¶
func New(stages ...StageRunner) *Pipeline
type ProcessorFunc ¶
type StageParams ¶
type StageRunner ¶
type StageRunner interface {
Run(context.Context, StageParams)
}
func Broadcast ¶
func Broadcast(procs ...Processor) StageRunner
func DynamicWorkerPool ¶
func DynamicWorkerPool(proc Processor, maxWorkers int) StageRunner
func FIFO ¶
func FIFO(proc Processor) StageRunner
func FixedWorkerPool ¶
func FixedWorkerPool(proc Processor, numWorkers int) StageRunner
Click to show internal directories.
Click to hide internal directories.