pipeline

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: May 12, 2026 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PipelineAppendStep

func PipelineAppendStep(file *os.File, s PipelineStep) error

Types

type Pipeline

type Pipeline struct {
	// contains filtered or unexported fields
}

func NewPipeline

func NewPipeline(filename string) *Pipeline

func (*Pipeline) Run

func (p *Pipeline) Run(ctx context.Context, outputChan chan<- *PipelineResult)

type PipelineResult

type PipelineResult struct {
	// contains filtered or unexported fields
}

func NewPipelineResultError

func NewPipelineResultError(id int, err error) *PipelineResult

func NewPipelineResultOutput

func NewPipelineResultOutput(id int, output interfaces.Output) *PipelineResult

func (*PipelineResult) GetError

func (p *PipelineResult) GetError() error

func (*PipelineResult) GetId

func (p *PipelineResult) GetId() int

func (*PipelineResult) GetOutput

func (p *PipelineResult) GetOutput() interfaces.Output

func (*PipelineResult) IsError

func (p *PipelineResult) IsError() bool

type PipelineStep

type PipelineStep interface {
	UnRaw() (executor.RunCommand, error)
	GetMethod() types.CommandType
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL