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 NewProcessorOnlyProvider(diagnosticMessageReceiver diagnostic.MessageReceiver, ...) 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()
	ReconfigureSDSStandardRules(standardRules []byte) (bool, error)
	ReconfigureSDSAgentConfig(config []byte) (bool, error)
	StopSDSProcessing() error
	NextPipelineChan() chan *message.Message
	GetOutputChan() chan *message.Message
	NextPipelineChanWithMonitor() (chan *message.Message, metrics.PipelineMonitor)
	// 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 NewProcessorOnlyProvider

func NewProcessorOnlyProvider(diagnosticMessageReceiver diagnostic.MessageReceiver, processingRules []*config.ProcessingRule, cfg pkgconfigmodel.Reader, hostname hostnameinterface.Component) Provider

NewProcessorOnlyProvider is used by the logs check subcommand as the feature does not require the functionalities of the log pipeline other then the processor.

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, diagnosticMessageReceiver diagnostic.MessageReceiver, 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