- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for shouldLead (0.32 sec)
-
pilot/pkg/serviceregistry/kube/controller/multicluster.go
m.opts.MeshServiceController.AddRegistryAndRun(kubeRegistry, clusterStopCh) go func() { var shouldLead bool if !configCluster { shouldLead = m.checkShouldLead(client, options.SystemNamespace, clusterStopCh) log.Infof("should join leader-election for cluster %s: %t", cluster.ID, shouldLead) } if m.startNsController && (shouldLead || configCluster) { // Block server exit on graceful termination of the leader controller.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
src/net/http/cookiejar/jar.go
func (e *entry) id() string { return fmt.Sprintf("%s;%s;%s", e.Domain, e.Path, e.Name) } // shouldSend determines whether e's cookie qualifies to be included in a // request to host/path. It is the caller's responsibility to check if the // cookie is expired. func (e *entry) shouldSend(https bool, host, path string) bool { return e.domainMatch(host) && e.pathMatch(path) && (https || !e.Secure) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 15K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/dispatch/AsyncDispatchTest.groovy
when: parallel.run { dispatch.dispatchTo(target1) dispatch.dispatch('message1') parallel.syncAt(1) dispatch.requestStop() parallel.shouldBeAt(1) parallel.syncAt(2) } parallel.waitForAll() dispatch.stop() then: target1.receivedMessages == ['message1'] }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 6.5K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java
public void expectBlocksUntil(int tick, Closure closure) { expectLater(tick); closure.call(); shouldBeAt(tick); } /** * Asserts that the clock is at the given tick. * * @param tick The expected clock tick. */ public void shouldBeAt(int tick) { lock.lock(); try { if (currentTick != getTick(tick)) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 23.3K bytes - Viewed (0)