Documentation
¶
Overview ¶
Package pipeline provides log processing pipeline functionality
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Pipeline ¶
Pipeline processes and sends messages to the backend
func NewPipeline ¶
func NewPipeline( processingRules []*config.ProcessingRule, endpoints *config.Endpoints, senderImpl sender.PipelineComponent, diagnosticMessageReceiver diagnostic.MessageReceiver, serverlessMeta sender.ServerlessMeta, hostname hostnameinterface.Component, cfg pkgconfigmodel.Reader, compression logscompression.Component, instanceID string, ) *Pipeline
NewPipeline returns a new Pipeline
type Provider ¶
type Provider interface {
Start()
Stop()
NextPipelineChan() chan *message.Message
GetOutputChan() chan *message.Message
NextPipelineChanWithMonitor() (chan *message.Message, *metrics.CapacityMonitor)
// 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, hostname hostnameinterface.Component, cfg pkgconfigmodel.Reader) 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, sink sender.Sink, diagnosticMessageReceiver diagnostic.MessageReceiver, processingRules []*config.ProcessingRule, endpoints *config.Endpoints, destinationsContext *client.DestinationsContext, status statusinterface.Status, hostname hostnameinterface.Component, cfg pkgconfigmodel.Reader, compression logscompression.Component, legacyMode bool, serverless bool, secretsComp secrets.Component, ) Provider
NewProvider returns a new Provider. When secretsComp is backed by a real secrets backend, HTTP destinations will trigger an async API key refresh on 403 responses and retry the payload instead of dropping it. Pass a SecretNoop when no secrets backend is available.
Source Files
Directories