- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for leaderTransitions (0.22 sec)
-
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) -
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) -
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) -
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)