- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for ShouldSync (0.53 sec)
-
pkg/kubelet/active_deadline.go
} return &activeDeadlineHandler{ clock: clock, podStatusProvider: podStatusProvider, recorder: recorder, }, nil } // ShouldSync returns true if the pod is past its active deadline. func (m *activeDeadlineHandler) ShouldSync(pod *v1.Pod) bool { return m.pastActiveDeadline(pod) } // ShouldEvict returns true if the pod is past its active deadline.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 3.2K bytes - Viewed (0) -
pkg/kubelet/lifecycle/interfaces.go
} // PodSyncLoopHandler is invoked during each sync loop iteration. type PodSyncLoopHandler interface { // ShouldSync returns true if the pod needs to be synced. // This operation must return immediately as its called for each pod. // The provided pod should never be modified. ShouldSync(pod *v1.Pod) bool } // PodSyncLoopTarget maintains a list of handlers to pod sync loop. type PodSyncLoopTarget interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 22 17:25:57 UTC 2017 - 4K bytes - Viewed (0) -
pkg/kubelet/active_deadline_test.go
expected bool }{{pods[0], true}, {pods[1], false}, {pods[2], false}, {pods[3], false}, {pods[4], false}} for i, testCase := range testCases { if actual := handler.ShouldSync(testCase.pod); actual != testCase.expected { t.Errorf("[%d] ShouldSync expected %#v, got %#v", i, testCase.expected, actual) } actual := handler.ShouldEvict(testCase.pod) if actual.Evict != testCase.expected {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Oct 08 09:06:42 UTC 2022 - 4.5K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
if endpointSlice == nil { utilruntime.HandleError(fmt.Errorf("onEndpointSliceAdd() expected type discovery.EndpointSlice, got %T", obj)) return } if managedByController(endpointSlice) && c.endpointSliceTracker.ShouldSync(endpointSlice) { c.queueEndpointsForEndpointSlice(endpointSlice) } } // onEndpointSliceUpdate queues a sync for the relevant Endpoints resource for a
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
if endpointSlice == nil { utilruntime.HandleError(fmt.Errorf("Invalid EndpointSlice provided to onEndpointSliceAdd()")) return } if c.reconciler.ManagedByController(endpointSlice) && c.endpointSliceTracker.ShouldSync(endpointSlice) { c.queueServiceForEndpointSlice(endpointSlice) } } // onEndpointSliceUpdate queues a sync for the relevant Service for a sync if
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
type testPodSyncLoopHandler struct { // list of pods to sync podsToSync []*v1.Pod } // ShouldSync evaluates if the pod should be synced from the kubelet. func (a *testPodSyncLoopHandler) ShouldSync(pod *v1.Pod) bool { for _, podToSync := range a.podsToSync { if podToSync.UID == pod.UID { return true } } return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/kubelet.go
// The work of the pod is ready podsToSync = append(podsToSync, pod) continue } for _, podSyncLoopHandler := range kl.PodSyncLoopHandlers { if podSyncLoopHandler.ShouldSync(pod) { podsToSync = append(podsToSync, pod) break } } } return podsToSync } // deletePod deletes the pod from the internal state of the kubelet by:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0)