pipeline

package

v1.8.1-community Latest Latest Go to latest Published: Mar 11, 2025 License: Apache-2.0 Imports: 26 Imported by: 1

Details

View Source

const (
	StageIngest    = "ingest"
	StageTransform = "transform"
	StageExtract   = "extract"
	StageEncode    = "encode"
	StageWrite     = "write"
)

interface definitions of pipeline components

This section is empty.

func StartFLPInProcess(cfg *config.ConfigFileStruct, in chan config.GenericMap) error

StartFLPInProcess is an entry point to start the whole FLP / pipeline processing from imported code

type Error struct {
	StageName string
	// contains filtered or unexported fields
}

Error wraps any error caused by a wrong formation of the pipeline

func (e *Error) Error() string

func (e *Error) Unwrap() error

type Pipeline struct {
	IsRunning bool

	Metrics *operational.Metrics
	// contains filtered or unexported fields
}

Pipeline manager

func NewPipeline(cfg *config.ConfigFileStruct) (*Pipeline, error)

NewPipeline defines the pipeline elements

func (p *Pipeline) IsAlive() error

func (p *Pipeline) IsReady() error

func (p *Pipeline) Run()