- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for endpointsMap (0.23 sec)
-
pkg/proxy/endpointschangetracker.go
} // Merge ensures that the current EndpointsMap contains all <service, endpoints> pairs from the EndpointsMap passed in. func (em EndpointsMap) merge(other EndpointsMap) { for svcPortName := range other { em[svcPortName] = other[svcPortName] } } // Unmerge removes the <service, endpoints> pairs from the current EndpointsMap which are contained in the EndpointsMap passed in.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 13.2K bytes - Viewed (0) -
pkg/proxy/endpointslicecache.go
return true } // endpointsMapFromEndpointInfo computes an endpointsMap from endpointInfo that // has been grouped by service port and IP. func endpointsMapFromEndpointInfo(endpointInfoBySP map[ServicePortName]map[string]Endpoint) EndpointsMap { endpointsMap := EndpointsMap{} // transform endpointInfoByServicePort into an endpointsMap with sorted IPs. for svcPortName, endpointSet := range endpointInfoBySP {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 11.7K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier_test.go
remoteSubnets: remoteSubnets, } hnsNetwork := newHnsNetwork(hnsNetworkInfo) hcnMock := fakehcn.NewHcnMock(hnsNetwork) proxier := &Proxier{ svcPortMap: make(proxy.ServicePortMap), endpointsMap: make(proxy.EndpointsMap), hostname: testHostName, nodeIP: nodeIP, serviceHealthServer: healthcheck.NewFakeServiceHealthServer(), network: *hnsNetworkInfo,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 28 14:30:51 UTC 2024 - 30.2K bytes - Viewed (0) -
pkg/proxy/servicechangetracker_test.go
svcPortMap ServicePortMap endpointsMap EndpointsMap hostname string } func newFakeProxier(ipFamily v1.IPFamily, t time.Time) *FakeProxier { return &FakeProxier{ svcPortMap: make(ServicePortMap), serviceChanges: NewServiceChangeTracker(nil, ipFamily, nil, nil), endpointsMap: make(EndpointsMap), endpointsChanges: &EndpointsChangeTracker{
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/endpointslicecache_test.go
}, }, }, // 2 slices with all endpoints overlapping, more unready in first than // second. If an endpoint is marked ready, we add it to the // EndpointsMap, even if conditions.Ready isn't true for another // matching endpoint "2 slices, overlapping endpoints, some endpoints unready in 1 or both": { namespacedName: types.NamespacedName{Name: "svc1", Namespace: "ns1"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 24.9K bytes - Viewed (0)