- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 91 for multiError (0.18 sec)
-
pkg/config/validation/agent/validation.go
errs = multierror.Append(errs, multierror.Prefix(err, "invalid proxy admin port:")) } if err := ValidateControlPlaneAuthPolicy(config.ControlPlaneAuthPolicy); err != nil { errs = multierror.Append(errs, multierror.Prefix(err, "invalid authentication policy:")) } if err := ValidatePort(int(config.StatusPort)); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 30.9K bytes - Viewed (0) -
pilot/pkg/security/authz/builder/extauthz.go
port, err := parsePort(config.Port) if err != nil { errs = multierror.Append(errs, err) } hostname, cluster, err := model.LookupCluster(push, config.Service, port) if err != nil { model.IncLookupClusterFailures("authz") errs = multierror.Append(errs, err) } status, err := parseStatusOnError(config.StatusOnError) if err != nil { errs = multierror.Append(errs, err) } if config.PathPrefix != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/util/istiomultierror/util.go
package istiomultierror import ( "fmt" "strings" "github.com/hashicorp/go-multierror" ) // MultiErrorFormat provides a format for multierrors. This matches the default format, but if there // is only one error we will not expand to multiple lines. func MultiErrorFormat() multierror.ErrorFormatFunc { return func(es []error) string { if len(es) == 1 { return es[0].Error() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Mar 09 05:07:21 UTC 2024 - 1.3K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
warning, err := v.validateResource(*istioNamespace, defaultNamespace, &un, writer) if err != nil { errs = multierror.Append(errs, multierror.Prefix(err, fmt.Sprintf("%s/%s/%s:", un.GetKind(), un.GetNamespace(), un.GetName()))) } if warning != nil { warnings = multierror.Append(warnings, multierror.Prefix(warning, fmt.Sprintf("%s/%s/%s:", un.GetKind(), un.GetNamespace(), un.GetName()))) } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 22 17:58:52 UTC 2024 - 15K bytes - Viewed (0) -
pilot/pkg/model/validation.go
if len(s.Hostname) == 0 { errs = multierror.Append(errs, fmt.Errorf("invalid empty hostname")) } parts := strings.Split(string(s.Hostname), ".") for _, part := range parts { if !labels.IsDNS1123Label(part) { errs = multierror.Append(errs, fmt.Errorf("invalid hostname part: %q", part)) } } // Require at least one port if len(s.Ports) == 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 3.5K bytes - Viewed (0) -
pkg/test/framework/components/istio/cleanup.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5K bytes - Viewed (0) -
pilot/pkg/security/authz/builder/logger.go
package builder import ( "fmt" "strings" "github.com/hashicorp/go-multierror" "istio.io/istio/pkg/log" "istio.io/istio/pkg/util/istiomultierror" ) var authzLog = log.RegisterScope("authorization", "Istio Authorization Policy") type AuthzLogger struct { debugMsg []string errMsg *multierror.Error } func (al *AuthzLogger) AppendDebugf(format string, args ...any) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 1.5K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/executor.go
// See the License for the specific language governing permissions and // limitations under the License. package forwarder import ( "context" "fmt" "github.com/hashicorp/go-multierror" "go.uber.org/atomic" "golang.org/x/sync/semaphore" ) const ( maxConcurrencyPerForward = 20 ) type executor struct { totalRequests *atomic.Uint64 activeRequests *atomic.Uint64
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 10 18:09:08 UTC 2022 - 2K bytes - Viewed (0) -
tests/integration/pilot/revisioned_upgrade_test.go
// enableDefaultInjection takes a namespaces and relabels it such that it will have a default sidecar injected func enableDefaultInjection(ns namespace.Instance) error { var errs *multierror.Error errs = multierror.Append(errs, ns.SetLabel("istio-injection", "enabled")) errs = multierror.Append(errs, ns.RemoveLabel("istio.io/rev")) return errs.ErrorOrNil()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 4.9K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/kube.go
var clusters cluster.Clusters for i, cfg := range configs { c, err := buildCluster(cfg, allClusters) if err != nil { errs = multierror.Append(errs, fmt.Errorf("failed building cluster from config %d: %v", i, err)) continue } if _, ok := allClusters[c.Name()]; ok { errs = multierror.Append(errs, fmt.Errorf("more than one cluster named %s", c.Name())) continue } allClusters[c.Name()] = c
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5.1K bytes - Viewed (0)