- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for gracePeriod (0.66 sec)
-
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) -
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) -
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) -
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) -
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) -
pkg/kubelet/eviction/api/types.go
Operator ThresholdOperator // Value is the threshold the resource is evaluated against. Value ThresholdValue // GracePeriod represents the amount of time that a threshold must be met before eviction is triggered. GracePeriod time.Duration // MinReclaim represents the minimum amount of resource to reclaim if the threshold is met. MinReclaim *ThresholdValue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 18:46:33 UTC 2023 - 5.7K bytes - Viewed (0) -
pkg/kubelet/eviction/memory_threshold_notifier_test.go
Signal: evictionapi.SignalMemoryAvailable, Operator: evictionapi.OpLessThan, Value: evictionapi.ThresholdValue{ Quantity: quantityMustParse("2Gi"), }, GracePeriod: time.Minute * 2, }, expectedSubstrings: []string{"soft"}, omittedSubstrings: []string{"allocatable", "hard"}, }, { description: "hard allocatable threshold",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 8.2K bytes - Viewed (0) -
tests/util/leak/check.go
Errorf(format string, args ...any) } var gracePeriod = time.Second * 5 func check(filter func(in []*goroutine) []*goroutine) error { // Loop, waiting for goroutines to shut down. // Wait up to timeout, but finish as quickly as possible. // The timeout here is not super sensitive, since if we hit this we will fail; a happy case will finish quickly deadline := time.Now().Add(gracePeriod) var leaked []*goroutine var err error
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 10:22:38 UTC 2023 - 6.9K bytes - Viewed (0) -
pkg/test/kube/util.go
func DeleteOptionsForeground() metav1.DeleteOptions { propagationPolicy := metav1.DeletePropagationForeground gracePeriod := int64(0) return metav1.DeleteOptions{ PropagationPolicy: &propagationPolicy, GracePeriodSeconds: &gracePeriod, } } // WaitUntilPodsAreReady waits until the pod with the name/namespace is in ready state.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Dec 04 22:47:52 UTC 2023 - 9.4K bytes - Viewed (0) -
tests/integration/pilot/vm_test.go
d := fmt.Sprintf("%s-%s", autoVM.Config().Service, "v1") scaleDeploymentOrFail(t, d, autoVM.Config().Namespace.Name(), 0) // it should take at most just over GracePeriod to cleanup if all pilots are healthy retry.UntilSuccessOrFail(t, func() error { if len(getWorkloadEntriesOrFail(t, autoVM)) > 0 { return errors.New("expected 0 WorkloadEntries") } return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 7.4K bytes - Viewed (0)