- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for ServiceTypeLoadBalancer (0.66 sec)
-
pkg/api/v1/service/util_test.go
}) checkExternalPolicyLocal(false, &v1.Service{ Spec: v1.ServiceSpec{ Type: v1.ServiceTypeLoadBalancer, ExternalTrafficPolicy: v1.ServiceExternalTrafficPolicyCluster, }, }) checkExternalPolicyLocal(true, &v1.Service{ Spec: v1.ServiceSpec{ Type: v1.ServiceTypeLoadBalancer, ExternalTrafficPolicy: v1.ServiceExternalTrafficPolicyLocal, }, }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 01 15:18:45 UTC 2023 - 8.8K bytes - Viewed (0) -
pkg/api/service/util_test.go
checkRequestsOnlyLocalTraffic(false, &api.Service{ Spec: api.ServiceSpec{ Type: api.ServiceTypeLoadBalancer, ExternalTrafficPolicy: api.ServiceExternalTrafficPolicyCluster, }, }) checkRequestsOnlyLocalTraffic(true, &api.Service{ Spec: api.ServiceSpec{ Type: api.ServiceTypeLoadBalancer, ExternalTrafficPolicy: api.ServiceExternalTrafficPolicyLocal, }, }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 01 15:18:45 UTC 2023 - 7.6K bytes - Viewed (0) -
pkg/api/service/util.go
return service.Spec.Type == api.ServiceTypeLoadBalancer || service.Spec.Type == api.ServiceTypeNodePort || (service.Spec.Type == api.ServiceTypeClusterIP && len(service.Spec.ExternalIPs) > 0) } // RequestsOnlyLocalTraffic checks if service requests OnlyLocal traffic. func RequestsOnlyLocalTraffic(service *api.Service) bool { if service.Spec.Type != api.ServiceTypeLoadBalancer && service.Spec.Type != api.ServiceTypeNodePort {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 30 15:56:47 UTC 2023 - 3.2K bytes - Viewed (0) -
pkg/api/v1/service/util.go
} } return ipnets, nil } // ExternallyAccessible checks if service is externally accessible. func ExternallyAccessible(service *v1.Service) bool { return service.Spec.Type == v1.ServiceTypeLoadBalancer || service.Spec.Type == v1.ServiceTypeNodePort || (service.Spec.Type == v1.ServiceTypeClusterIP && len(service.Spec.ExternalIPs) > 0) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 30 15:56:47 UTC 2023 - 3.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/proxy.go
svc, err := services.Services(namespace).Get(id) if err != nil { return nil, err } switch { case svc.Spec.Type == v1.ServiceTypeClusterIP, svc.Spec.Type == v1.ServiceTypeLoadBalancer, svc.Spec.Type == v1.ServiceTypeNodePort: // these are fine default: return nil, fmt.Errorf("unsupported service type %q", svc.Spec.Type) } svcPort, err := findServicePort(svc, port) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 5.6K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/context.go
svc.Attributes.ClusterExternalAddresses.ForEach(func(c cluster.ID, externalIPs []string) { foundExternal.InsertAll(externalIPs...) }) } else if corev1.ServiceType(svc.Attributes.Type) == corev1.ServiceTypeLoadBalancer { if !foundPending.Contains(g) { warnings = append(warnings, fmt.Sprintf("address pending for hostname %q", g)) foundPending.Insert(g) } } } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 18:33:02 UTC 2024 - 6.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/conversion.go
portMap[uint32(p.Port)] = uint32(p.NodePort) } istioService.Attributes.ClusterExternalPorts = map[cluster.ID]map[uint32]uint32{clusterID: portMap} // address mappings will be done elsewhere case corev1.ServiceTypeLoadBalancer: if len(svc.Status.LoadBalancer.Ingress) > 0 { var lbAddrs []string for _, ingress := range svc.Status.LoadBalancer.Ingress { if len(ingress.IP) > 0 { lbAddrs = append(lbAddrs, ingress.IP)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 9.4K bytes - Viewed (0)