- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 58 for startTimer (0.39 sec)
-
maven-api-impl/src/test/java/org/apache/maven/internal/impl/standalone/ApiRunner.java
return injector.getInstance(Session.class); } static class DefaultSession extends AbstractSession { private final Map<String, String> systemProperties; private Instant startTime = Instant.now(); DefaultSession(RepositorySystemSession session, RepositorySystem repositorySystem, Lookup lookup) { this(session, repositorySystem, Collections.emptyList(), null, lookup); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 07:23:04 UTC 2024 - 17.1K bytes - Viewed (0) -
pkg/spiffe/spiffe.go
}).DialContext, IdleConnTimeout: 90 * time.Second, TLSHandshakeTimeout: 10 * time.Second, ExpectContinueTimeout: 1 * time.Second, } retryBackoffTime := firstRetryBackOffTime startTime := time.Now() var resp *http.Response for { resp, err = httpClient.Get(endpoint) var errMsg string if err != nil { errMsg = fmt.Sprintf("Calling %s failed with error: %v", endpoint, err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
private Exception exception; private volatile long startTime; private long timeSpentBlocked; TimedWaiterThread(AbstractFuture<?> future, long timeout, TimeUnit unit) { this.future = future; this.timeout = timeout; this.unit = unit; } @Override public void run() { startTime = System.nanoTime(); try { future.get(timeout, unit);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1/types_swagger_doc_generated.go
"activeDeadlineSeconds": "Specifies the duration in seconds relative to the startTime that the job may be continuously active before the system tries to terminate it; value must be positive integer. If a Job is suspended (at creation or through an update), this timer will effectively be stopped and reset when the Job is resumed again.",...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 12:01:28 UTC 2024 - 27.5K bytes - Viewed (0) -
cmd/kubeadm/app/phases/kubeconfig/kubeconfig.go
if err != nil { return nil, err } startTime := kubeadmutil.StartTimeUTC() notAfter := startTime.Add(kubeadmconstants.CertificateValidityPeriod) if cfg.ClusterConfiguration.CertificateValidityPeriod != nil { notAfter = startTime.Add(cfg.ClusterConfiguration.CertificateValidityPeriod.Duration) } return map[string]*kubeConfigSpec{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:04:18 UTC 2024 - 27K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
private Exception exception; private volatile long startTime; private long timeSpentBlocked; TimedWaiterThread(AbstractFuture<?> future, long timeout, TimeUnit unit) { this.future = future; this.timeout = timeout; this.unit = unit; } @Override public void run() { startTime = System.nanoTime(); try { future.get(timeout, unit);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
staging/src/k8s.io/api/batch/v1/generated.proto
// More info: https://kubernetes.io/docs/concepts/workloads/controllers/jobs-run-to-completion/ // +optional optional int32 completions = 2; // Specifies the duration in seconds relative to the startTime that the job // may be continuously active before the system tries to terminate it; value // must be positive integer. If a Job is suspended (at creation or through an
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 12:01:28 UTC 2024 - 29.1K bytes - Viewed (0) -
src/internal/trace/summary.go
} } } // Handle transition in. switch new { case GoRunning: // We started running. Record it. g.lastStartTime = ev.Time() if g.StartTime == 0 { g.StartTime = ev.Time() } case GoRunnable: g.lastRunnableTime = ev.Time() case GoWaiting: if st.Reason != "forever" { g.lastBlockTime = ev.Time() g.lastBlockReason = st.Reason
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 20.7K bytes - Viewed (0) -
pkg/apis/batch/types.go
// `JobSuccessPolicy` feature gate (disabled by default). // +optional SuccessPolicy *SuccessPolicy // Specifies the duration in seconds relative to the startTime that the job // may be continuously active before the system tries to terminate it; value // must be positive integer. If a Job is suspended (at creation or through an
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 12:01:28 UTC 2024 - 33K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
if errors.IsNotFound(err) { return fmt.Errorf("missing Kubernetes Gateway CRDs need to be installed before applying a waypoint: %s", err) } return err } if waitReady { startTime := time.Now() ticker := time.NewTicker(1 * time.Second) defer ticker.Stop() for range ticker.C { programmed := false
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 15:59:33 UTC 2024 - 16.4K bytes - Viewed (0)