- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 103 for multierror (0.18 sec)
-
pkg/test/framework/config.go
// See the License for the specific language governing permissions and // limitations under the License. package framework import ( "context" "fmt" "strings" "github.com/hashicorp/go-multierror" "go.uber.org/atomic" "golang.org/x/sync/errgroup" "istio.io/istio/pkg/test" "istio.io/istio/pkg/test/framework/components/cluster" "istio.io/istio/pkg/test/framework/components/istioctl"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/config/validation/validation.go
} if len(rule.Issuer) == 0 { errs = multierror.Append(errs, errors.New("issuer must be set")) } for _, audience := range rule.Audiences { if len(audience) == 0 { errs = multierror.Append(errs, errors.New("audience must be non-empty string")) } } if len(rule.JwksUri) != 0 { if _, err := security.ParseJwksURI(rule.JwksUri); err != nil { errs = multierror.Append(errs, err) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:33 UTC 2024 - 107.2K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
if err == nil { _, _ = fmt.Fprintf(c.OutOrStdout(), "%v.%v:\n%v\n", podName, podNamespace, resp) } else { errs = multierror.Append(fmt.Errorf("%v.%v: %v", podName, podNamespace, err)) } } if err := multierror.Flatten(errs.ErrorOrNil()); err != nil { return err } return nil }, ValidArgsFunction: completion.ValidPodsNameArgs(ctx), }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 22K bytes - Viewed (0) -
pkg/test/kube/util.go
// See the License for the specific language governing permissions and // limitations under the License. package kube import ( "context" "fmt" "time" "github.com/hashicorp/go-multierror" corev1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/client-go/kubernetes" istioKube "istio.io/istio/pkg/kube" "istio.io/istio/pkg/slices"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 04 22:47:52 UTC 2023 - 9.4K bytes - Viewed (0) -
pkg/config/validation/agent/extensionprovider.go
// limitations under the License. package agent import ( "fmt" "net/url" "strconv" "strings" envoytypev3 "github.com/envoyproxy/go-control-plane/envoy/type/v3" "github.com/hashicorp/go-multierror" meshconfig "istio.io/api/mesh/v1alpha1" "istio.io/istio/pkg/util/sets" ) func validateExtensionProviderService(service string) error { if service == "" { return fmt.Errorf("service must not be empty")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 11K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
// limitations under the License. package multicluster import ( "bytes" "crypto/sha256" "fmt" "time" "github.com/hashicorp/go-multierror" "go.uber.org/atomic" corev1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/types" "k8s.io/client-go/kubernetes" "k8s.io/client-go/rest" "istio.io/istio/pilot/pkg/features" "istio.io/istio/pkg/cluster"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
} else { mu.Lock() multiErr = multierror.Append(multiErr, err) mu.Unlock() } } else { fmt.Fprintf(cmd.OutOrStdout(), "waypoint %v/%v deleted\n", namespace, name) } }(name) } wg.Wait() return multiErr.ErrorOrNil() } func labelNamespaceWithWaypoint(kubeClient kube.CLIClient, ns string) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 15:59:33 UTC 2024 - 16.4K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/instance.go
// See the License for the specific language governing permissions and // limitations under the License. package kube import ( "context" "fmt" "io" "time" "github.com/hashicorp/go-multierror" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "istio.io/istio/pkg/config/protocol" "istio.io/istio/pkg/test" echoClient "istio.io/istio/pkg/test/echo"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 16 18:55:23 UTC 2023 - 9K bytes - Viewed (0) -
pilot/pkg/config/file/store.go
limitations under the License. */ package file import ( "bufio" "bytes" "crypto/sha256" "encoding/json" "errors" "fmt" "io" "strings" "sync" "github.com/hashicorp/go-multierror" yamlv3 "gopkg.in/yaml.v3" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/serializer"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 17:36:47 UTC 2024 - 18.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/endpointslice.go
var err *multierror.Error var endpoints []*v1.EndpointSlice if filtered { endpoints = esc.slices.List(ns, klabels.Everything()) } else { endpoints = esc.slices.ListUnfiltered(ns, klabels.Everything()) } log.Debugf("initializing %d endpointslices", len(endpoints)) for _, s := range endpoints { err = multierror.Append(err, esc.onEvent(nil, s, model.EventAdd)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 16.9K bytes - Viewed (0)