- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 20 for gracePeriod (0.17 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)