Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for portNums (0.16 sec)

  1. pkg/proxy/endpointslicecache_test.go

    		AddressType: discovery.AddressTypeIPv4,
    		Endpoints:   []discovery.Endpoint{},
    	}
    
    	for i, portNum := range portNums {
    		endpointSlice.Ports = append(endpointSlice.Ports, discovery.EndpointPort{
    			Name:     ptr.To(fmt.Sprintf("port-%d", i)),
    			Port:     portNum,
    			Protocol: ptr.To(v1.ProtocolTCP),
    		})
    	}
    
    	for i := 1; i <= numEndpoints; i++ {
    		readyCondition := i%unreadyMod != 0
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:07:21 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  2. pilot/pkg/config/kube/gateway/deploymentcontroller.go

    	svcPorts = append(svcPorts, corev1.ServicePort{
    		Name:        "status-port",
    		Port:        int32(15021),
    		AppProtocol: &tcp,
    	})
    	portNums := sets.New[int32]()
    	for i, l := range gw.Spec.Listeners {
    		if portNums.Contains(int32(l.Port)) {
    			continue
    		}
    		portNums.Insert(int32(l.Port))
    		name := string(l.Name)
    		if name == "" {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 21:43:20 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  3. pilot/pkg/model/gateway.go

    		name = name[len("https."):]
    		// format: https.<port>.<port_name>.<gw name>.<gw namespace>
    		portNums, rest, ok := strings.Cut(name, ".")
    		if !ok {
    			return
    		}
    		portNumber, _ = strconv.Atoi(portNums)
    		portName, rest, ok = strings.Cut(rest, ".")
    		if !ok {
    			return
    		}
    		gwName, gwNs, ok := strings.Cut(rest, ".")
    		if !ok {
    			return
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 26K bytes
    - Viewed (0)
  4. pilot/pkg/model/endpointshards.go

    			var portNum int
    			if ep.LegacyClusterPortKey != 0 {
    				if !ports.Contains(ep.LegacyClusterPortKey) {
    					continue
    				}
    				portNum = ep.LegacyClusterPortKey
    			} else {
    				pn, f := portMap[ep.ServicePortName]
    				if !f {
    					continue
    				}
    				portNum = pn
    			}
    			res[portNum] = append(res[portNum], ep)
    		}
    	}
    	return res
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  5. src/net/http/socks_bundle.go

    	host, port, err := net.SplitHostPort(address)
    	if err != nil {
    		return "", 0, err
    	}
    	portnum, err := strconv.Atoi(port)
    	if err != nil {
    		return "", 0, err
    	}
    	if 1 > portnum || portnum > 0xffff {
    		return "", 0, errors.New("port number out of range " + port)
    	}
    	return host, portnum, nil
    }
    
    // A Command represents a SOCKS command.
    type socksCommand int
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 11 22:42:18 UTC 2023
    - 12.9K bytes
    - Viewed (0)
  6. docs/debugging/xl-meta/main.go

    	names := make([][]string, 0)
    	/// part, verID, file
    	files := make([]map[string][]string, 0)
    	partNums := make(map[int]int)
    	for k, v := range all {
    		for _, file := range v {
    			part := getPartNum(file)
    			partIdx, ok := partNums[part]
    			if !ok {
    				partIdx = len(names)
    				partNums[part] = partIdx
    				names = append(names, nil)
    				files = append(files, make(map[string][]string))
    			}
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 31 14:49:23 UTC 2024
    - 38.5K bytes
    - Viewed (0)
  7. operator/pkg/apis/istio/v1alpha1/validation/validation.go

    			t, ok := p["targetPort"].(float64)
    			if !ok {
    				continue
    			}
    			tp = int(t)
    		}
    
    		rport, ok := p["port"].(float64)
    		if !ok {
    			continue
    		}
    		portnum := int(rport)
    		if tp == 0 && portnum > 1024 {
    			// Target port defaults to port. If its >1024, it is safe.
    			continue
    		}
    		if tp < 1024 {
    			// nolint: lll
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 20:02:28 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  8. cmd/testdata/xl-meta-merge.zip

    ÖzD'¨E<‹ÞÆ-ئEcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDist” ¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘Ñ äªPartASizes‘Ñ ä¤SizeÑ ä¥MTimeÓ ¹ôc â N§MetaSys ¼x-minio-internal-inline-dataÄ true§MetaUsr‚¬content-type¸application/octet-stream¤etagÙ 9fe7a344ef4227d3e537¡vÎeçnÐÄ$•Ä sÉöQð#Ef° ÌS Û|âÓ ¹ôb Îf­Ä ñ.È´ Å Mƒ¤Type ¥V2ObjÞ ¢IDÄ sÉöQð#Ef° ÌS Û|â¤DDirÄ #" ‘³sF"¥ URÄ,C ¦EcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDist” ¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘Ñ äªPartASizes‘Ñ ä¤SizeÑ ä¥MTimeÓ ¹ôb Îf­§MetaSys...
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  9. pilot/pkg/serviceregistry/kube/controller/endpointslice.go

    			for _, port := range slice.Ports {
    				var portNum int32
    				if port.Port != nil {
    					portNum = *port.Port
    				}
    				var portName string
    				if port.Name != nil {
    					portName = *port.Name
    				}
    
    				istioEndpoint := builder.buildIstioEndpoint(a, portNum, portName, discoverabilityPolicy, healthStatus)
    				endpoints = append(endpoints, istioEndpoint)
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  10. pkg/proxy/endpointslicecache.go

    		}
    	}
    
    	return endpointInfoBySP
    }
    
    // addEndpoints adds an Endpoint for each unique endpoint.
    func (cache *EndpointSliceCache) addEndpoints(svcPortName *ServicePortName, portNum int, endpointSet map[string]Endpoint, endpoints []discovery.Endpoint) map[string]Endpoint {
    	if endpointSet == nil {
    		endpointSet = map[string]Endpoint{}
    	}
    
    	// iterate through endpoints to add them to endpointSet.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:07:21 UTC 2024
    - 11.7K bytes
    - Viewed (0)
Back to top