in internal/handler/cache.go [105:122]
func (c *CacheHandler) createOperationsAsync(ctx context.Context, ops []*v1alpha1.Operation) error {
wg := sync.WaitGroup{}
errChan := make(chan error, len(ops))
for _, op := range ops {
wg.Add(1)
go func() {
defer wg.Done()
errChan <- c.client.Create(ctx, op)
}()
}
wg.Wait()
close(errChan)
var errs error
for err := range errChan {
errs = errors.Join(errs, err)
}
return errs
}