fix: add multierr collection
Signed-off-by: nelson.parente <nelson_parente@live.com.pt>
This commit is contained in:
parent
81989e025b
commit
551b4ca9c4
|
@ -32,6 +32,7 @@ import (
|
||||||
|
|
||||||
"cloud.google.com/go/storage"
|
"cloud.google.com/go/storage"
|
||||||
"github.com/google/uuid"
|
"github.com/google/uuid"
|
||||||
|
"go.uber.org/multierr"
|
||||||
"google.golang.org/api/googleapi"
|
"google.golang.org/api/googleapi"
|
||||||
"google.golang.org/api/iterator"
|
"google.golang.org/api/iterator"
|
||||||
"google.golang.org/api/option"
|
"google.golang.org/api/option"
|
||||||
|
@ -490,10 +491,13 @@ func (g *GCPStorage) bulkGet(ctx context.Context, req *bindings.InvokeRequest) (
|
||||||
wg.Wait()
|
wg.Wait()
|
||||||
close(errCh)
|
close(errCh)
|
||||||
|
|
||||||
|
var multiErr error
|
||||||
for err := range errCh {
|
for err := range errCh {
|
||||||
if err != nil {
|
multierr.AppendInto(&multiErr, err)
|
||||||
return nil, err
|
}
|
||||||
}
|
|
||||||
|
if multiErr != nil {
|
||||||
|
return nil, multiErr
|
||||||
}
|
}
|
||||||
|
|
||||||
return &bindings.InvokeResponse{}, nil
|
return &bindings.InvokeResponse{}, nil
|
||||||
|
|
Loading…
Reference in New Issue