pipeline

Documentation

Index

• type Pipeline
  • func NewPipeline(factories []component.Factory) *Pipeline
  • func (p *Pipeline) Close()

Types

type Pipeline

type Pipeline struct {
	// contains filtered or unexported fields
}

Pipeline contains an array of worker pools of components.

func NewPipeline

func NewPipeline(factories []component.Factory) *Pipeline

NewPipeline creates a new Pipeline. It uses factories to spawn workers and push them to the worker pool.

The output channel for a pool is the input channel for the next pool. The input channel for the first component is nil. The first component Handle function won't be called so it should not be implemented.

func (*Pipeline) Close

func (p *Pipeline) Close()

Close broadcast a terminate signal to all pools, wait for all gorutines to finish and release associated resources