- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for endpointSliceCacheKeys (0.4 sec)
-
pkg/proxy/endpointslicecache.go
var formattedList []string for _, ep := range endpoints { formattedList = append(formattedList, ep.String()) } return formattedList } // endpointSliceCacheKeys returns cache keys used for a given EndpointSlice. func endpointSliceCacheKeys(endpointSlice *discovery.EndpointSlice) (types.NamespacedName, string, error) { var err error serviceName, ok := endpointSlice.Labels[discovery.LabelServiceName]
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/endpointslicecache_test.go
if tc.initialSlice != nil { tc.cache.updatePending(tc.initialSlice, false) tc.cache.checkoutChanges() } serviceKey, sliceKey, err := endpointSliceCacheKeys(tc.updatedSlice) if err != nil { t.Fatalf("Expected no error calling endpointSliceCacheKeys(): %v", err) } esData := &endpointSliceData{tc.updatedSlice, false} changed := tc.cache.esDataChanged(serviceKey, sliceKey, esData)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:07:21 UTC 2024 - 24.9K bytes - Viewed (0) -
pkg/proxy/endpointschangetracker.go
return false } // This should never happen if endpointSlice == nil { klog.ErrorS(nil, "Nil endpointSlice passed to EndpointSliceUpdate") return false } namespacedName, _, err := endpointSliceCacheKeys(endpointSlice) if err != nil { klog.InfoS("Error getting endpoint slice cache keys", "err", err) return false } metrics.EndpointChangesTotal.Inc() ect.lock.Lock() defer ect.lock.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 13.2K bytes - Viewed (0)