- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of about 10,000 for recur1 (0.37 sec)
-
pkg/monitoring/base.go
} func (f baseMetric) Name() string { return f.name } func (f baseMetric) Increment() { f.rest.Record(1) } func (f baseMetric) Decrement() { f.rest.Record(-1) } func (f baseMetric) runRecordHook(value float64) { recordHookMutex.RLock() if rh, ok := recordHooks[f.name]; ok { lv := slices.Map(f.attrs, func(e attribute.KeyValue) LabelValue { return LabelValue{e} })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 1.7K bytes - Viewed (0) -
pkg/kubelet/oom/oom_watcher_linux.go
// the oom streamer. func NewWatcher(recorder record.EventRecorder) (Watcher, error) { // for test purpose _, ok := recorder.(*record.FakeRecorder) if ok { return nil, nil } oomStreamer, err := oomparser.New() if err != nil { return nil, err } watcher := &realWatcher{ recorder: recorder, oomStreamer: oomStreamer, } return watcher, nil } const (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Nov 08 23:17:05 UTC 2022 - 2.3K bytes - Viewed (0) -
src/testing/slogtest/slogtest.go
func hasKey(key string) check { return func(m map[string]any) string { if _, ok := m[key]; !ok { return fmt.Sprintf("missing key %q", key) } return "" } } func missingKey(key string) check { return func(m map[string]any) string { if _, ok := m[key]; ok { return fmt.Sprintf("unexpected key %q", key) } return "" } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 08 17:55:47 UTC 2023 - 9.8K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/trace/BuildOperationTree.java
for (BuildOperationRecord record : roots) { visit(records, record); } this.roots = BuildOperationRecord.ORDERING.immutableSortedCopy(roots); this.records = records.build(); } private void visit(ImmutableMap.Builder<Long, BuildOperationRecord> records, BuildOperationRecord record) { records.put(record.id, record);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Mar 07 09:24:42 UTC 2018 - 1.9K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/DefaultVersionResolver.java
Object obj = cache.get(session, cacheKey); if (obj instanceof Record) { Record record = (Record) obj; result.setVersion(record.version); result.setRepository( getRepository(session, request.getRepositories(), record.repoClass, record.repoId)); return result; } } Metadata metadata;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 20.2K bytes - Viewed (0) -
pkg/kubelet/active_deadline.go
// no active deadline was specified if pod.Spec.ActiveDeadlineSeconds == nil { return false } // get the latest status to determine if it was started podStatus, ok := m.podStatusProvider.GetPodStatus(pod.UID) if !ok { podStatus = pod.Status } // we have no start time so just return if podStatus.StartTime.IsZero() { return false } // determine if the deadline was exceeded start := podStatus.StartTime.Time
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 10 10:20:09 UTC 2021 - 3.2K bytes - Viewed (0) -
internal/s3select/parquet/reader.go
fr, err := parquetgo.NewFileReader(rsc) if err != nil { return nil, errParquetParsingError(err) } return &Reader{Closer: rsc, r: fr}, nil } func (pr *Reader) Read(dst sql.Record) (rec sql.Record, rerr error) { nextRow, err := pr.r.NextRow() if err != nil { if err == io.EOF { return nil, err } return nil, errParquetParsingError(err) } kvs := jstream.KVS{}
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Apr 14 13:54:47 UTC 2022 - 4.5K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/base/LazyStackTraceBenchmark.java
throw new SkipThisScenarioException(); } } @Benchmark public boolean timeFindCaller(int reps) { return timeFindCaller(reps, recursionCount); } private boolean timeFindCaller(int reps, int recurse) { return recurse > 0 ? timeFindCaller(reps, recurse - 1) : mode.timeIt(reps, breakAt); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 2.5K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/base/LazyStackTraceBenchmark.java
throw new SkipThisScenarioException(); } } @Benchmark public boolean timeFindCaller(int reps) { return timeFindCaller(reps, recursionCount); } private boolean timeFindCaller(int reps, int recurse) { return recurse > 0 ? timeFindCaller(reps, recurse - 1) : mode.timeIt(reps, breakAt); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 2.5K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
Endpoint string Secure bool Err error } func (rs *replStat) endpoint() string { scheme := "http" if rs.Secure { scheme = "https" } return scheme + "://" + rs.Endpoint } func (rs *replStat) set(arn string, n int64, duration time.Duration, status replication.StatusType, opType replication.Type, endpoint string, secure bool, err error) { rs.Endpoint = endpoint
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 13.4K bytes - Viewed (0)