Documentation ¶
Overview ¶
Package pl implements some Data Pipeline helper functions. Reference: https://medium.com/amboss/applying-modern-go-concurrency-patterns-to-data-pipelines-b3b5327908d4#3a80
See also:
https://www.oreilly.com/library/view/concurrency-in-go/9781491941294/ch04.html#fano_fani https://www.youtube.com/watch?v=f6kdp27TYZs https://www.youtube.com/watch?v=QDDwwePbDtw
Index ¶
- func FromSlice[T any](ctx context.Context, in []T) <-chan T
- func Merge[T any](ctx context.Context, cs ...<-chan T) <-chan T
- func ReadOrDone[T any](ctx context.Context, in <-chan T) <-chan T
- func SendOrDone[T any](ctx context.Context, out chan<- T, v T)
- func Sink[In any](ctx context.Context, maxWorkers int, inputChannel <-chan In, ...) chan error
- func Stage[In any, Out any](ctx context.Context, maxWorkers int, inputChannel <-chan In, ...) (chan Out, chan error)
- func Tee[T any](ctx context.Context, in <-chan T) (<-chan T, <-chan T)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ReadOrDone ¶
func SendOrDone ¶
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.