pipeline

Documentation

Index

• type Pipeline
  • func NewPipeline(connManager *sender.ConnectionManager, outputChan chan message.Message) *Pipeline
  • func (p *Pipeline) Start()
  • func (p *Pipeline) Stop()
• type Provider
  • func NewProvider(numberOfPipelines int, connManager *sender.ConnectionManager, ...) Provider

Types

type Pipeline

type Pipeline struct {
	InputChan chan message.Message
	// contains filtered or unexported fields
}

Pipeline processes and sends messages to the backend

func NewPipeline

func NewPipeline(connManager *sender.ConnectionManager, outputChan chan message.Message) *Pipeline

NewPipeline returns a new Pipeline

func (*Pipeline) Start

func (p *Pipeline) Start()

Start launches the pipeline

func (*Pipeline) Stop

func (p *Pipeline) Stop()

Stop stops the pipeline

type Provider

type Provider interface {
	Start()
	Stop()
	NextPipelineChan() chan message.Message
}

Provider provides message channels

func NewProvider

func NewProvider(numberOfPipelines int, connManager *sender.ConnectionManager, outputChan chan message.Message) Provider

NewProvider returns a new Provider