- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 781 for ledger (0.1 sec)
-
releasenotes/notes/drop-reload-prioritized-leader-election.yaml
John Howard <******@****.***> 1682620625 -0700
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 27 18:37:05 UTC 2023 - 148 bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection_test.go
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() if reportedLeader != test.outHolder { t.Errorf("reported leader was not the new leader. expected %q, got %q", test.outHolder, reportedLeader)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jan 23 16:39:43 UTC 2023 - 42.5K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/strategy/DefaultVersionComparatorTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 8.4K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection.go
// Store as field for testing le *k8sleaderelection.LeaderElector mu sync.RWMutex } // Run will start leader election, calling all runFns when we become the leader. // If leader election is disabled, it skips straight to the runFns. func (l *LeaderElection) Run(stop <-chan struct{}) { if !l.enabled { log.Infof("bypassing leader election: %v", l.electionID) for _, f := range l.runFns { go f(stop) } <-stop return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 9.7K bytes - Viewed (0) -
pilot/pkg/leaderelection/leaderelection_test.go
watcher := &fakeDefaultWatcher{"foo"} // First pod becomes the leader _, stop := createPerRevisionElection(t, "pod1", "foo", watcher, true, client) // A new pod is not the leader _, stop2 := createPerRevisionElection(t, "pod2", "foo", watcher, false, client) close(stop2) close(stop) t.Log("drop") // After leader is lost, we can take over _, stop3 := createPerRevisionElection(t, "pod2", "foo", watcher, true, client)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 11.4K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/metrics.go
// leader's value indicates if the current process is the owner of name lease leader SwitchMetric } func (m *defaultLeaderMetrics) leaderOn(name string) { if m == nil { return } m.leader.On(name) } func (m *defaultLeaderMetrics) leaderOff(name string) { if m == nil { return } m.leader.Off(name) } type noMetrics struct{} func (noMetrics) leaderOn(name string) {}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Oct 11 16:58:48 UTC 2021 - 2.6K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/healthzadaptor.go
// It helps deal with the /healthz endpoint being set up prior to the LeaderElection. // This contains the code needed to act as an adaptor between the leader // election code the health check code. It allows us to provide health // status about the leader election. Most specifically about if the leader // has failed to renew without exiting the process. In that case we should // report not healthy and rely on the kubelet to take down the process.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Oct 11 16:58:48 UTC 2021 - 2.3K bytes - Viewed (0) -
licenses/github.com/hashicorp/go-version/LICENSE
rights in the Source Code Form under this License. 3.3. Distribution of a Larger Work You may create and distribute a Larger Work under terms of Your choice, provided that You also comply with the requirements of this License for the Covered Software. If the Larger Work is a combination of Covered Software with a work governed by one or more Secondary Licenses, and the Covered
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 15:59:40 UTC 2024 - 15.6K bytes - Viewed (0) -
licenses/github.com/hashicorp/golang-lru/v2/LICENSE
recipients' rights in the Source Code Form under this License. 3.3. Distribution of a Larger Work You may create and distribute a Larger Work under terms of Your choice, provided that You also comply with the requirements of this License for the Covered Software. If the Larger Work is a combination of Covered Software with a work governed by one or more Secondary Licenses, and the
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 03 20:21:32 UTC 2023 - 15.6K bytes - Viewed (0) -
pkg/util/strcase/camelcase.go
return "" } t := make([]byte, 0, 32) i := 0 if isWordSeparator(s[0]) { // Need a capital letter; drop the '_'. t = append(t, 'X') i++ } // Invariant: if the next letter is lower case, it must be converted // to upper case. // That is, we process a word at a time, where words are marked by _, - or // upper case letter. Digits are treated as words. for ; i < len(s); i++ { c := s[i] if isWordSeparator(c) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 28 19:48:10 UTC 2020 - 2.7K bytes - Viewed (0)