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

v0

v0.8.3

Jun 23, 2015

Changes in this version

+ var ErrFailed = errors.New("pfs: pipeline failed")

+ func WaitPipeline(pipelineDir, pipeline, commit string) error

type Pipeline

+ func (p *Pipeline) Fail() error

v0.8.2

Jun 17, 2015

Changes in this version

+ var ErrArgCount = errors.New("pfs: illegal argument count")

+ var ErrCancelled = errors.New("pfs: cancelled")

+ var ErrUnkownKeyword = errors.New("pfs: unknown keyword")

v0.8.1

Jun 15, 2015

Changes in this version

+ var ArgCount = errors.New("Illegal argument count.")

+ var Cancelled = errors.New("cancelled")

+ func RunPipelines(pipelineDir, inRepo, outRepo, commit, branch, shard string) error

+ type Pipeline struct

+ func NewPipeline(name, dataRepo, outRepo, commit, branch, shard string) *Pipeline

+ func (p *Pipeline) Cancel() error

+ func (p *Pipeline) Finish() error

+ func (p *Pipeline) Image(image string) error

+ func (p *Pipeline) Input(name string) error

+ func (p *Pipeline) Run(cmd []string) error

+ func (p *Pipeline) RunPachFile(r io.Reader) error

+ func (p *Pipeline) Shuffle(dir string) error

+ func (p *Pipeline) Start() error

+ type Runner struct

+ func NewRunner(pipelineDir, inRepo, outPrefix, commit, branch, shard string) *Runner

+ func (r *Runner) Cancel() error

+ func (r *Runner) Run() error