Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for gatewayNames (0.24 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top