Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ShouldSkipService (0.25 sec)

  1. pkg/proxy/util/utils.go

    // the IPv4 or IPv6 zero CIDR
    func IsZeroCIDR(cidr string) bool {
    	if cidr == IPv4ZeroCIDR || cidr == IPv6ZeroCIDR {
    		return true
    	}
    	return false
    }
    
    // ShouldSkipService checks if a given service should skip proxying
    func ShouldSkipService(service *v1.Service) bool {
    	// if ClusterIP is "None" or empty, skip proxying
    	if !helper.IsServiceIPSet(service) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 20 11:57:43 UTC 2024
    - 7.4K bytes
    - Viewed (0)
  2. pkg/proxy/servicechangetracker.go

    //
    // NOTE: service object should NOT be modified.
    func (sct *ServiceChangeTracker) serviceToServiceMap(service *v1.Service) ServicePortMap {
    	if service == nil {
    		return nil
    	}
    
    	if proxyutil.ShouldSkipService(service) {
    		return nil
    	}
    
    	clusterIP := proxyutil.GetClusterIPByFamily(sct.ipFamily, service)
    	if clusterIP == "" {
    		return nil
    	}
    
    	svcPortMap := make(ServicePortMap)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Dec 21 14:44:08 UTC 2023
    - 8.7K bytes
    - Viewed (0)
  3. pkg/proxy/util/utils_test.go

    				Spec: v1.ServiceSpec{
    					ClusterIP: "1.2.3.4",
    					Type:      v1.ServiceTypeLoadBalancer,
    				},
    			},
    			shouldSkip: false,
    		},
    	}
    
    	for i := range testCases {
    		skip := ShouldSkipService(testCases[i].service)
    		if skip != testCases[i].shouldSkip {
    			t.Errorf("case %d: expect %v, got %v", i, testCases[i].shouldSkip, skip)
    		}
    	}
    }
    
    func TestAppendPortIfNeeded(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 20 11:57:43 UTC 2024
    - 17.1K bytes
    - Viewed (0)
Back to top