- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,049 for leaders (0.18 sec)
-
src/cmd/compile/internal/ssagen/pgen.go
if mls != nil && mls.IsLeader(n) { leaders[n] = -s.stksize } } if mls != nil { // Update offsets of followers (subsumed vars) to be the // same as the leader var in their partition. for i := 0; i < len(fn.Dcl); i++ { n := fn.Dcl[i] if !mls.Subsumed(n) { continue } leader := mls.Leader(n) off, ok := leaders[leader] if !ok {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 15:44:14 UTC 2024 - 13.1K 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) -
cluster/addons/addon-manager/kube-addons.sh
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Oct 15 05:40:38 UTC 2023 - 10.4K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
doneCh := make(chan error, 1) defer xioutil.SafeClose(doneCh) // Save rebalance.bin periodically. go func() { // Update rebalance.bin periodically once every 5-10s, chosen randomly // to avoid multiple pool leaders herding to update around the same // time. r := rand.New(rand.NewSource(time.Now().UnixNano())) randSleepFor := func() time.Duration { return 5*time.Second + time.Duration(float64(5*time.Second)*r.Float64()) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 03 15:45:54 UTC 2024 - 27.3K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/controller/repair.go
func (c *Repair) doRunOnce() error { // TODO: (per smarterclayton) if Get() or ListServices() is a weak consistency read, // or if they are executed against different leaders, // the ordering guarantee required to ensure no port is allocated twice is violated. // ListServices must return a ResourceVersion higher than the etcd index Get triggers,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 10.4K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repair.go
func (c *Repair) doRunOnce() error { // TODO: (per smarterclayton) if Get() or ListServices() is a weak consistency read, // or if they are executed against different leaders, // the ordering guarantee required to ensure no IP is allocated twice is violated. // ListServices must return a ResourceVersion higher than the etcd index Get triggers,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 13.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Headers.kt
/** * Add a header with the specified name and formatted date. Does validation of header names and * value. */ fun add( name: String, value: Date, ) = add(name, value.toHttpDateString()) /** * Add a header with the specified name and formatted instant. Does validation of header names * and value. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 11.5K bytes - Viewed (0) -
platforms/native/language-native/src/integTest/groovy/org/gradle/language/cpp/CppIncrementalBuildIntegrationTest.groovy
def "source file can reference multiple header files using the same macro"() { def header1 = file("app/src/main/headers/hello1.h") def header2 = file("app/src/main/headers/hello2.h") def header3 = file("app/src/main/headers/hello3.h") def unused = file("app/src/main/headers/ignoreme.h") when: file("app/src/main/headers/hello.h") << """ #if 0
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 40.4K bytes - Viewed (0) -
docs/es/docs/advanced/response-headers.md
Y como la `Response` puede ser usada frecuentemente para configurar headers y cookies, **FastAPI** también la provee en `fastapi.Response`. ## Headers Personalizados Ten en cuenta que se pueden añadir headers propietarios personalizados <a href="https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers" class="external-link" target="_blank">usando el prefijo 'X-'</a>.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Wed Feb 07 12:51:12 UTC 2024 - 2.5K bytes - Viewed (0) -
docs/en/docs/advanced/response-headers.md
And as the `Response` can be used frequently to set headers and cookies, **FastAPI** also provides it at `fastapi.Response`. ## Custom Headers Keep in mind that custom proprietary headers can be added <a href="https://developer.mozilla.org/en-US/docs/Web/HTTP/Headers" class="external-link" target="_blank">using the 'X-' prefix</a>.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Jan 11 16:31:18 UTC 2024 - 2.2K bytes - Viewed (0)