A minimal package to parallelize work and return error, with respect to k8s.io/client-go/util/workqueue
e.g.
ctx, cancel := context.WithCancel(context.Background())
errCh := parallelize.NewErrorChannel()
raw := []int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}
result := make([]int, len(raw))
parallelize.Until(ctx, len(raw), func(index int) {
res, err := addTen(ctx, raw[index]) // addTen returns (10 + input number)
if err != nil {
errCh.SendErrorWithCancel(err, cancel)
return
}
result[index] = res
})
if err := errCh.ReceiveError(); err != nil {
rlog.Error(err, "Running general case", "func", "addTen", "raw", raw)
}
rlog.Info("General case result", "func", "addTen", "raw", raw, "result", result)see more in examples