- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for endpointsMap (0.29 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) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/compact.go
"sync" "time" clientv3 "go.etcd.io/etcd/client/v3" "k8s.io/klog/v2" ) const ( compactRevKey = "compact_rev_key" ) var ( endpointsMapMu sync.Mutex endpointsMap map[string]struct{} ) func init() { endpointsMap = make(map[string]struct{}) } // StartCompactor starts a compactor in the background to compact old version of keys that's not needed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 17 02:54:36 UTC 2022 - 5.6K bytes - Viewed (0) -
pkg/proxy/topology.go
endpointsMap := make(map[string]Endpoint, len(clusterEndpoints)+len(localEndpoints)) for _, ep := range clusterEndpoints { endpointsMap[ep.String()] = ep } for _, ep := range localEndpoints { endpointsMap[ep.String()] = ep } allReachableEndpoints = make([]Endpoint, 0, len(endpointsMap)) for _, ep := range endpointsMap {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 06:46:03 UTC 2024 - 7.4K bytes - Viewed (0) -
pkg/proxy/endpointschangetracker_test.go
} func TestGetLocalEndpointIPs(t *testing.T) { testCases := []struct { endpointsMap EndpointsMap expected map[types.NamespacedName]sets.Set[string] }{{ // Case[0]: nothing endpointsMap: EndpointsMap{}, expected: map[types.NamespacedName]sets.Set[string]{}, }, { // Case[1]: unnamed port endpointsMap: EndpointsMap{ makeServicePortName("ns1", "ep1", "", v1.ProtocolTCP): []Endpoint{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 79.9K 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/winkernel/proxier.go
svcInfo.cleanupAllPolicies(proxier.endpointsMap[*svcPortName], proxier.mapStaleLoadbalancers, true) } else { // If no service exists, just cleanup the remote endpoints klog.V(3).InfoS("Endpoints are orphaned, cleaning up") // Cleanup Endpoints references epInfos, exists := proxier.endpointsMap[*svcPortName] if exists { // Cleanup Endpoints references
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/nftables/proxier.go
endpointsChanges *proxy.EndpointsChangeTracker serviceChanges *proxy.ServiceChangeTracker mu sync.Mutex // protects the following fields svcPortMap proxy.ServicePortMap endpointsMap proxy.EndpointsMap nodeLabels map[string]string // endpointSlicesSynced, and servicesSynced are set to true // when corresponding objects are synced after startup. This is used to avoid
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/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/iptables/proxier.go
endpointsChanges *proxy.EndpointsChangeTracker serviceChanges *proxy.ServiceChangeTracker mu sync.Mutex // protects the following fields svcPortMap proxy.ServicePortMap endpointsMap proxy.EndpointsMap nodeLabels map[string]string // endpointSlicesSynced, and servicesSynced are set to true // when corresponding objects are synced after startup. This is used to avoid
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0)