- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 45 for internalTrafficPolicy (0.31 sec)
-
pkg/proxy/topology_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 26.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/conversion.go
externalName = svc.Spec.ExternalName if features.EnableExternalNameAlias { resolution = model.Alias } else { resolution = model.DNSLB } } if svc.Spec.InternalTrafficPolicy != nil && *svc.Spec.InternalTrafficPolicy == corev1.ServiceInternalTrafficPolicyLocal { nodeLocal = true } if svc.Spec.ClusterIP == corev1.ClusterIPNone { // headless services should not be load balanced
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 9.4K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
Selector: map[string]string{"foo": "bar"}, Ports: []v1.ServicePort{{Name: "", TargetPort: intstr.FromInt32(80), Protocol: v1.ProtocolTCP}}, }, } if tc.internalTrafficPolicy != nil { svc.Spec.InternalTrafficPolicy = tc.internalTrafficPolicy } fp.OnServiceAdd(svc) // Add initial endpoint slice endpointSlice := &discovery.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0) -
pkg/proxy/iptables/proxier_test.go
Selector: map[string]string{"foo": "bar"}, Ports: []v1.ServicePort{{Name: "", Port: 80, Protocol: v1.ProtocolTCP}}, }, } if tc.internalTrafficPolicy != nil { svc.Spec.InternalTrafficPolicy = tc.internalTrafficPolicy } fp.OnServiceAdd(svc) endpointSlice := &discovery.EndpointSlice{ ObjectMeta: metav1.ObjectMeta{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 249.9K bytes - Viewed (0) -
pkg/apis/core/v1/defaults_test.go
name: "must set default internalTrafficPolicy", expectedInternalTrafficPolicy: &cluster, svc: v1.Service{}, }, { name: "must not set default internalTrafficPolicy when it's cluster", expectedInternalTrafficPolicy: &cluster, svc: v1.Service{ Spec: v1.ServiceSpec{ InternalTrafficPolicy: &cluster, }, }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 84.4K bytes - Viewed (0) -
pkg/apis/core/v1/defaults.go
} if obj.Spec.InternalTrafficPolicy == nil { if obj.Spec.Type == v1.ServiceTypeNodePort || obj.Spec.Type == v1.ServiceTypeLoadBalancer || obj.Spec.Type == v1.ServiceTypeClusterIP { serviceInternalTrafficPolicyCluster := v1.ServiceInternalTrafficPolicyCluster obj.Spec.InternalTrafficPolicy = &serviceInternalTrafficPolicyCluster } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 19 22:24:15 UTC 2024 - 14.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/services.go
workloadapi.LoadBalancing_REGION, workloadapi.LoadBalancing_ZONE, workloadapi.LoadBalancing_SUBZONE, }, Mode: workloadapi.LoadBalancing_FAILOVER, } } if itp := svc.Spec.InternalTrafficPolicy; itp != nil && *itp == v1.ServiceInternalTrafficPolicyLocal { lb = &workloadapi.LoadBalancing{ // Only allow endpoints on the same node. RoutingPreference: []workloadapi.LoadBalancing_Scope{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 12:29:55 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/registry/core/service/storage/storage.go
normalizeClusterIPs(After{service}, Before{nil}) // Set ipFamilies and ipFamilyPolicy if needed. r.defaultOnReadIPFamilies(service) // We unintentionally defaulted internalTrafficPolicy when it's not needed // for the ExternalName type. It's too late to change the field in storage, // but we can drop the field when read. defaultOnReadInternalTrafficPolicy(service) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 13:09:33 UTC 2024 - 22.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/conversion_test.go
Namespace: namespace, }, Spec: corev1.ServiceSpec{ Ports: []corev1.ServicePort{ { Name: "http", Port: 80, Protocol: corev1.ProtocolTCP, }, }, InternalTrafficPolicy: &local, }, } service := ConvertService(svc, domainSuffix, clusterID, nil) if service == nil { t.Fatalf("could not convert service") } if !service.Attributes.NodeLocal {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
localTrafficDSR := service.Spec.ExternalTrafficPolicy == v1.ServiceExternalTrafficPolicyLocal var internalTrafficLocal bool if service.Spec.InternalTrafficPolicy != nil { internalTrafficLocal = *service.Spec.InternalTrafficPolicy == v1.ServiceInternalTrafficPolicyLocal } hcnImpl := proxier.hcn err := hcnImpl.DsrSupported() if err != nil { preserveDIP = false localTrafficDSR = false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0)