pipeline

Documentation

Index

• type Pipeline
  • func NewPipeline(outputChan chan *message.Message, processingRules []*config.ProcessingRule, ...) *Pipeline
  • func (p *Pipeline) Start()
  • func (p *Pipeline) Stop()
• type Provider
  • func NewProvider(numberOfPipelines int, auditor *auditor.Auditor, ...) 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(outputChan chan *message.Message, processingRules []*config.ProcessingRule, endpoints *client.Endpoints, destinationsContext *client.DestinationsContext) *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, auditor *auditor.Auditor, processingRules []*config.ProcessingRule, endpoints *client.Endpoints, destinationsContext *client.DestinationsContext) Provider

NewProvider returns a new Provider