- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for healthCheckNodePorts (0.33 sec)
-
pkg/proxy/servicechangetracker_test.go
} // The only-local-loadbalancer ones get added healthCheckNodePorts := fp.svcPortMap.HealthCheckNodePorts() if len(healthCheckNodePorts) != 1 { t.Errorf("expected 1 healthcheck port, got %v", healthCheckNodePorts) } else { nsn := makeNSN("ns1", "only-local-load-balancer") if port, found := healthCheckNodePorts[nsn]; !found || port != 345 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 33.7K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
} // The only-local-loadbalancer ones get added healthCheckNodePorts := fp.svcPortMap.HealthCheckNodePorts() if len(healthCheckNodePorts) != 1 { t.Errorf("expected 1 healthcheck port, got %v", healthCheckNodePorts) } else { nsn := makeNSN("somewhere", "only-local-load-balancer") if port, found := healthCheckNodePorts[nsn]; !found || port != 345 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0) -
pkg/proxy/nftables/proxier_test.go
} // The only-local-loadbalancer ones get added healthCheckNodePorts := fp.svcPortMap.HealthCheckNodePorts() if len(healthCheckNodePorts) != 1 { t.Errorf("expected 1 healthcheck port, got %v", healthCheckNodePorts) } else { nsn := makeNSN("somewhere", "only-local-load-balancer") if port, found := healthCheckNodePorts[nsn]; !found || port != 345 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 173.5K bytes - Viewed (0) -
pkg/proxy/servicechangetracker.go
// connection-tracking information. DeletedUDPClusterIPs sets.Set[string] } // HealthCheckNodePorts returns a map of Service names to HealthCheckNodePort values // for all Services in sm with non-zero HealthCheckNodePort. func (sm ServicePortMap) HealthCheckNodePorts() map[types.NamespacedName]uint16 { // TODO: If this will appear to be computationally expensive, consider
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/iptables/proxier_test.go
} // The only-local-loadbalancer ones get added healthCheckNodePorts := fp.svcPortMap.HealthCheckNodePorts() if len(healthCheckNodePorts) != 1 { t.Errorf("expected 1 healthcheck port, got %v", healthCheckNodePorts) } else { nsn := makeNSN("somewhere", "only-local-load-balancer") if port, found := healthCheckNodePorts[nsn]; !found || port != 345 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 249.9K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
"--dport", strconv.Itoa(svcInfo.NodePort()), "-j", externalTrafficFilterTarget, ) } } // Capture healthCheckNodePorts. if svcInfo.HealthCheckNodePort() != 0 { // no matter if node has local endpoints, healthCheckNodePorts // need to add a rule to accept the incoming connection filterRules.Write( "-A", string(kubeNodePortsChain),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
// not "OnlyLocal", but the services list will not, and the serviceHealthServer // will just drop those endpoints. if err := proxier.serviceHealthServer.SyncServices(proxier.svcPortMap.HealthCheckNodePorts()); err != nil { proxier.logger.Error(err, "Error syncing healthcheck services") } if err := proxier.serviceHealthServer.SyncEndpoints(proxier.endpointsMap.LocalReadyEndpoints()); err != nil {
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/winkernel/proxier.go
// not "OnlyLocal", but the services list will not, and the serviceHealthServer // will just drop those endpoints. if err := proxier.serviceHealthServer.SyncServices(proxier.svcPortMap.HealthCheckNodePorts()); err != nil { klog.ErrorS(err, "Error syncing healthcheck services") } if err := proxier.serviceHealthServer.SyncEndpoints(proxier.endpointsMap.LocalReadyEndpoints()); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
// not "OnlyLocal", but the services list will not, and the serviceHealthServer // will just drop those endpoints. if err := proxier.serviceHealthServer.SyncServices(proxier.svcPortMap.HealthCheckNodePorts()); err != nil { proxier.logger.Error(err, "Error syncing healthcheck services") } if err := proxier.serviceHealthServer.SyncEndpoints(proxier.endpointsMap.LocalReadyEndpoints()); 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)