Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for ShouldSync (0.53 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top