Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for endpointsMap (0.23 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top