Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for ShouldSync (0.15 sec)

  1. 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)
  2. 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)
  3. 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