- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for servicePortMap (0.13 sec)
-
pkg/proxy/conntrack/cleanup.go
netutils "k8s.io/utils/net" ) // CleanStaleEntries takes care of flushing stale conntrack entries for services and endpoints. func CleanStaleEntries(ct Interface, svcPortMap proxy.ServicePortMap, serviceUpdateResult proxy.UpdateServiceMapResult, endpointsUpdateResult proxy.UpdateEndpointsMapResult) { deleteStaleServiceConntrackEntries(ct, svcPortMap, serviceUpdateResult, endpointsUpdateResult)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 18:09:05 UTC 2024 - 5.2K bytes - Viewed (0) -
pkg/config/analysis/analyzers/deployment/services.go
} return true }) return matchingSvcs } // servicePortMap build a map of ports and protocols for each Service. e.g. m[80]["TCP"] -> svcA, svcB, svcC func servicePortMap(svcs []ServiceSpecWithName) PortMap { portMap := PortMap{} for _, swn := range svcs { svc := swn.Spec for _, sPort := range svc.Ports {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun May 05 03:44:57 UTC 2024 - 6.6K bytes - Viewed (0) -
pkg/proxy/conntrack/cleanup_test.go
testPort = 53 testNodePort = 5353 testEndpointPort = "5300" ) func TestCleanStaleEntries(t *testing.T) { // We need to construct a proxy.ServicePortMap to pass to CleanStaleEntries. // ServicePortMap is just map[string]proxy.ServicePort, but there are no public // constructors for any implementation of proxy.ServicePort, so we have to either
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 15 18:09:05 UTC 2024 - 7.6K bytes - Viewed (0)