- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for gracePeriod (5.65 sec)
-
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) -
security/pkg/nodeagent/cache/secretcache_test.go
expire time.Time gracePeriod float64 expected time.Duration }{ { name: "already expired", created: now.Add(-time.Second * 2), expire: now.Add(-time.Second), gracePeriod: 0.5, expected: 0, }, { name: "grace period .50", created: now, expire: now.Add(time.Hour), gracePeriod: 0.5, expected: time.Minute * 30,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 23.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/fieldselector_test.go
}() createTestResources(ctx, t, dynamicClient) // after creating resources, delete one to make sure deletions can be observed toDelete := "shirt1" var gracePeriod int64 = 0 err := clients["v1"].Delete(ctx, toDelete, metav1.DeleteOptions{GracePeriodSeconds: &gracePeriod}) if err != nil { t.Fatal(err) } // after creating resources, update the color of one CR to longer appear in a field selected watch.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 15:53:03 UTC 2024 - 27K bytes - Viewed (0) -
pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux.go
// If the pod's spec specifies a termination gracePeriod which is less than the gracePeriodOverride calculated, use the pod spec termination gracePeriod. if pod.Spec.TerminationGracePeriodSeconds != nil && *pod.Spec.TerminationGracePeriodSeconds <= gracePeriodOverride { gracePeriodOverride = *pod.Spec.TerminationGracePeriodSeconds }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 08:02:40 UTC 2022 - 15.5K bytes - Viewed (0) -
pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux_test.go
} type PodKillInfo struct { Name string GracePeriod int64 } podKillChan := make(chan PodKillInfo, 1) killPodsFunc := func(pod *v1.Pod, evict bool, gracePeriodOverride *int64, fn func(podStatus *v1.PodStatus)) error { var gracePeriod int64 if gracePeriodOverride != nil { gracePeriod = *gracePeriodOverride } fn(&pod.Status)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 29.8K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container_test.go
}) } } func testLifeCycleHook(t *testing.T, testPod *v1.Pod, testContainer *v1.Container) { // Setup fakeRuntime, _, m, _ := createTestRuntimeManager() gracePeriod := int64(30) cID := kubecontainer.ContainerID{ Type: "docker", ID: "foo", } cmdPostStart := &v1.Lifecycle{ PostStart: &v1.LifecycleHandler{ Exec: &v1.ExecAction{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 28K bytes - Viewed (0) -
pkg/quota/v1/evaluator/core/pods.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 05 00:02:47 UTC 2023 - 17.4K 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) -
security/pkg/nodeagent/cache/secretcache.go
}, nil } var rotateTime = func(secret security.SecretItem, graceRatio float64) time.Duration { secretLifeTime := secret.ExpireTime.Sub(secret.CreatedTime) gracePeriod := time.Duration((graceRatio) * float64(secretLifeTime)) delay := time.Until(secret.ExpireTime.Add(-gracePeriod)) if delay < 0 { delay = 0 } return delay } func (sc *SecretManagerClient) registerSecret(item security.SecretItem) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 04 08:29:46 UTC 2024 - 28.2K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager.go
summaryProvider stats.SummaryProvider // records when a threshold was first observed thresholdsFirstObservedAt thresholdsObservedAt // records the set of thresholds that have been met (including graceperiod) but not yet resolved thresholdsMet []evictionapi.Threshold // signalToRankFunc maps a resource to ranking function for that resource. signalToRankFunc map[evictionapi.Signal]rankFunc
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 18:55:56 UTC 2024 - 24.6K bytes - Viewed (0)