Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for LeaseDuration (0.16 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top