Home
last modified time | relevance | path

Searched refs:slicesToUpdate (Results 1 – 4 of 4) sorted by relevance

/dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controller/endpointslice/
H A Dreconciler.go134 slicesToUpdate := []*discovery.EndpointSlice{}
204 slicesToUpdate = append(slicesToUpdate, pmSlicesToUpdate...)
240 ToUpdate: slicesToUpdate,
245 slicesToCreate, slicesToUpdate = r.topologyCache.AddHints(si)
250 slicesToCreate, slicesToUpdate = topologycache.RemoveHintsFromSlices(si)
260 slicesToUpdate,
283 slicesToUpdate = append(slicesToUpdate, slice)
309 for _, endpointSlice := range slicesToUpdate {
482 slicesToUpdate := []*discovery.EndpointSlice{}
484 slicesToUpdate = append(slicesToUpdate, slicesByName[sliceName])
[all …]
H A Dutils.go370 func unchangedSlices(existingSlices, slicesToUpdate, slicesToDelete []*discovery.EndpointSlice) []*… argument
372 for _, slice := range slicesToUpdate {
H A Dreconciler_test.go1273 slicesToUpdate := []*discovery.EndpointSlice{}
1275 slicesToUpdate = append(slicesToUpdate, esToUpdate.DeepCopy())
1282 err = r.finalize(&svc, slicesToCreate, slicesToUpdate, slicesToDelete, time.Now())
/dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controller/endpointslice/topologycache/
H A Dtopologycache_test.go252 slicesToCreate, slicesToUpdate := cache.AddHints(tc.sliceInfo)
255 expectEquivalentSlices(t, slicesToUpdate, tc.expectedSlicesToUpdate)