Documentation ¶
Index ¶
- func ErrorHandler(ctx context.Context, err error) (returns bool)
- func FatalErrorHandler(ctx context.Context, err error) (returns bool)
- func GetFanoutName(ctx context.Context, fn func(InT) ([]OutT, error), ...) (chan<- InT, <-chan OutT)
- func GetPipeName(ctx context.Context, fn func(InT) (OutT, error), ...) (chan<- InT, <-chan OutT)
- func Init(ctx context.Context)
- type InT
- type NameGetContexter
- type OutT
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ErrorHandler ¶
ErrorHandler is an error handler with error level.
func FatalErrorHandler ¶
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'.
Types ¶
type NameGetContexter ¶
Click to show internal directories.
Click to hide internal directories.