Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 33 for portNums (0.26 sec)

  1. 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)
  2. 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)
  3. pkg/controller/endpoint/endpoints_controller.go

    		} else {
    			for i := range service.Spec.Ports {
    				servicePort := &service.Spec.Ports[i]
    				portNum, err := podutil.FindPort(pod, servicePort)
    				if err != nil {
    					logger.V(4).Info("Failed to find port for service", "service", klog.KObj(service), "error", err)
    					continue
    				}
    				epp := endpointPortFromServicePort(servicePort, portNum)
    
    				var readyEps, notReadyEps int
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/controller.go

    				svcPort, f := modelService.Ports.Get(port.Name)
    				if !f {
    					return nil, fmt.Errorf("failed to get svc port for %v", port.Name)
    				}
    
    				var portNum int
    				if len(proxy.Metadata.PodPorts) > 0 {
    					var err error
    					portNum, err = findPortFromMetadata(port, proxy.Metadata.PodPorts)
    					if err != nil {
    						return nil, fmt.Errorf("failed to find target port for %v: %v", proxy.ID, err)
    					}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  5. pkg/registry/core/service/storage/storage.go

    	if portNum, err := strconv.ParseInt(portStr, 10, 64); err == nil {
    		obj, err := r.Get(ctx, svcName, &metav1.GetOptions{})
    		if err != nil {
    			return nil, nil, err
    		}
    		svc := obj.(*api.Service)
    		found := false
    		for _, svcPort := range svc.Spec.Ports {
    			if int64(svcPort.Port) == portNum {
    				// use the declared port's name
    				portStr = svcPort.Name
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 13:09:33 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  6. pkg/apis/core/v1/defaults_test.go

    	hostPortNum := s2.Containers[0].Ports[0].HostPort
    	if hostPortNum != portNum {
    		t.Errorf("Expected container port to be defaulted, was made %d instead of %d", hostPortNum, portNum)
    	}
    
    	hostPortNum = s2.InitContainers[0].Ports[0].HostPort
    	if hostPortNum != portNum {
    		t.Errorf("Expected container port to be defaulted, was made %d instead of %d", hostPortNum, portNum)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 84.4K bytes
    - Viewed (0)
  7. pilot/pkg/serviceregistry/kube/controller/controller_test.go

    		refs = make([]*corev1.ObjectReference, len(ips))
    	}
    	var portNum int32 = 1001
    	eas := make([]corev1.EndpointAddress, 0)
    	for i, ip := range ips {
    		eas = append(eas, corev1.EndpointAddress{IP: ip, TargetRef: refs[i]})
    	}
    
    	eps := make([]corev1.EndpointPort, 0)
    	for _, name := range portNames {
    		eps = append(eps, corev1.EndpointPort{Name: name, Port: portNum})
    	}
    
    	endpoint := &corev1.Endpoints{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 85K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-v2_gen.go

    				var zb0004 uint8
    				zb0004, err = dc.ReadUint8()
    				if err != nil {
    					err = msgp.WrapError(err, "BitrotChecksumAlgo")
    					return
    				}
    				z.BitrotChecksumAlgo = ChecksumAlgo(zb0004)
    			}
    		case "PartNums":
    			var zb0005 uint32
    			zb0005, err = dc.ReadArrayHeader()
    			if err != nil {
    				err = msgp.WrapError(err, "PartNumbers")
    				return
    			}
    			if cap(z.PartNumbers) >= int(zb0005) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 29 19:14:09 UTC 2024
    - 53.8K bytes
    - Viewed (0)
  9. cmd/testdata/xl-many-parts.meta

    XL2 ��;�$����,�J8���!;o���|>���e���������Type�V2Obj��ID���,�J8���!;o���DDir��z���Jj���i�[�EcAlgo�EcM�EcN�EcBSize��EcIndex�EcDist�	
    L2:
    �CSumAlgo�PartNums�#8	
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sat Sep 02 21:40:38 UTC 2023
    - 808.8K bytes
    - Viewed (0)
  10. pkg/proxy/ipvs/proxier.go

    			continue
    		}
    		portNum, err := strconv.Atoi(port)
    		if err != nil {
    			proxier.logger.Error(err, "Failed to parse endpoint port", "port", port)
    			continue
    		}
    
    		newDest := &utilipvs.RealServer{
    			Address: netutils.ParseIPSloppy(ip),
    			Port:    uint16(portNum),
    			Weight:  1,
    		}
    
    		if curEndpoints.Has(ep) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
Back to top