Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

pipeline

package

Go to main page

Versions in this module

v1

v1.0.0

Jul 18, 2023

Changes in this version

+ func InputsFromFiles(files []string) func() (PipelineEntryInfo, io.ReadCloser, error)

+ func ListPipelineSteps() []func() Step

+ func RegisterPipelineStep(op string, step func() Step)

+ func Run(ctx *PipelineContext) error

+ type DefaultPipelineEntryInfo struct

+ Name string

+ func (pinfo DefaultPipelineEntryInfo) GetName() string

+ type ForkStep struct

+ Steps map[string]Pipeline

+ func (ForkStep) Help()

+ func (ForkStep) Name() string

+ func (fork ForkStep) Flush(ctx *PipelineContext) error

+ func (fork ForkStep) Run(ctx *PipelineContext) error

+ type Pipeline []Step

+ func (p *Pipeline) UnmarshalJSON(in []byte) error

+ func (p *Pipeline) UnmarshalYAML(in []byte) error

+ type PipelineContext struct

+ CurrentStep int

+ EntryLogger func(*PipelineContext, map[string]any)

+ Env map[string]string

+ Err chan error

+ ErrorLogger func(*PipelineContext, error)

+ Graph *lpg.Graph

+ GraphOwner *PipelineContext

+ InfoLogger func(*PipelineContext, map[string]any)

+ NextInput func() (PipelineEntryInfo, io.ReadCloser, error)

+ Properties map[string]interface{}

+ Roots []*lpg.Node

+ Steps []Step

+ Wait sync.WaitGroup

+ func NewContext(lsctx *ls.Context, env map[string]string, pipeline Pipeline, ...) *PipelineContext

+ func (ctx *PipelineContext) FlushNext() error

+ func (ctx *PipelineContext) HasNext() bool

+ func (ctx *PipelineContext) Next() error

+ func (ctx *PipelineContext) SetGraph(g *lpg.Graph) *PipelineContext

+ type PipelineEntryInfo interface

+ GetName func() string

+ type PipelineError struct

+ Step int

+ Wrapped error

+ func (e PipelineError) Error() string

+ func (e PipelineError) Unwrap() error

+ type ReadGraphStep struct

+ Format string

+ func (ReadGraphStep) Flush(*PipelineContext) error

+ func (ReadGraphStep) Help()

+ func (ReadGraphStep) Name() string

+ func (rd ReadGraphStep) Run(pipeline *PipelineContext) error

+ type Step interface

+ Flush func(*PipelineContext) error

+ Name func() string

+ Run func(*PipelineContext) error

+ func ReadPipeline(file string) ([]Step, error)

+ func UnmarshalPipeline(stepMarshals []stepMarshal) ([]Step, error)

+ type StepFunc func(*PipelineContext) error

+ func (f StepFunc) Run(ctx *PipelineContext) error

+ type UniqueStep struct

+ Labels []string

+ func (UniqueStep) Flush(*PipelineContext) error

+ func (UniqueStep) Help()

+ func (UniqueStep) Name() string

+ func (rd UniqueStep) Run(pipeline *PipelineContext) error

v1.0.0-beta22

Feb 9, 2023

v1.0.0-beta21

Feb 8, 2023

v1.0.0-beta20

Jan 17, 2023

v1.0.0-beta19

Dec 16, 2022

v1.0.0-beta17

Oct 20, 2022

v1.0.0-beta16

Sep 15, 2022

v1.0.0-beta-18

Nov 8, 2022