pipeline

Documentation

Index

• type Pipeline
  • func NewPipeline(outputChan chan *message.Payload, processingRules []*config.ProcessingRule, ...) *Pipeline
  • func (p *Pipeline) Flush(ctx context.Context)
  • func (p *Pipeline) Start()
  • func (p *Pipeline) Stop()
• type Provider
  • func NewMockProvider() 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.Payload,
	processingRules []*config.ProcessingRule,
	endpoints *config.Endpoints,
	destinationsContext *client.DestinationsContext,
	diagnosticMessageReceiver diagnostic.MessageReceiver,
	serverless bool,
	pipelineID int,
	status statusinterface.Status,
	hostname hostnameinterface.Component,
	cfg pkgconfigmodel.Reader) *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 NewMockProvider

func NewMockProvider() Provider

NewMockProvider creates a new provider that will not provide any pipelines.

func NewProvider

func NewProvider(numberOfPipelines int, auditor auditor.Auditor, diagnosticMessageReceiver diagnostic.MessageReceiver, processingRules []*config.ProcessingRule, endpoints *config.Endpoints, destinationsContext *client.DestinationsContext, status statusinterface.Status, hostname hostnameinterface.Component, cfg pkgconfigmodel.Reader) Provider

NewProvider returns a new Provider

func NewServerlessProvider

func NewServerlessProvider(numberOfPipelines int, auditor auditor.Auditor, processingRules []*config.ProcessingRule, endpoints *config.Endpoints, destinationsContext *client.DestinationsContext, status statusinterface.Status, hostname hostnameinterface.Component, cfg pkgconfigmodel.Reader) Provider

NewServerlessProvider returns a new Provider in serverless mode