Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for leaderTransitions (0.22 sec)

  1. pilot/pkg/leaderelection/k8sleaderelection/k8sresourcelock/leaselock.go

    		r.HolderIdentity = *spec.HolderIdentity
    	}
    	if spec.LeaseDurationSeconds != nil {
    		r.LeaseDurationSeconds = int(*spec.LeaseDurationSeconds)
    	}
    	if spec.LeaseTransitions != nil {
    		r.LeaderTransitions = int(*spec.LeaseTransitions)
    	}
    	if spec.AcquireTime != nil {
    		r.AcquireTime = metav1.Time{Time: spec.AcquireTime.Time}
    	}
    	if spec.RenewTime != nil {
    		r.RenewTime = metav1.Time{Time: spec.RenewTime.Time}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Jun 04 16:02:26 UTC 2022
    - 4.3K bytes
    - Viewed (0)
  2. pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go

    	if le.IsLeader() {
    		leaderElectionRecord.AcquireTime = oldLeaderElectionRecord.AcquireTime
    		leaderElectionRecord.LeaderTransitions = oldLeaderElectionRecord.LeaderTransitions
    	} else {
    		leaderElectionRecord.LeaderTransitions = oldLeaderElectionRecord.LeaderTransitions + 1
    	}
    
    	// update the lock itself
    	if err = le.config.Lock.Update(ctx, leaderElectionRecord); err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 24 04:04:42 UTC 2023
    - 16.3K bytes
    - Viewed (0)
  3. pilot/pkg/leaderelection/k8sleaderelection/k8sresourcelock/interface.go

    	LeaseDurationSeconds int         `json:"leaseDurationSeconds"`
    	AcquireTime          metav1.Time `json:"acquireTime"`
    	RenewTime            metav1.Time `json:"renewTime"`
    	LeaderTransitions    int         `json:"leaderTransitions"`
    }
    
    // EventRecorder records a change in the ResourceLock.
    type EventRecorder interface {
    	Eventf(obj runtime.Object, eventType, reason, message string, args ...any)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jul 25 19:30:47 UTC 2022
    - 6K bytes
    - Viewed (0)
  4. pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go

    				t.Errorf("wrong number of api interactions")
    			}
    			if test.transitionLeader && le.observedRecord.LeaderTransitions != 1 {
    				t.Errorf("leader should have transitioned but did not")
    			}
    			if !test.transitionLeader && le.observedRecord.LeaderTransitions != 0 {
    				t.Errorf("leader should not have transitioned but did")
    			}
    
    			le.maybeReportTransition()
    			wg.Wait()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jan 23 16:39:43 UTC 2023
    - 42.5K bytes
    - Viewed (0)
Back to top