- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for LeaseDuration (0.16 sec)
-
pilot/pkg/leaderelection/k8sleaderelection/healthzadaptor_test.go
adaptorTimeout: time.Second * 20, elector: &LeaderElector{ config: LeaderElectionConfig{ Lock: &fakeLock{identity: "healthTest"}, LeaseDuration: time.Minute, Name: "foo", }, observedRecord: rl.LeaderElectionRecord{ HolderIdentity: "healthTest", }, observedTime: current,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 12 18:41:53 UTC 2022 - 5.3K bytes - Viewed (0) -
pkg/scheduler/apis/config/v1/defaults_test.go
EnableProfiling: &enable, EnableContentionProfiling: &enable, }, LeaderElection: componentbaseconfig.LeaderElectionConfiguration{ LeaderElect: ptr.To(true), LeaseDuration: metav1.Duration{Duration: 15 * time.Second}, RenewDeadline: metav1.Duration{Duration: 10 * time.Second}, RetryPeriod: metav1.Duration{Duration: 2 * time.Second}, ResourceLock: "leases",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 15:03:04 UTC 2024 - 27.9K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go
if lec.LeaseDuration <= lec.RenewDeadline { return nil, fmt.Errorf("leaseDuration must be greater than renewDeadline") } if lec.RenewDeadline <= time.Duration(JitterFactor*float64(lec.RetryPeriod)) { return nil, fmt.Errorf("renewDeadline must be greater than retryPeriod*JitterFactor") } if lec.LeaseDuration < 1 { return nil, fmt.Errorf("leaseDuration must be greater than zero") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 16.3K bytes - Viewed (0) -
pkg/apis/coordination/validation/validation_test.go
} } func TestValidateLeaseSpec(t *testing.T) { holder := "holder" leaseDuration := int32(0) leaseTransitions := int32(-1) spec := &coordination.LeaseSpec{ HolderIdentity: &holder, LeaseDurationSeconds: &leaseDuration, LeaseTransitions: &leaseTransitions, } errs := ValidateLeaseSpec(spec, field.NewPath("foo")) if len(errs) != 2 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 02 02:22:52 UTC 2018 - 2.9K bytes - Viewed (0) -
operator/cmd/operator/server.go
if !leaderElectionEnabled { log.Warn("Leader election namespace not set. Leader election is disabled. NOT APPROPRIATE FOR PRODUCTION USE!") } // renewDeadline cannot be greater than leaseDuration renewDeadline := getRenewDeadline() leaseDuration := time.Duration(renewDeadline.Nanoseconds() * 2) // Get a config to talk to the apiserver cfg, err := config.GetConfig() if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 30 21:09:08 UTC 2023 - 7.6K bytes - Viewed (0) -
cmd/kube-scheduler/app/options/options_test.go
EnableProfiling: true, EnableContentionProfiling: true, }, LeaderElection: componentbaseconfig.LeaderElectionConfiguration{ LeaderElect: true, LeaseDuration: metav1.Duration{Duration: 15 * time.Second}, RenewDeadline: metav1.Duration{Duration: 10 * time.Second}, RetryPeriod: metav1.Duration{Duration: 2 * time.Second}, ResourceLock: "leases",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 13 07:42:19 UTC 2023 - 30.3K bytes - Viewed (0) -
cmd/kube-scheduler/app/options/options.go
if leaderelection.Changed("leader-elect") { cfg.LeaderElection.LeaderElect = o.LeaderElection.LeaderElect } if leaderelection.Changed("leader-elect-lease-duration") { cfg.LeaderElection.LeaseDuration = o.LeaderElection.LeaseDuration } if leaderelection.Changed("leader-elect-renew-deadline") { cfg.LeaderElection.RenewDeadline = o.LeaderElection.RenewDeadline } if leaderelection.Changed("leader-elect-retry-period") {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 17 17:06:29 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/kube-scheduler/app/server_test.go
if err := os.WriteFile(leaderElectionConfig, []byte(fmt.Sprintf(` apiVersion: kubescheduler.config.k8s.io/v1 kind: KubeSchedulerConfiguration clientConnection: kubeconfig: '%s' leaderElection: leaseDuration: 1h `, configKubeconfig)), os.FileMode(0600)); err != nil { t.Fatal(err) } testcases := []struct { name string flags []string registryOptions []Option
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 14.2K bytes - Viewed (0) -
cluster/images/etcd/migrate/migrate_client.go
etcdctlCmd.Stdout = os.Stdout etcdctlCmd.Stderr = os.Stderr return etcdctlCmd.Run() } // AttachLease attaches leases of the given leaseDuration to all the etcd objects under // ttlKeysDirectory specified in this client's config. func (e *CombinedEtcdClient) AttachLease(leaseDuration time.Duration) error { ttlKeysPrefix := e.cfg.ttlKeysDirectory
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:53:06 UTC 2021 - 6.6K bytes - Viewed (0) -
pkg/scheduler/apis/config/scheme/scheme_test.go
clientConnection: acceptContentTypes: "" burst: 0 contentType: "" kubeconfig: "" qps: 0 kind: KubeSchedulerConfiguration leaderElection: leaderElect: null leaseDuration: 0s renewDeadline: 0s resourceLock: "" resourceName: "" resourceNamespace: "" retryPeriod: 0s profiles: - pluginConfig: - args: apiVersion: kubescheduler.config.k8s.io/v1
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 13 07:42:19 UTC 2023 - 22.2K bytes - Viewed (0)