Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for updatepan (0.17 sec)

  1. cmd/bucket-handlers.go

    		return
    	}
    
    	updatedAt, err := globalBucketMetadataSys.Delete(ctx, bucket, bucketTaggingConfig)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	replLogIf(ctx, globalSiteReplicationSys.BucketMetaHook(ctx, madmin.SRBucketMeta{
    		Type:      madmin.SRBucketMetaTypeTags,
    		Bucket:    bucket,
    		UpdatedAt: updatedAt,
    	}))
    
    	// Write success response.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 61.2K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet.go

    	// and been cleaned up by SyncKnownPods. This means a pod may be desired (in API), admitted
    	// (in pod manager), and requested (by invoking UpdatePod) but not start for an arbitrarily
    	// long interval because a prior pod is still terminating.
    	//
    	// As an event-driven (by UpdatePod) controller, the podWorkers must periodically be resynced
    	// by the kubelet invoking SyncKnownPods with the desired state (admitted pods in podManager).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  3. pkg/kubelet/kubelet_pods.go

    		if pod == nil || wasMirror {
    			klog.V(2).InfoS("Programmer error, restartable pod was a mirror pod but activePods should never contain a mirror pod", "podUID", desiredPod.UID)
    			continue
    		}
    		kl.podWorkers.UpdatePod(UpdatePodOptions{
    			UpdateType: kubetypes.SyncPodCreate,
    			Pod:        pod,
    			MirrorPod:  mirrorPod,
    		})
    
    		// the desired pod is now known as well
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_test.go

    					{
    						State: v1.ContainerState{
    							Terminated: &v1.ContainerStateTerminated{},
    						},
    					},
    				},
    			},
    		},
    	}
    	for _, pod := range pods {
    		kubelet.podWorkers.UpdatePod(UpdatePodOptions{
    			Pod:        pod,
    			UpdateType: kubetypes.SyncPodSync,
    			StartTime:  time.Now(),
    		})
    		if !got {
    			t.Errorf("Should not skip completed pod %q", pod.Name)
    		}
    		got = 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)
Back to top