processes

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

type ProcessController interface {
	Steps() (n int64)
	Units() (n int64)
	Start(ctx context.Context) (results <-chan Result)
	Abort(timeout time.Duration) (err error)
}

type Result struct {
	StepNo   int64
	StepNum  int64
	StepName string
	UnitNo   int64
	UnitNum  int64
	Data     interface{}
	Error    error
}

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

type Unit interface {
	Handle(ctx context.Context) (result interface{}, err error)
}