Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 46 for portMap (0.13 sec)

  1. pilot/pkg/networking/core/envoyfilter/rc_patch.go

    	})
    	// In case the patches cause panic, use the route generated before to reduce the influence.
    	out = routeConfiguration
    	if efw == nil {
    		return out
    	}
    
    	var portMap model.GatewayPortMap
    	if proxy.MergedGateway != nil {
    		portMap = proxy.MergedGateway.PortMap
    	}
    
    	// only merge is applicable for route configuration.
    	for _, rp := range efw.Patches[networking.EnvoyFilter_ROUTE_CONFIGURATION] {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 13K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/envoyfilter/rc_patch_test.go

    					},
    				},
    				rc: &route.RouteConfiguration{Name: "http.8443"},
    				portMap: map[int]sets.Set[int]{
    					8443: {443: {}},
    				},
    			},
    			want: true,
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			if got := routeConfigurationMatch(tt.args.patchContext, tt.args.rc, tt.args.cp, tt.args.portMap); got != tt.want {
    				t.Errorf("routeConfigurationMatch() = %v, want %v", got, tt.want)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 17:09:02 UTC 2024
    - 32.4K bytes
    - Viewed (0)
  3. pkg/proxy/winkernel/hns.go

    		if len(lb.FrontendVIPs) == 0 {
    			// Leave VIP uninitialized
    			id = loadBalancerIdentifier{protocol: uint16(portMap.Protocol), internalPort: portMap.InternalPort, externalPort: portMap.ExternalPort, endpointsHash: hash}
    		} else {
    			id = loadBalancerIdentifier{protocol: uint16(portMap.Protocol), internalPort: portMap.InternalPort, externalPort: portMap.ExternalPort, vip: lb.FrontendVIPs[0], endpointsHash: hash}
    		}
    		loadBalancers[id] = &loadBalancerInfo{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 09 21:21:12 UTC 2023
    - 15K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/serviceentry/conversion_test.go

    					TLSMode:        "istio",
    					Namespace:      "ns1",
    					Locality: model.Locality{
    						ClusterID: cluster.ID(clusterID),
    					},
    				},
    				PortMap: map[string]uint32{
    					"http": 80,
    				},
    			},
    		},
    		{
    			name: "simple - tls mode disabled",
    			wle: config.Config{
    				Meta: config.Meta{
    					Namespace: "ns1",
    				},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 39K bytes
    - Viewed (0)
  5. pilot/pkg/model/service.go

    	// Where the workloadInstance come from, valid values are`Pod` or `WorkloadEntry`
    	Kind     workloadKind      `json:"kind"`
    	Endpoint *IstioEndpoint    `json:"endpoint,omitempty"`
    	PortMap  map[string]uint32 `json:"portMap,omitempty"`
    	// Can only be selected by service entry of DNS type.
    	DNSServiceEntryOnly bool `json:"dnsServiceEntryOnly,omitempty"`
    }
    
    func (instance *WorkloadInstance) CmpOpts() []cmp.Option {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 46.3K bytes
    - Viewed (0)
  6. src/vendor/golang.org/x/net/http/httpproxy/proxy.go

    	}
    }
    
    var portMap = map[string]string{
    	"http":   "80",
    	"https":  "443",
    	"socks5": "1080",
    }
    
    // canonicalAddr returns url.Host but always with a ":port" suffix
    func canonicalAddr(url *url.URL) string {
    	addr := url.Hostname()
    	if v, err := idnaASCII(addr); err == nil {
    		addr = v
    	}
    	port := url.Port()
    	if port == "" {
    		port = portMap[url.Scheme]
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sat Mar 09 00:09:40 UTC 2024
    - 10K bytes
    - Viewed (0)
  7. pilot/pkg/model/endpointshards.go

    // the results by service port number. This is a bit weird, but lets us efficiently construct the format the caller needs.
    func (es *EndpointShards) CopyEndpoints(portMap map[string]int, ports sets.Set[int]) map[int][]*IstioEndpoint {
    	es.RLock()
    	defer es.RUnlock()
    	res := map[int][]*IstioEndpoint{}
    	for _, v := range es.Shards {
    		for _, ep := range v {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  8. pilot/pkg/networking/grpcgen/lds.go

    			ln.RequestedNames.Insert(requestedName)
    
    			// only build the portmap if we aren't filtering this name yet, or if the existing filter is non-empty
    			if hasPort && (!ok || len(ln.Ports) != 0) {
    				if ln.Ports == nil {
    					ln.Ports = map[string]struct{}{}
    				}
    				ln.Ports.Insert(port)
    			} else if !hasPort {
    				// if we didn't have a port, we should clear the portmap
    				ln.Ports = nil
    			}
    			filter[name] = ln
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 22:20:44 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  9. pilot/pkg/serviceregistry/serviceentry/conversion.go

    			// if not port name not match, use the targetPort specified in ServiceEntry
    			// if both not matched, fallback to ServiceEntry port number.
    			var targetPort uint32
    			if port, ok := workloadInstance.PortMap[serviceEntryPort.Name]; ok && port > 0 {
    				targetPort = port
    			} else if serviceEntryPort.TargetPort > 0 {
    				targetPort = serviceEntryPort.TargetPort
    			} else {
    				targetPort = serviceEntryPort.Number
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  10. pilot/pkg/model/gateway.go

    	// clusters to be sent to the workload
    	ContainsAutoPassthroughGateways bool
    
    	// PortMap defines a mapping of targetPorts to the set of Service ports that reference them
    	PortMap GatewayPortMap
    
    	// VerifiedCertificateReferences contains a set of all credentialNames referenced by gateways *in the same namespace as the proxy*.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 26K bytes
    - Viewed (0)
Back to top