Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for gracePeriod (0.46 sec)

  1. pkg/kubelet/eviction/helpers.go

    				Value:       softImageFsDisk.Value,
    				MinReclaim:  softImageFsDisk.MinReclaim,
    				GracePeriod: softImageFsDisk.GracePeriod,
    			})
    		}
    		if hardContainerFsINodes != -1 {
    			thresholds[hardContainerFsINodes] = evictionapi.Threshold{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 53.6K bytes
    - Viewed (0)
  2. pkg/kubelet/kuberuntime/kuberuntime_container.go

    			"containerName", containerName, "containerID", containerID.String(), "gracePeriod", gracePeriod)
    	}
    
    	// Run the pre-stop lifecycle hooks if applicable and if there is enough time to run it
    	if containerSpec.Lifecycle != nil && containerSpec.Lifecycle.PreStop != nil && gracePeriod > 0 {
    		gracePeriod = gracePeriod - m.executePreStopHook(ctx, pod, containerID, containerSpec, gracePeriod)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 54.7K bytes
    - Viewed (0)
  3. pkg/kubelet/pod_workers.go

    	}
    	// no matter what, we always supply a grace period of 1
    	if gracePeriod < 1 {
    		gracePeriod = 1
    	}
    	return gracePeriod, status.gracePeriod != 0 && status.gracePeriod != gracePeriod
    }
    
    // allowPodStart tries to start the pod and returns true if allowed, otherwise
    // it requeues the pod and returns false. If the pod will never be able to start
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 02 13:22:37 UTC 2024
    - 74.8K bytes
    - Viewed (0)
  4. pkg/kubelet/pod_workers_test.go

    				func() {
    					lock.Lock()
    					defer lock.Unlock()
    					processed[pod.UID] = append(processed[pod.UID], syncPodRecord{
    						name:        pod.Name,
    						updateType:  kubetypes.SyncPodKill,
    						gracePeriod: gracePeriod,
    					})
    				}()
    				return nil
    			},
    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/registry/core/pod/strategy_test.go

    			if out.GracePeriodSeconds == nil {
    				t.Errorf("out grace period was nil but supposed to be %v", tc.gracePeriod)
    			}
    			if *(out.GracePeriodSeconds) != tc.gracePeriod {
    				t.Errorf("out grace period was %v but was expected to be %v", *out, tc.gracePeriod)
    			}
    		})
    	}
    }
    
    type mockPodGetter struct {
    	pod *api.Pod
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 76.2K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  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. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store.go

    				if pendingFinalizers {
    					klog.V(6).InfoS("Object has pending finalizers, so the registry is going to update its status to deleting",
    						"object", klog.KRef(genericapirequest.NamespaceValue(ctx), name), "gracePeriod", time.Second*0)
    					err = markAsDeleting(existing, time.Now())
    					if err != nil {
    						return nil, err
    					}
    					return existing, nil
    				}
    				return nil, errDeleteNow
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 23:22:44 UTC 2024
    - 60.8K bytes
    - Viewed (0)
Back to top