- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 370 for Ticker (0.17 sec)
-
android/guava-testlib/src/com/google/common/testing/ArbitraryInstances.java
.put(com.google.common.base.Optional.class, com.google.common.base.Optional.absent()) .put(Predicate.class, Predicates.alwaysTrue()) .put(Equivalence.class, Equivalence.equals()) .put(Ticker.class, Ticker.systemTicker()) .put(Stopwatch.class, Stopwatch.createUnstarted()) // io types .put(InputStream.class, new ByteArrayInputStream(new byte[0]))
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 20.5K bytes - Viewed (0) -
cni/pkg/install/install_test.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0) -
internal/config/identity/plugin/config.go
} var ( healthCheckInterval = 1 * time.Minute healthCheckTimeout = 5 * time.Second ) func (o *AuthNPlugin) doPeriodicHealthCheck() { ticker := time.NewTicker(healthCheckInterval) defer ticker.Stop() for { select { case <-ticker.C: now := time.Now() isConnected := o.checkConnectivity(o.shutdownCtx) if isConnected { o.serviceMetrics.setConnSuccess(now) } else {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.3K bytes - Viewed (3) -
cmd/admin-handlers.go
keepConnLive := func(w http.ResponseWriter, r *http.Request, respCh chan healResp) { ticker := time.NewTicker(time.Second * 10) defer ticker.Stop() started := false forLoop: for { select { case <-r.Context().Done(): return case <-ticker.C: if !started { // Start writing response to client started = true setCommonHeaders(w)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
android/guava-testlib/src/com/google/common/testing/FreshValueGenerator.java
@Override public String toString() { return string; } }; } @Generates Ticker generateTicker() { return new Ticker() { @Override public long read() { return 0; } final String string = paramString(Ticker.class, generateInt()); @Override public String toString() { return string; } };
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 28K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
} return err } if waitReady { startTime := time.Now() ticker := time.NewTicker(1 * time.Second) defer ticker.Stop() for range ticker.C { programmed := false gwc, err := kubeClient.GatewayAPI().GatewayV1().Gateways(ctx.NamespaceOrDefault(ctx.Namespace())).Get(context.TODO(), gw.Name, metav1.GetOptions{})
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/metacache-set.go
go mc.setErr(err.Error()) cancel() } }() defer cancel() // Save continuous updates go func() { var err error ticker := time.NewTicker(10 * time.Second) defer ticker.Stop() var exit bool for !exit { select { case <-ticker.C: case <-ctx.Done(): exit = true } metaMu.Lock() meta := *mc.meta meta, err = o.updateMetacacheListing(meta, rpc)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java
import com.google.common.base.Equivalence; import com.google.common.base.Joiner; import com.google.common.base.Predicate; import com.google.common.base.Splitter; import com.google.common.base.Stopwatch; import com.google.common.base.Ticker; import com.google.common.collect.BiMap; import com.google.common.collect.ClassToInstanceMap; import com.google.common.collect.ImmutableBiMap; import com.google.common.collect.ImmutableClassToInstanceMap;
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 22.1K bytes - Viewed (0) -
cmd/lock-rest-server.go
// lockMaintenance loops over all locks and discards locks // that have not been refreshed for some time. func lockMaintenance(ctx context.Context) { if !globalIsDistErasure { return } // Initialize a new ticker with 1 minute between each ticks. lkTimer := time.NewTimer(lockMaintenanceInterval) // Stop the timer upon returning. defer lkTimer.Stop() for { // Verifies every minute for locks held more than 2 minutes.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
internal/s3select/message.go
return false } writer.writer.(http.Flusher).Flush() return true } func (writer *messageWriter) start() { keepAliveTicker := time.NewTicker(1 * time.Second) var progressTicker *time.Ticker var progressTickerC <-chan time.Time if writer.getProgressFunc != nil { progressTicker = time.NewTicker(1 * time.Minute) progressTickerC = progressTicker.C }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0)