pipe

func ErrorHandler ¶

func ErrorHandler(ctx context.Context, err error) (returns bool)

ErrorHandler is an error handler with error level.

func FatalErrorHandler ¶

func FatalErrorHandler(ctx context.Context, err error) (returns bool)

FatalErrorHandler is an error handler with fatal level.

func GetFanoutName ¶

func GetFanoutName(
	ctx context.Context,
	fn func(InT) ([]OutT, error),
	fnErr func(context.Context, error) bool,
) (
	chan<- InT,
	<-chan OutT,
)

GetFanoutName returns new input(chan<- InT)/output(<-chan OutT) channels that embedded the given 'func(InT) OutT'.

func GetPipeName ¶

func GetPipeName(
	ctx context.Context,
	fn func(InT) (OutT, error),
	fnErr func(context.Context, error) bool,
) (
	chan<- InT,
	<-chan OutT,
)

GetPipeName returns new input(chan<- InT)/output(<-chan OutT) channels that embedded the given 'func(InT) OutT'.

func Init ¶

func Init(ctx context.Context)