- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 21 for portNums (0.33 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
pkg/proxy/ipvs/proxier.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
pkg/printers/internalversion/printers.go
list := []string{} max := 3 more := false count := 0 for _, port := range ports { if len(list) < max { portNum := "*" if port.Port != nil { portNum = strconv.Itoa(int(*port.Port)) } else if port.Name != nil { portNum = *port.Name } list = append(list, portNum) } else if len(list) == max { more = true } count++ } return listWithMoreString(list, more, count, max)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 128.3K bytes - Viewed (0)