pipeline

package
v0.0.0-...-fb5a1ab Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 20, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddPostFilters 

func AddPostFilters(p *Pipeline)

Types

type Pipeline 

type Pipeline struct {
	obs.PipelineSpec

	Filters []*PipelineFilter
	// contains filtered or unexported fields
}

Pipeline is an adapter between logging API and config generation

func NewPipeline 

func NewPipeline(index int, p obs.PipelineSpec, inputs map[string]helpers.InputComponent, outputs map[string]*output.Output, filters map[string]*filter.InternalFilterSpec, inputSpecs []obs.InputSpec, addPostFilters func(p *Pipeline)) *Pipeline

func (*Pipeline) Elements 

func (o *Pipeline) Elements() []framework.Element

func (*Pipeline) Name 

func (p *Pipeline) Name() string

type PipelineFilter 

type PipelineFilter struct {
	Next []helpers.InputComponent
	// contains filtered or unexported fields
}

PipelineFilter is an adapter between CLF pipeline filter instance and config generation

func NewPipelineFilter 

func NewPipelineFilter(pipelineName, filterRef string, spec filter.InternalFilterSpec, pipeline obs.PipelineSpec) *PipelineFilter

func (*PipelineFilter) AddInputFrom 

func (pf *PipelineFilter) AddInputFrom(n helpers.InputComponent)

func (*PipelineFilter) Element 

func (o *PipelineFilter) Element() framework.Element

func (*PipelineFilter) ID 

func (pf *PipelineFilter) ID() string

func (*PipelineFilter) InputIDs 

func (pf *PipelineFilter) InputIDs() []string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.