- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 145 for Mickey (0.19 sec)
-
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) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/DefaultVersionResolver.java
info.repository = repository; info.timestamp = timestamp; } } private void merge(Map<String, VersionInfo> infos, String srcKey, String dstKey) { VersionInfo srcInfo = infos.get(srcKey); VersionInfo dstInfo = infos.get(dstKey); if (dstInfo == null || (srcInfo != null && dstInfo.isOutdated(srcInfo.timestamp)
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 20.2K bytes - Viewed (0) -
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 Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 21K bytes - Viewed (1) -
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) -
internal/bucket/lifecycle/lifecycle_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:11:10 GMT 2024 - 53.2K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/FreshValueGeneratorTest.java
import com.google.common.base.Equivalence; import com.google.common.base.Function; import com.google.common.base.Joiner; import com.google.common.base.Predicate; import com.google.common.base.Splitter; import com.google.common.base.Ticker; import com.google.common.collect.ArrayListMultimap; import com.google.common.collect.BiMap; import com.google.common.collect.HashBasedTable; import com.google.common.collect.HashBiMap;
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 18.4K bytes - Viewed (0) -
docs/bucket/replication/DESIGN.md
All replication failures are picked up by the scanner which runs at a one minute frequency, each time scanning upto a sixteenth of the namespace. Object versions marked `PENDING` or `FAILED` are re-queued for replication.
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 14.7K bytes - Viewed (0) -
internal/crypto/key.go
// UnsealETag unseals the etag using the provided object key. // It does not try to decrypt the ETag if len(etag) == 16 // because such ETags indicate that the S3 client hasn't sent // an ETag = MD5(object) and the backend has picked an ETag value. func (key ObjectKey) UnsealETag(etag []byte) ([]byte, error) { if !IsETagSealed(etag) { return etag, nil } mac := hmac.New(sha256.New, key[:]) mac.Write([]byte("SSE-etag"))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 20:28:10 GMT 2024 - 6.4K bytes - Viewed (0) -
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)