Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 45 for gracePeriod (0.6 sec)

  1. pkg/kubelet/eviction/helpers_test.go

    					},
    					GracePeriod: gracePeriod,
    					MinReclaim: &evictionapi.ThresholdValue{
    						Quantity: quantityMustParse("2Gi"),
    					},
    				},
    				{
    					Signal:   evictionapi.SignalNodeFsAvailable,
    					Operator: evictionapi.OpLessThan,
    					Value: evictionapi.ThresholdValue{
    						Quantity: quantityMustParse("200Mi"),
    					},
    					GracePeriod: gracePeriod,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 106.7K bytes
    - Viewed (0)
  2. pkg/kubelet/kuberuntime/kuberuntime_termination_order.go

    // the specified grace period.  If gracePeriod = 0, there is no wait.
    func (o *terminationOrdering) waitForTurn(name string, gracePeriod int64) float64 {
    	// if there is no grace period, we don't wait
    	if gracePeriod <= 0 {
    		return 0
    	}
    
    	start := time.Now()
    	remainingGrace := time.NewTimer(time.Duration(gracePeriod) * time.Second)
    
    	for _, c := range o.prereqs[name] {
    		select {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Oct 18 00:07:21 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  3. src/cmd/go/internal/vcweb/script.go

    	gracePeriod := 30 * time.Second // arbitrary
    
    	cmds := script.DefaultCmds()
    	cmds["at"] = scriptAt()
    	cmds["bzr"] = script.Program("bzr", interrupt, gracePeriod)
    	cmds["fossil"] = script.Program("fossil", interrupt, gracePeriod)
    	cmds["git"] = script.Program("git", interrupt, gracePeriod)
    	cmds["hg"] = script.Program("hg", interrupt, gracePeriod)
    	cmds["handle"] = scriptHandle()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 08 19:37:03 UTC 2022
    - 9K bytes
    - Viewed (0)
  4. src/internal/testenv/exec.go

    			// output of a reasonable program after it terminates.
    			gracePeriod = 100 * time.Millisecond
    			if s := os.Getenv("GO_TEST_TIMEOUT_SCALE"); s != "" {
    				scale, err := strconv.Atoi(s)
    				if err != nil {
    					t.Fatalf("invalid GO_TEST_TIMEOUT_SCALE: %v", err)
    				}
    				gracePeriod *= time.Duration(scale)
    			}
    
    			// If time allows, increase the termination grace period to 5% of the
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Oct 27 17:53:23 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  5. 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)
  6. security/pkg/util/certutil.go

    	// when duration is time.Hour * 90000). So float64 is used instead.
    	gracePeriod := time.Duration(float64(cert.NotAfter.Sub(cert.NotBefore)) * (float64(cu.gracePeriodPercentage) / 100))
    	// waitTime is the duration between now and the grace period starts.
    	// It is the time until cert expiration minus the length of grace period.
    	waitTime := timeToExpire - gracePeriod
    	if waitTime < 0 {
    		// We are within the grace period.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Nov 30 19:33:26 UTC 2023
    - 2.3K bytes
    - Viewed (0)
  7. security/pkg/credentialfetcher/plugin/gce.go

    	// When fails to get expiration time from token, always refresh the token.
    	if err != nil || exp.IsZero() {
    		return true
    	}
    	rotate := now.After(exp.Add(-gracePeriod))
    	gcecredLog.Debugf("credential expiration: %s, grace period: %s, should rotate: %t",
    		exp.String(), gracePeriod.String(), rotate)
    	return rotate
    }
    
    // GetPlatformCredential fetches the GCE VM identity jwt token from its metadata server,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 13:56:46 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  8. src/cmd/go/script_test.go

    	}
    
    	StartProxy()
    
    	var (
    		ctx         = context.Background()
    		gracePeriod = 100 * time.Millisecond
    	)
    	if deadline, ok := t.Deadline(); ok {
    		timeout := time.Until(deadline)
    
    		// If time allows, increase the termination grace period to 5% of the
    		// remaining time.
    		if gp := timeout / 20; gp > gracePeriod {
    			gracePeriod = gp
    		}
    
    		// When we run commands that execute subprocesses, we want to reserve two
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 18:15:22 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top