pipeline

Documentation

Index

• type Pipelines
  • func NewPipelines(ctx context.Context) *Pipelines
  • func (p *Pipelines) Execute() (context.Context, error)
  • func (p *Pipelines) Register(pipe ...Piper)
• type Piper

Types

type Pipelines

type Pipelines struct {
	Piper []Piper
	Ctx   context.Context
}

func NewPipelines

func NewPipelines(ctx context.Context) *Pipelines

func (*Pipelines) Execute

func (p *Pipelines) Execute() (context.Context, error)

func (*Pipelines) Register

func (p *Pipelines) Register(pipe ...Piper)

Register all build-related pipe implementations in order. nolint:gochecknoglobals

type Piper

type Piper interface {
	fmt.Stringer
	// Run the pipe
	Run(ctx context.Context) error
}

Piper defines a pipe, which can be part of a pipeline (a series of pipes).