Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for updatePending (0.09 sec)

  1. pkg/proxy/endpointslicecache.go

    	}
    }
    
    // standardEndpointInfo is the default makeEndpointFunc.
    func standardEndpointInfo(ep *BaseEndpointInfo, _ *ServicePortName) Endpoint {
    	return ep
    }
    
    // updatePending updates a pending slice in the cache.
    func (cache *EndpointSliceCache) updatePending(endpointSlice *discovery.EndpointSlice, remove bool) bool {
    	serviceKey, sliceKey, err := endpointSliceCacheKeys(endpointSlice)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:07:21 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  2. pkg/proxy/endpointslicecache_test.go

    			esCache := NewEndpointSliceCache(tc.hostname, v1.IPv4Protocol, nil, nil)
    
    			cmc := newCacheMutationCheck(tc.endpointSlices)
    			for _, endpointSlice := range tc.endpointSlices {
    				esCache.updatePending(endpointSlice, false)
    			}
    
    			compareEndpointsMapsStr(t, esCache.getEndpointsMap(tc.namespacedName, esCache.trackerByServiceMap[tc.namespacedName].pending), tc.expectedMap)
    			cmc.Check(t)
    		})
    	}
    }
    
    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