Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for leaderElect (0.28 sec)

  1. 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},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 15:03:04 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  2. cmd/kube-scheduler/app/options/options_test.go

    clientConnection:
      kubeconfig: '%s'
    leaderElection:
      leaderElect: true`, configKubeconfig)), os.FileMode(0600)); err != nil {
    		t.Fatal(err)
    	}
    
    	noVersionConfig := filepath.Join(tmpDir, "scheduler_invalid_no_version.yaml")
    	if err := os.WriteFile(noVersionConfig, []byte(fmt.Sprintf(`
    kind: KubeSchedulerConfiguration
    clientConnection:
      kubeconfig: '%s'
    leaderElection:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 13 07:42:19 UTC 2023
    - 30.3K bytes
    - Viewed (0)
  3. cmd/kube-scheduler/app/options/options.go

    	leaderelection := o.Flags.FlagSet("leader election")
    	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") {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 17 17:06:29 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. cmd/kube-scheduler/app/server_test.go

    				"--config", emptyLeaderElectionConfig,
    			},
    			wantLeaderElection: &componentbaseconfig.LeaderElectionConfiguration{
    				LeaderElect:       false,                                    // from CLI args
    				LeaseDuration:     metav1.Duration{Duration: 2 * time.Hour}, // from CLI args
    				RenewDeadline:     metav1.Duration{Duration: 10 * time.Second},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  5. 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:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 13 07:42:19 UTC 2023
    - 22.2K bytes
    - Viewed (0)
  6. pkg/scheduler/apis/config/validation/validation_test.go

    			ContentType:        "application/json",
    			QPS:                10,
    			Burst:              10,
    		},
    		LeaderElection: componentbaseconfig.LeaderElectionConfiguration{
    			ResourceLock:      "leases",
    			LeaderElect:       true,
    			LeaseDuration:     metav1.Duration{Duration: 30 * time.Second},
    			RenewDeadline:     metav1.Duration{Duration: 15 * time.Second},
    			RetryPeriod:       metav1.Duration{Duration: 5 * time.Second},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  7. cmd/kube-scheduler/app/server.go

    	cc.EventBroadcaster.StartRecordingToSink(ctx.Done())
    	defer cc.EventBroadcaster.Shutdown()
    
    	// Setup healthz checks.
    	var checks, readyzChecks []healthz.HealthChecker
    	if cc.ComponentConfig.LeaderElection.LeaderElect {
    		checks = append(checks, cc.LeaderElection.WatchDog)
    		readyzChecks = append(readyzChecks, cc.LeaderElection.WatchDog)
    	}
    	readyzChecks = append(readyzChecks, healthz.NewShutdownHealthz(ctx.Done()))
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 14.3K bytes
    - Viewed (0)
  8. pkg/scheduler/apis/config/validation/validation.go

    	// TODO: This can be removed when ResourceLock is not available
    	// Only ResourceLock values with leases are allowed
    	if cc.LeaderElection.LeaderElect && cc.LeaderElection.ResourceLock != "leases" {
    		leaderElectionPath := field.NewPath("leaderElection")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  9. cmd/kube-controller-manager/app/controllermanager.go

    	}
    
    	// Setup any healthz checks we will want to use.
    	var checks []healthz.HealthChecker
    	var electionChecker *leaderelection.HealthzAdaptor
    	if c.ComponentConfig.Generic.LeaderElection.LeaderElect {
    		electionChecker = leaderelection.NewLeaderHealthzAdaptor(time.Second * 20)
    		checks = append(checks, electionChecker)
    	}
    	healthzHandler := controllerhealthz.NewMutableHealthzHandler(checks...)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 13:03:53 UTC 2024
    - 37.5K bytes
    - Viewed (0)
  10. cmd/kube-controller-manager/app/options/options_test.go

    					Burst:       100,
    				},
    				ControllerStartInterval: metav1.Duration{Duration: 2 * time.Minute},
    				LeaderElection: componentbaseconfig.LeaderElectionConfiguration{
    					ResourceLock:      "configmap",
    					LeaderElect:       false,
    					LeaseDuration:     metav1.Duration{Duration: 30 * time.Second},
    					RenewDeadline:     metav1.Duration{Duration: 15 * time.Second},
    					RetryPeriod:       metav1.Duration{Duration: 5 * time.Second},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 02:59:09 UTC 2024
    - 55.1K bytes
    - Viewed (0)
Back to top