- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for isLeader (0.15 sec)
-
cmd/kube-scheduler/app/server.go
configz.InstallHandler(pathRecorderMux) pathRecorderMux.Handle("/metrics", legacyregistry.HandlerWithReset()) resourceMetricsHandler := resources.Handler(informers.Core().V1().Pods().Lister()) pathRecorderMux.HandleFunc("/metrics/resources", func(w http.ResponseWriter, req *http.Request) { if !isLeader() { return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 14.3K bytes - Viewed (0) -
src/cmd/compile/internal/ssagen/pgen.go
fmt.Fprintf(os.Stderr, "=-= sorted DCL for %v:\n", fn) for i, v := range fn.Dcl { if !ssa.IsMergeCandidate(v) { continue } fmt.Fprintf(os.Stderr, " %d: %q isleader=%v subsumed=%v used=%v sz=%d align=%d t=%s\n", i, v.Sym().Name, mls.IsLeader(v), mls.Subsumed(v), v.Used(), v.Type().Size(), v.Type().Alignment(), v.Type().String()) } } // Reassign stack offsets of the locals that are used. lastHasPtr := false
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/k8sleaderelection/leaderelection.go
func (le *LeaderElector) GetLeader() string { return le.getObservedRecord().HolderIdentity } // IsLeader returns true if the last observed leader was this client else returns false. func (le *LeaderElector) IsLeader() bool { return le.getObservedRecord().HolderIdentity == le.config.Lock.Identity() }
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/leaderelection_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 28 04:22:19 UTC 2024 - 11.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/convert_control_to_data_outputs.cc
for (auto class_iter = resource_equivalence_classes.begin(); class_iter != resource_equivalence_classes.end(); ++class_iter) { // Only visit one element per class, the leader. if (!class_iter->isLeader()) continue; // Create chain source and sink identity islands for current equivalence // class. auto chain_arg = func.getArgument(chain_index++);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 28.7K bytes - Viewed (0) -
subprojects/diagnostics/src/test/groovy/org/gradle/api/tasks/diagnostics/internal/insight/DependencyInsightReporterSpec.groovy
when: def sorted = reporter.convertToRenderableItems(dependencies, false) then: sorted.size() == 2 verify(sorted[0]) { selected 'group:a:1.0' isHeader() noMoreChildren() } verify(sorted[1]) { selected 'group:a:1.0' isNotHeader() hasChild('group:b:1.0') { noMoreChildren()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Nov 22 04:22:29 UTC 2023 - 10.3K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/project/interpolation/AbstractStringBasedModelInterpolator.java
serializedModel = interpolate(serializedModel, model, projectDir, config, debugEnabled); StringReader sReader = new StringReader(serializedModel); MavenStaxReader modelReader = new MavenStaxReader(); try { model = new Model(modelReader.read(sReader)); } catch (XMLStreamException e) { throw new ModelInterpolationException(
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 13.5K bytes - Viewed (0) -
internal/grid/connection.go
if err := controlHandler(hdr, &wsReader); err != nil { return nil, err } continue } if hdr.OpCode&want == 0 { if err := wsReader.Discard(); err != nil { return nil, err } continue } if int64(cap(dst)) < hdr.Length+1 { dst = make([]byte, 0, hdr.Length+hdr.Length>>3) } return readAllInto(dst[:0], &wsReader) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
cluster/addons/addon-manager/kube-addons.sh
-l ${ADDON_MANAGER_LABEL}=EnsureExists --recursive 2>&1 | grep -v AlreadyExists log INFO "== Kubernetes addon ensure completed at $(date -Is) ==" } function is_leader() { # In multi-master setup, only one addon manager should be running. We use # existing leader election in kube-controller-manager instead of implementing # a separate mechanism here.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Oct 15 05:40:38 UTC 2023 - 10.4K bytes - Viewed (0) -
src/runtime/race/testdata/mop_test.go
}(v) c <- true }() v = 42 <-c } type OsFile struct{} func (*OsFile) Read() { } type IoReader interface { Read() } func TestRaceIfaceConv(t *testing.T) { c := make(chan bool) f := &OsFile{} go func() { go func(x IoReader) { }(f) c <- true }() f = &OsFile{} <-c } func TestRaceError(t *testing.T) { ch := make(chan bool, 1)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 23 16:46:25 UTC 2023 - 28.9K bytes - Viewed (0)