- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for gatewayNames (0.24 sec)
-
pilot/pkg/networking/core/route/route_test.go
return out } gatewayNames := sets.New("some-gateway") t.Run("for virtual service", func(t *testing.T) { g := NewWithT(t) cg := core.NewConfigGenTest(t, core.TestOptions{}) t.Setenv("ISTIO_DEFAULT_REQUEST_TIMEOUT", "0ms") routes, err := route.BuildHTTPRoutesForVirtualService(node(cg), virtualServicePlain, serviceRegistry, nil, 8080, gatewayNames, route.RouteOptions{})
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 88.1K bytes - Viewed (0) -
pkg/config/analysis/analyzers/gateway/certificate.go
if currentServer.Tls == nil || server.Tls == nil { continue } if haveSameCertificate(currentServer.Tls, server.Tls) { gatewayNames := []string{currentGatewayFullName.String(), gatewayFullName.String()} message := msg.NewGatewayDuplicateCertificate(currentResource, gatewayNames) if line, ok := util.ErrorLine(currentResource, util.MetadataName); ok { message.Line = line }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 01 01:34:15 UTC 2023 - 4.9K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route.go
hashByDestination, gatewayNames, opts); r != nil { out = append(out, r) } catchall = true } else { for _, match := range http.Match { if r := translateRoute(node, http, match, listenPort, virtualService, serviceRegistry, hashByDestination, gatewayNames, opts); r != nil { out = append(out, r)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 14:12:39 UTC 2024 - 56.1K bytes - Viewed (0) -
pilot/pkg/networking/core/gateway.go
} return portMatch } func isGatewayMatch(gateway string, gatewayNames []string) bool { // if there's no gateway predicate, gatewayMatch is true; otherwise we match against the gateways for this workload if len(gatewayNames) == 0 { return true } if len(gatewayNames) > 0 { for _, gatewayName := range gatewayNames { if gatewayName == gateway { return true } } } return false
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 06 04:44:06 UTC 2024 - 46.4K bytes - Viewed (0) -
pilot/pkg/networking/core/route/route_internal_test.go
} }) } } func TestSourceMatchHTTP(t *testing.T) { type args struct { match *networking.HTTPMatchRequest proxyLabels labels.Instance gatewayNames sets.String proxyNamespace string } tests := []struct { name string args args want bool }{ { "source namespace match", args{ match: &networking.HTTPMatchRequest{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 11 02:47:57 UTC 2024 - 18.2K bytes - Viewed (0) -
pkg/config/validation/validation.go
} func validateGatewayNames(gatewayNames []string, gatewaySemantics bool) (errs Validation) { for _, gatewayName := range gatewayNames { parts := strings.SplitN(gatewayName, "/", 2) if len(parts) != 2 { if strings.Contains(gatewayName, ".") { // Legacy FQDN style parts := strings.Split(gatewayName, ".") recommended := fmt.Sprintf("%s/%s", parts[1], parts[0])
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 04:03:33 UTC 2024 - 107.2K bytes - Viewed (0) -
pkg/config/gateway/kube/gatewayapi.go
) // IsInternalGatewayReference returns true if gatewayName is referencing the internal // Istio Gateway corresponding to a Kubernetes Gateway API gateway. func IsInternalGatewayReference(gatewayName string) bool { parts := strings.SplitN(gatewayName, "/", 2) if len(parts) == 2 { gatewayName = parts[1] } return strings.Contains(gatewayName, fmt.Sprintf("-%s-", constants.KubernetesGatewayName)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 05 01:28:52 UTC 2023 - 1.3K bytes - Viewed (0) -
pilot/pkg/model/gateway.go
s.Name, gatewayName) } } if s.Port == nil { // Should be rejected in validation, this is an extra check log.Debugf("invalid server without port: %q", gatewayName) RecordRejectedConfig(gatewayName) continue } sanitizeServerHostNamespace(s, gatewayConfig.Namespace) gatewayNameForServer[s] = gatewayName
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 26K bytes - Viewed (0) -
pilot/pkg/model/policyattachment.go
} return targetRefs } func (p WorkloadPolicyMatcher) ShouldAttachPolicy(kind config.GroupVersionKind, policyName types.NamespacedName, policy TargetablePolicy) bool { gatewayName, isGatewayAPI := workloadGatewayName(p.WorkloadLabels) targetRefs := GetTargetRefs(policy) // non-gateway: use selector if !isGatewayAPI { // if targetRef is specified, ignore the policy altogether
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 4.9K bytes - Viewed (0) -
pilot/pkg/model/push_context_test.go
wantHosts: []string{"rule2gw.com", "rule3gw.com"}, gateway: gatewayName, }, { proxyNs: "test2", wantHosts: []string{"rule2gw.com", "rule3gw.com"}, gateway: gatewayName, }, { proxyNs: "ns1", wantHosts: []string{"rule2gw.com", "rule3gw.com"}, gateway: gatewayName, }, { proxyNs: "random", wantHosts: []string{"rule3gw.com"},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 95.3K bytes - Viewed (0)