pipeline

Documentation

Index

• func Merge[T any](ctx context.Context, chs ...chan T) <-chan T
• func Source[In any](ctx context.Context, in []In) (chan In, chan error)
• func Step[In any, Out any](ctx context.Context, chIn <-chan In, ...) (chan Out, chan error)
• type StepOption
  • func WithLimit(l int64) StepOption

Functions

func Merge

func Merge[T any](ctx context.Context, chs ...chan T) <-chan T

func Source

func Source[In any](ctx context.Context, in []In) (chan In, chan error)

func Step

func Step[In any, Out any](
	ctx context.Context,
	chIn <-chan In,
	stepAction *stepaction.StepAction[In, Out],
	opts ...StepOption,
) (chan Out, chan error)

Types

type StepOption

type StepOption func(*stepConfig)

func WithLimit

func WithLimit(l int64) StepOption