- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 31 for internalTrafficPolicy (0.74 sec)
-
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) -
pkg/registry/core/service/strategy_test.go
}, ClusterIP: "1.2.3.4", ClusterIPs: []string{"1.2.3.4", "5:6:7::8"}, IPFamilyPolicy: &preferDual, IPFamilies: []api.IPFamily{"IPv4", "IPv6"}, InternalTrafficPolicy: &clusterInternalTrafficPolicy, }, } } func makeValidServicePort(name string, proto api.Protocol, port int32) api.ServicePort { return api.ServicePort{ Name: name, Protocol: proto,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 32.4K bytes - Viewed (0) -
pkg/apis/core/validation/validation_test.go
// that may have allowed internalTrafficPolicy when Type=ExternalName. // This test case ensures we don't break compatibility for internalTrafficPolicy // when Type=ExternalName name: "internalTrafficPolicy field is set when type is ExternalName", tweakSvc: func(s *core.Service) { cluster := core.ServiceInternalTrafficPolicyCluster s.Spec.InternalTrafficPolicy = &cluster
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 857.7K bytes - Viewed (0) -
pkg/apis/core/validation/validation.go
allErrs = append(allErrs, field.Required(field.NewPath("spec").Child("internalTrafficPolicy"), "")) } } if service.Spec.InternalTrafficPolicy != nil && !supportedServiceInternalTrafficPolicy.Has(*service.Spec.InternalTrafficPolicy) { allErrs = append(allErrs, field.NotSupported(field.NewPath("spec").Child("internalTrafficPolicy"), *service.Spec.InternalTrafficPolicy, sets.List(supportedServiceInternalTrafficPolicy))) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 349.5K bytes - Viewed (0) -
pkg/registry/core/service/storage/storage_test.go
t.Errorf("ipFamilies: expected %v, got %v", want, got) } if want, got := fmtInternalTrafficPolicy(exp.Spec.InternalTrafficPolicy), fmtInternalTrafficPolicy(svc.Spec.InternalTrafficPolicy); want != got { t.Errorf("internalTrafficPolicy: expected %v, got %v", want, got) } }) } } // // Scaffolding for create-update-delete tests. Many tests can and should be
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 440.2K bytes - Viewed (0) -
pilot/pkg/model/service.go
// spec.Type Type string // spec.ExternalName ExternalName string // NodeLocal means the proxy will only forward traffic to node local endpoints // spec.InternalTrafficPolicy == Local NodeLocal bool } // DeepCopy creates a deep copy of ServiceAttributes, but skips internal mutexes. func (s *ServiceAttributes) DeepCopy() ServiceAttributes {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
internalTrafficFilterVerdict = fmt.Sprintf("goto %s", rejectChain) externalTrafficFilterVerdict = fmt.Sprintf("goto %s", rejectChain) } else { if !hasInternalEndpoints { // The internalTrafficPolicy is "Local" but there are no local // endpoints. Traffic to the clusterIP will be dropped, but // external traffic may still be accepted. internalTrafficFilterVerdict = "drop"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
externalTrafficFilterTarget = "REJECT" externalTrafficFilterComment = internalTrafficFilterComment } else { if !hasInternalEndpoints { // The internalTrafficPolicy is "Local" but there are no local // endpoints. Traffic to the clusterIP will be dropped, but // external traffic may still be accepted. internalTrafficFilterTarget = "DROP"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0)