Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for PortNumber (0.19 sec)

  1. pilot/pkg/model/gateway.go

    	pm := GatewayPortMap{}
    	for r, s := range serversByRouteName {
    		portNumber, _, _ := ParseGatewayRDSRouteName(r)
    		if _, f := pm[portNumber]; !f {
    			pm[portNumber] = sets.New[int]()
    		}
    		for _, se := range s {
    			if se.Port == nil {
    				continue
    			}
    			pm[portNumber].Insert(int(se.Port.Number))
    		}
    	}
    	return pm
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 26K bytes
    - Viewed (0)
  2. pilot/pkg/model/gateway_test.go

    	if !hosts.Equals(expectedHosts) {
    		t.Errorf("expected to get: [a.apps.svc.cluster.local,b.apps.svc.cluster.local], got: %s", hosts.String())
    	}
    }
    
    func makeConfig(name, namespace, host, portName, portProtocol string, portNumber uint32, gw string, bind string,
    	mode networking.ServerTLSSettings_TLSmode,
    ) config.Config {
    	c := config.Config{
    		Meta: config.Meta{
    			Name:      name,
    			Namespace: namespace,
    		},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 02:36:23 UTC 2024
    - 9K bytes
    - Viewed (0)
  3. pilot/pkg/config/kube/gateway/deploymentcontroller_test.go

    					},
    				},
    				Spec: k8s.GatewaySpec{
    					GatewayClassName: k8s.ObjectName(features.GatewayAPIDefaultGatewayClass),
    					Listeners: []k8s.Listener{{
    						Name:     "http",
    						Port:     k8s.PortNumber(80),
    						Protocol: k8s.HTTPProtocolType,
    					}},
    				},
    			},
    			objects:                  defaultObjects,
    			discoveryNamespaceFilter: discoveryNamespacesFilter,
    		},
    		{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 21:43:20 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/listener_builder_test.go

    				Context: networking.EnvoyFilter_SIDECAR_OUTBOUND,
    				ObjectTypes: &networking.EnvoyFilter_EnvoyConfigObjectMatch_Listener{
    					Listener: &networking.EnvoyFilter_ListenerMatch{
    						PortNumber: 81,
    					},
    				},
    			},
    			Patch: &networking.EnvoyFilter_Patch{
    				Operation: networking.EnvoyFilter_Patch_REMOVE,
    			},
    		},
    		{
    			ApplyTo: networking.EnvoyFilter_LISTENER,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  5. pilot/pkg/networking/core/envoyfilter/listener_patch.go

    	// FIXME: Ports on a listener can be 0. the API only takes uint32 for ports
    	// We should either make that field in API as a wrapper type or switch to int
    	if lMatch.PortNumber != 0 {
    		sockAddr := listener.Address.GetSocketAddress()
    		if sockAddr == nil || sockAddr.GetPortValue() != lMatch.PortNumber {
    			return false
    		}
    	}
    	return true
    }
    
    // We assume that the parent listener has already been matched
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 17 15:39:29 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  6. pilot/pkg/networking/core/cluster.go

    	sidecarScope := proxy.SidecarScope
    	for _, ingressListener := range sidecarScope.Sidecar.Ingress {
    		// LDS would have setup the inbound clusters
    		// as inbound|portNumber|portName|Hostname[or]SidecarScopeID
    		listenPort := &model.Port{
    			Port:     int(ingressListener.Port.Number),
    			Protocol: protocol.Parse(ingressListener.Port.Protocol),
    			Name:     ingressListener.Port.Name,
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 33K bytes
    - Viewed (0)
  7. pilot/pkg/config/kube/gateway/conversion.go

    	if needMesh {
    		meshResult = convertRules(true)
    	}
    	if needGw {
    		gwResult = convertRules(false)
    	}
    	return meshResult, gwResult
    }
    
    func augmentPortMatch(routes []*istio.HTTPRoute, port k8s.PortNumber) []*istio.HTTPRoute {
    	res := make([]*istio.HTTPRoute, 0, len(routes))
    	for _, r := range routes {
    		r = r.DeepCopy()
    		for _, m := range r.Match {
    			m.Port = uint32(port)
    		}
    		if len(r.Match) == 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  8. pkg/config/analysis/msg/messages.gen.go

    func NewConflictingGateways(r *resource.Instance, gateway string, selector string, portnumber string, hosts string) diag.Message {
    	return diag.NewMessage(
    		ConflictingGateways,
    		r,
    		gateway,
    		selector,
    		portnumber,
    		hosts,
    	)
    }
    
    // NewImageAutoWithoutInjectionWarning returns a new diag.Message based on ImageAutoWithoutInjectionWarning.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 22 10:13:03 UTC 2024
    - 43.2K bytes
    - Viewed (0)
  9. pkg/config/analysis/msg/messages.yaml

        template: "Conflict with gateways %s (workload selector %s, port %s, hosts %v)."
        args:
          - name: gateway
            type: string
          - name: selector
            type: string
          - name: portnumber
            type: string
          - name: hosts
            type: string
    
      - name: "ImageAutoWithoutInjectionWarning"
        code: IST0146
        level: Warning
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 22 10:13:03 UTC 2024
    - 23.5K bytes
    - Viewed (0)
  10. pilot/pkg/networking/core/route/route.go

    	pls []*networking.TrafficPolicy_PortTrafficPolicy,
    ) *networking.LoadBalancerSettings_ConsistentHashLB {
    	if dst.Port != nil {
    		portNumber := dst.GetPort().GetNumber()
    		for _, setting := range pls {
    			number := setting.GetPort().GetNumber()
    			if number == portNumber {
    				return setting.GetLoadBalancer().GetConsistentHash()
    			}
    		}
    	}
    
    	return nil
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue May 14 14:12:39 UTC 2024
    - 56.1K bytes
    - Viewed (0)
Back to top