Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 20 for gracePeriod (0.17 sec)

  1. pkg/controller/nodelifecycle/node_lifecycle_controller.go

    		nodeHealth.lease = observedLease
    		nodeHealth.probeTimestamp = nc.now()
    	}
    
    	if nc.now().After(nodeHealth.probeTimestamp.Add(gracePeriod)) {
    		// NodeReady condition or lease was last set longer ago than gracePeriod, so
    		// update it to Unknown (regardless of its current value) in the master.
    
    		nodeConditionTypes := []v1.NodeConditionType{
    			v1.NodeReady,
    			v1.NodeMemoryPressure,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  2. pkg/registry/core/service/ipallocator/controller/repairip.go

    		// Assume that CreationTimestamp exists.
    		ipLifetime := r.clock.Now().Sub(ipAddress.CreationTimestamp.Time)
    		gracePeriod := 60 * time.Second
    		if ipLifetime > gracePeriod {
    			runtime.HandleError(fmt.Errorf("IPAddress %s appears to have leaked: cleaning up", ipAddress.Name))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config_test.go

    	// Transforms data using one of them, and tries to untransform using the others.
    	// Repeats this for all possible combinations.
    	// Math for GracePeriod is explained at - https://github.com/kubernetes/kubernetes/blob/c9ed04762f94a319d7b1fb718dc345491a32bea6/staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go#L159-L163
    	expectedKMSCloseGracePeriod := 46 * time.Second
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 16:56:39 UTC 2024
    - 72.3K bytes
    - Viewed (0)
  4. pkg/apis/core/validation/validation.go

    			}
    			allErrs = append(allErrs, validateLivenessProbe(ctr.LivenessProbe, gracePeriod, idxPath.Child("livenessProbe"))...)
    			allErrs = append(allErrs, validateReadinessProbe(ctr.ReadinessProbe, gracePeriod, idxPath.Child("readinessProbe"))...)
    			allErrs = append(allErrs, validateStartupProbe(ctr.StartupProbe, gracePeriod, idxPath.Child("startupProbe"))...)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 349.5K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_pods_test.go

    					{name: "pod1", updateType: kubetypes.SyncPodCreate},
    					{name: "pod1", updateType: kubetypes.SyncPodKill, gracePeriod: &two},
    					{name: "pod1", updateType: kubetypes.SyncPodKill, gracePeriod: &two},
    					// after the second attempt
    					{name: "pod1", updateType: kubetypes.SyncPodKill, gracePeriod: &two},
    					// from termination
    					{name: "pod1", terminated: true},
    				}; !reflect.DeepEqual(expected, actual) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  6. pkg/kubelet/eviction/eviction_manager_test.go

    				},
    			},
    			{
    				Signal:   evictionapi.SignalMemoryAvailable,
    				Operator: evictionapi.OpLessThan,
    				Value: evictionapi.ThresholdValue{
    					Quantity: quantityMustParse("2Gi"),
    				},
    				GracePeriod: time.Minute * 2,
    			},
    		},
    	}
    	summaryProvider := &fakeSummaryProvider{result: summaryStatsMaker("2Gi", podStats)}
    	manager := &managerImpl{
    		clock:                        fakeClock,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 119.9K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet.go

    	}
    	kl.statusManager.SetPodStatus(pod, apiPodStatus)
    
    	if gracePeriod != nil {
    		klog.V(4).InfoS("Pod terminating with grace period", "pod", klog.KObj(pod), "podUID", pod.UID, "gracePeriod", *gracePeriod)
    	} else {
    		klog.V(4).InfoS("Pod terminating with grace period", "pod", klog.KObj(pod), "podUID", pod.UID, "gracePeriod", nil)
    	}
    
    	kl.probeManager.StopLivenessAndStartup(pod)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  8. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    	podStatus, err := m.GetPodStatus(ctx, pod.UID, pod.Name, pod.Namespace)
    	require.NoError(t, err)
    	p := kubecontainer.ConvertPodStatusToRunningPod("", podStatus)
    	gracePeriod := int64(1)
    	err = m.KillPod(ctx, pod, p, &gracePeriod)
    	require.NoError(t, err)
    }
    
    func TestGetPodStatusWithNotFoundError(t *testing.T) {
    	ctx := context.Background()
    	fakeRuntime, _, m, err := createTestRuntimeManager()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  9. pkg/apis/core/validation/validation_test.go

    			},
    			gracePeriod: 30,
    		},
    		{
    			name: "negative seconds",
    			action: &core.SleepAction{
    				Seconds: -1,
    			},
    			gracePeriod: 30,
    			expectErr:   field.ErrorList{field.Invalid(fldPath, -1, getInvalidStr(30))},
    		},
    		{
    			name: "longer than gracePeriod",
    			action: &core.SleepAction{
    				Seconds: 5,
    			},
    			gracePeriod: 3,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 857.7K bytes
    - Viewed (0)
  10. pkg/controller/job/backoff_utils.go

    // 1. if all containers finished, use the latest time
    // 2. if the pod has Ready=False condition, use the last transition time
    // 3. if the pod has been deleted, use the `deletionTimestamp - grace_period` to estimate the moment of deletion
    // 4. fallback to pod's creation time
    //
    // Pods owned by Kubelet are marked with Ready=False condition when
    // transitioning to terminal phase, thus being handled by (1.) or (2.).
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 07:46:41 UTC 2024
    - 8.3K bytes
    - Viewed (0)
Back to top