pipe

README

pipe

Simple library for pipeline building.

Documentation

Index

• func Execute[T any](ctx context.Context, pipeline Pipeline[T], in T) (out T, err error)
• func Parallel[T any](ctx context.Context, pipeline Pipeline[[]T], in []T, jobs int) (out []T, err error)
• type HandlerFunc
  • func ForEach[T any](handle HandlerFunc[T]) HandlerFunc[[]T]
• type Pipeline

Functions

func Execute

func Execute[T any](ctx context.Context, pipeline Pipeline[T], in T) (out T, err error)

Execute starts pipeline processing.

func Parallel

func Parallel[T any](ctx context.Context, pipeline Pipeline[[]T], in []T, jobs int) (out []T, err error)

Parallel distributes 'in' batch between jobs and executes piplene inside of separated routines. Order of results will be same as input.

Types

type HandlerFunc

type HandlerFunc[T any] func(ctx context.Context, in T) (out T, err error)

func ForEach

func ForEach[T any](handle HandlerFunc[T]) HandlerFunc[[]T]

ForEach returns new handler over []T with applied handle function to every element.

type Pipeline

type Pipeline[T any] []HandlerFunc[T]