Merge pull request #38 from ccremer/unnamed

Add new anonymous pipeline that just executes functions

Author: ccremer

simple.go

@@ -0,0 +1,29 @@
+package pipeline
+
+import (
+	"context"
+	"reflect"
+	"runtime"
+	"strings"
+)
+
+// NewAnonymous creates a pipeline from the given anonymous functions.
+// This is meant to quickly set up a Pipeline that executes error-prone functions in a fail-first fashion.
+// The context allows to carry over values.
+//
+// Note: You may want to use Pipeline.WithOptions(DisableErrorWrapping) to suppress function names as step names in errors.
+func NewAnonymous(funcs ...func(ctx context.Context) error) *Pipeline {
+	steps := make([]Step, len(funcs))
+	for i := 0; i < len(funcs); i++ {
+		fn := funcs[i]
+		steps[i] = NewStepFromFunc(getFunctionName(fn), func(ctx context.Context) error {
+			return fn(ctx)
+		})
+	}
+	return NewPipeline().WithSteps(steps...)
+}
+
+func getFunctionName(temp interface{}) string {
+	strs := strings.Split(runtime.FuncForPC(reflect.ValueOf(temp).Pointer()).Name(), ".")
+	return strs[len(strs)-1]
+}

simple_test.go

@@ -0,0 +1,19 @@
+package pipeline
+
+import (
+	"context"
+	"fmt"
+)
+
+func ExampleNewAnonymous() {
+	p := NewAnonymous(
+		func(ctx context.Context) error {
+			return nil
+		},
+		func(ctx context.Context) error {
+			return fmt.Errorf("fail")
+		}).WithOptions(DisableErrorWrapping)
+	result := p.Run()
+	fmt.Printf("Name: %s, Err: %v", result.Name(), result.Err())
+	// Output: Name: func2, Err: fail
+}