pipeline

type Action ¶

type Action func(ctx context.ApplicationContext) error

Action is a function that takes a context and returns an error. It is used on Pipers, Defaulters and Publishers, although they are not aware of this generalization.

func Handle(action Action) Action

func Log(title string, next Action) Action

func Maybe(skipper interface{}, next Action) Action

type ErrSkip ¶

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

ErrSkip occurs when a pipe is skipped for some reason.

func Skip(reason string) ErrSkip

func (e ErrSkip) Error() string

type Pipelines ¶

type Pipelines interface {
	Execute() (context.ApplicationContext, error)
	Register(pipe ...Piper)
	// contains filtered or unexported methods
}

func NewPipelines(ctx context.ApplicationContext) Pipelines

type Piper ¶

type Piper interface {
	fmt.Stringer
	Run(ctx context.ApplicationContext) error
}

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

type SkipMemento ¶

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

SkipMemento remembers previous skip errors, so you can return them all at once later.

func (sm *SkipMemento) Evaluate() error

func (sm *SkipMemento) Remember(err error)

func (sm *SkipMemento) Size() int

type Skipper ¶

type Skipper interface {
	// Skip returns true if the Piper should be skipped.
	Skip(ctx context.ApplicationContext) bool
	fmt.Stringer
}

Skipper defines a method to skip an entire Piper.