Initial commit

.gitignore

@@ -4,6 +4,7 @@
 *.dll
 *.so
 *.dylib
+.idea
 
 # Test binary, built with `go test -c`
 *.test

pipeline.go

@@ -0,0 +1,9 @@
+package pipeline
+
+type Pipeline[K any] struct {
+	pipelineStepDelegate PipelineStepDelegate[K]
+}
+
+func (t Pipeline[K]) execute(context K) {
+	t.pipelineStepDelegate(context)
+}

pipeline_builder.go

@@ -0,0 +1,24 @@
+package pipeline
+
+type PipelineBuilder[K any] struct {
+	steps []func(next PipelineStepDelegate[K]) PipelineStepDelegate[K]
+}
+
+func (t PipelineBuilder[K]) build() Pipeline[K] {
+	var step PipelineStepDelegate[K] = func(context K) {}
+	for i := len(t.steps) - 1; i >= 0; i-- {
+		step = t.steps[i](step)
+	}
+	return Pipeline[K]{
+		pipelineStepDelegate: step,
+	}
+}
+
+func (t PipelineBuilder[K]) usePipelineStep(step PipelineStep[K]) PipelineBuilder[K] {
+	t.steps = append(t.steps, func(next PipelineStepDelegate[K]) PipelineStepDelegate[K] {
+		return func(context K) {
+			step.execute(context, next)
+		}
+	})
+	return t
+}

pipeline_step.go

@@ -0,0 +1,7 @@
+package pipeline
+
+type PipelineStepDelegate[K any] func(context K)
+
+type PipelineStep[K any] interface {
+	execute(context K, next func(context K))
+}