Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for InternalPolicyLocal (0.53 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top