Searched refs:slicesToUpdate (Results 1 – 4 of 4) sorted by relevance
/dports/sysutils/kubectl/kubernetes-1.22.2/pkg/controller/endpointslice/ |
H A D | reconciler.go | 134 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 D | utils.go | 370 func unchangedSlices(existingSlices, slicesToUpdate, slicesToDelete []*discovery.EndpointSlice) []*… argument 372 for _, slice := range slicesToUpdate {
|
H A D | reconciler_test.go | 1273 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 D | topologycache_test.go | 252 slicesToCreate, slicesToUpdate := cache.AddHints(tc.sliceInfo) 255 expectEquivalentSlices(t, slicesToUpdate, tc.expectedSlicesToUpdate)
|