pipeline

Documentation

Index

• type Pipeline
  • func NewPipeline(outputChan chan *message.Message, processingRules []*config.ProcessingRule, ...) *Pipeline
  • func (p *Pipeline) Flush(ctx context.Context)
  • func (p *Pipeline) Start()
  • func (p *Pipeline) Stop()
• type Provider
  • func NewProvider(numberOfPipelines int, auditor auditor.Auditor, ...) Provider
  • func NewServerlessProvider(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 *config.Endpoints, destinationsContext *client.DestinationsContext, diagnosticMessageReceiver diagnostic.MessageReceiver, serverless bool, pipelineID int) *Pipeline

NewPipeline returns a new Pipeline

func (*Pipeline) Flush

func (p *Pipeline) Flush(ctx context.Context)

Flush flushes synchronously the processor and sender managed by this 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
	// Flush flushes all pipeline contained in this Provider
	Flush(ctx context.Context)
}

Provider provides message channels

func NewProvider

func NewProvider(numberOfPipelines int, auditor auditor.Auditor, diagnosticMessageReceiver diagnostic.MessageReceiver, processingRules []*config.ProcessingRule, endpoints *config.Endpoints, destinationsContext *client.DestinationsContext) Provider

NewProvider returns a new Provider

func NewServerlessProvider

func NewServerlessProvider(numberOfPipelines int, auditor auditor.Auditor, processingRules []*config.ProcessingRule, endpoints *config.Endpoints, destinationsContext *client.DestinationsContext) Provider

NewServerlessProvider returns a new Provider in serverless mode