Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for PendingUpdate (0.19 sec)

  1. staging/src/k8s.io/apiserver/pkg/storageversion/manager.go

    	// UpdateStorageVersions tries to update the StorageVersions of the recorded resources
    	UpdateStorageVersions(kubeAPIServerClientConfig *rest.Config, apiserverID string)
    	// PendingUpdate returns true if the StorageVersion of the given resource is still pending update.
    	PendingUpdate(gr schema.GroupResource) bool
    	// LastUpdateError returns the last error hit when updating the storage version of the given resource.
    	LastUpdateError(gr schema.GroupResource) error
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 14 17:47:19 UTC 2023
    - 10.5K bytes
    - Viewed (0)
  2. pkg/kubelet/pod_workers.go

    	// by preserving the oldest StartTime
    	if status.pendingUpdate != nil && !status.pendingUpdate.StartTime.IsZero() && status.pendingUpdate.StartTime.Before(options.StartTime) {
    		options.StartTime = status.pendingUpdate.StartTime
    	}
    
    	// notify the pod worker there is a pending update
    	status.pendingUpdate = &options
    	status.working = true
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 02 13:22:37 UTC 2024
    - 74.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/endpoints/filters/storageversion.go

    		// Non-persisted resources are not in the to-be-updated list, so they will pass.
    		gr := schema.GroupResource{Group: requestInfo.APIGroup, Resource: requestInfo.Resource}
    		if !svm.PendingUpdate(gr) {
    			handler.ServeHTTP(w, req)
    			return
    		}
    
    		gv := schema.GroupVersion{Group: requestInfo.APIGroup, Version: requestInfo.APIVersion}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 03 06:51:04 UTC 2023
    - 5K bytes
    - Viewed (0)
  4. pkg/kubelet/pod_workers_test.go

    			},
    		},
    		{
    			desc: "orphaned terminating worker with pendingUpdate",
    			podSyncStatus: &podSyncStatus{
    				startedAt:     time.Unix(1, 0),
    				terminatingAt: time.Unix(2, 0),
    				finished:      false,
    				fullname:      "fake-fullname",
    				working:       true,
    				pendingUpdate: &UpdatePodOptions{
    					Pod: &v1.Pod{ObjectMeta: metav1.ObjectMeta{UID: podUID, Name: "2"}},
    				},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_pods_test.go

    				}
    				s, ok := w.podSyncStatuses[uid]
    				if !ok || s.IsTerminationRequested() || s.IsTerminationStarted() || s.IsFinished() || s.IsWorking() || s.IsDeleted() || s.restartRequested || s.activeUpdate != nil || s.pendingUpdate == nil {
    					t.Errorf("unexpected requested pod termination: %#v", s)
    				}
    
    				// expect that no sync calls are made, since the pod doesn't ever start
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
Back to top