- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for InternalPolicyLocal (0.53 sec)
-
pkg/proxy/serviceport.go
func (bsvcPortInfo *BaseServicePortInfo) ExternalPolicyLocal() bool { return bsvcPortInfo.externalPolicyLocal } // InternalPolicyLocal is part of ServicePort interface func (bsvcPortInfo *BaseServicePortInfo) InternalPolicyLocal() bool { return bsvcPortInfo.internalPolicyLocal } // HintsAnnotation is part of ServicePort interface. func (bsvcPortInfo *BaseServicePortInfo) HintsAnnotation() string {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 09 08:17:56 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/proxy/topology_test.go
serviceInfo: &BaseServicePortInfo{internalPolicyLocal: true}, endpoints: []Endpoint{}, clusterEndpoints: nil, localEndpoints: sets.New[string](), }, { name: "internalTrafficPolicy: Local, but all endpoints are remote", serviceInfo: &BaseServicePortInfo{internalPolicyLocal: true}, endpoints: []Endpoint{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 26.6K bytes - Viewed (0) -
pkg/api/v1/service/util.go
if !ExternallyAccessible(service) { return false } return service.Spec.ExternalTrafficPolicy == v1.ServiceExternalTrafficPolicyLocal } // InternalPolicyLocal checks if service has ITP = Local. func InternalPolicyLocal(service *v1.Service) bool { if service.Spec.InternalTrafficPolicy == nil { return false } return *service.Spec.InternalTrafficPolicy == v1.ServiceInternalTrafficPolicyLocal }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 30 15:56:47 UTC 2023 - 3.3K bytes - Viewed (0) -
pkg/api/v1/service/util_test.go
}, }) } func TestInternalPolicyLocal(t *testing.T) { checkInternalPolicyLocal := func(expected bool, service *v1.Service) { t.Helper() res := InternalPolicyLocal(service) if res != expected { t.Errorf("Expected internal local traffic = %v, got %v", expected, res) } } // default InternalTrafficPolicy is nil
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/proxy/ipvs/proxier.go
// ExternalTrafficPolicy only works for NodePort and external LB traffic, does not affect ClusterIP // So we still need clusterIP rules in onlyNodeLocalEndpoints mode. internalNodeLocal := false if svcInfo.InternalPolicyLocal() { internalNodeLocal = true } if err := proxier.syncEndpoint(svcPortName, internalNodeLocal, serv); err != nil {
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/proxy/nftables/proxier.go
// generate rules pointing to internalTrafficChain, or false if there are // no available internal endpoints. internalPolicyChain := clusterPolicyChain hasInternalEndpoints := hasEndpoints if svcInfo.InternalPolicyLocal() { internalPolicyChain = localPolicyChain if len(localEndpoints) == 0 { hasInternalEndpoints = false } } internalTrafficChain := internalPolicyChain
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
// generate rules pointing to internalTrafficChain, or false if there are // no available internal endpoints. internalPolicyChain := clusterPolicyChain hasInternalEndpoints := hasEndpoints if svcInfo.InternalPolicyLocal() { internalPolicyChain = localPolicyChain if len(localEndpoints) == 0 { hasInternalEndpoints = false } } internalTrafficChain := internalPolicyChain
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0)