- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 185 for timeFn (0.14 sec)
-
pkg/controller/deployment/util/deployment_util_test.go
nowFn: func() time.Time { return timeFn(1, 20) }, expected: true, }, { name: "progressDeadlineSeconds: 10s, now - started => 00:01:20 - 00:01:11 => 9s", d: deployment(apps.DeploymentProgressing, v1.ConditionTrue, "", &ten, timeFn(1, 11)), nowFn: func() time.Time { return timeFn(1, 20) }, expected: false, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 08 09:10:50 UTC 2023 - 37.1K bytes - Viewed (0) -
src/runtime/time.go
return when } // check runs any timers in ts that are ready. // If now is not 0 it is the current time. // It returns the passed time or the current time if now was passed as 0. // and the time when the next timer should run or 0 if there is no next timer, // and reports whether it ran any timers. // If the time when the next timer should run is not 0, // it is always larger than the returned time.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 29 14:36:24 UTC 2024 - 37.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/timer.go
type Timer interface { // C returns a channel that will receive a struct{} each time the timer fires. // The channel should not be waited on after Stop() is invoked. It is allowed // to cache the returned value of C() for the lifetime of the Timer. C() <-chan time.Time // Next is invoked by wait functions to signal timers that the next interval // should begin. You may only use Next() if you have drained the channel C().
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 19:14:11 UTC 2023 - 2.9K bytes - Viewed (0) -
platforms/core-runtime/time/src/main/java/org/gradle/internal/time/Time.java
* and are therefore not synchronized with {@link #clock()} or the system wall clock. * * System.nanoTime() does not consider time elapsed while the system is in hibernation. * Therefore, timers effectively measure the elapsed time, of which the system was awake. */ public static Timer startTimer() { return new DefaultTimer(TimeSource.SYSTEM); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 20:20:17 UTC 2024 - 2.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/loop.go
// // This is the common loop construct for all polling in the wait package. func loopConditionUntilContext(ctx context.Context, t Timer, immediate, sliding bool, condition ConditionWithContextFunc) error { defer t.Stop() var timeCh <-chan time.Time doneCh := ctx.Done() if !sliding { timeCh = t.C() } // if immediate is true the condition is // guaranteed to be executed at least once,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 02:47:00 UTC 2023 - 2.8K bytes - Viewed (0) -
src/time/time.go
// // Programs using times should typically store and pass them as values, // not pointers. That is, time variables and struct fields should be of // type [time.Time], not *time.Time. // // A Time value can be used by multiple goroutines simultaneously except // that the methods [Time.GobDecode], [Time.UnmarshalBinary], [Time.UnmarshalJSON] and // [Time.UnmarshalText] are not concurrency-safe. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 50.7K bytes - Viewed (0) -
platforms/core-runtime/time/src/main/java/org/gradle/internal/time/Timer.java
*/ package org.gradle.internal.time; public interface Timer { /** * @return A human-consumable description of the elapsed time. */ String getElapsed(); /** * Return the elapsed time in ms. Returned value is always >= 0. * @return The elapsed time, in ms. */ long getElapsedMillis(); /** * Restart this timer. Sets elapsed time to zero. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 20:20:17 UTC 2024 - 1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/time.go
} return false } // Unix returns the local time corresponding to the given Unix time // by wrapping time.Unix. func Unix(sec int64, nsec int64) Time { return Time{time.Unix(sec, nsec)} } // Rfc3339Copy returns a copy of the Time at second-level precision. func (t Time) Rfc3339Copy() Time { copied, _ := time.Parse(time.RFC3339, t.Format(time.RFC3339)) return Time{copied} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 21:48:09 UTC 2024 - 5.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/loop_test.go
}) } } type timerWrapper struct { timer clock.Timer resets []time.Duration onReset func(d time.Duration) } func (w *timerWrapper) C() <-chan time.Time { return w.timer.C() } func (w *timerWrapper) Stop() bool { return w.timer.Stop() } func (w *timerWrapper) Reset(d time.Duration) bool { w.resets = append(w.resets, d) b := w.timer.Reset(d) if w.onReset != nil { w.onReset(d) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 02:48:08 UTC 2023 - 15.8K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/internal/upload/date.go
} timeEnd, ok := parsed.Meta["TimeEnd"] if !ok { return time.Time{}, time.Time{}, fmt.Errorf("missing counter metadata for TimeEnd") } end, err = time.Parse(time.RFC3339, timeEnd) if err != nil { return time.Time{}, time.Time{}, fmt.Errorf("failed to parse TimeEnd: %v", err) } return begin, end, nil } // avoid parsing count files multiple times type parsedCache struct { mu sync.Mutex
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 21:12:15 UTC 2024 - 2.2K bytes - Viewed (0)