Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewLeaderElector (0.41 sec)

  1. pilot/pkg/leaderelection/leaderelection.go

    		config.KeyComparison = func(leaderKey string) bool {
    			return LocationPrioritizedComparison(leaderKey, l)
    		}
    	}
    
    	return k8sleaderelection.NewLeaderElector(config)
    }
    
    func LocationPrioritizedComparison(currentLeaderRevision string, l *LeaderElection) bool {
    	var currentLeaderRemote bool
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 12 16:44:32 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  2. cmd/kube-scheduler/app/server.go

    				default:
    					// We lost the lock.
    					logger.Error(nil, "Leaderelection lost")
    					klog.FlushAndExit(klog.ExitFlushTimeout, 1)
    				}
    			},
    		}
    		leaderElector, err := leaderelection.NewLeaderElector(*cc.LeaderElection)
    		if err != nil {
    			return fmt.Errorf("couldn't create leader elector: %v", err)
    		}
    
    		leaderElector.Run(ctx)
    
    		return fmt.Errorf("lost lease")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 14.3K bytes
    - Viewed (0)
Back to top