- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ShouldSkipService (0.25 sec)
-
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) -
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) -
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)