- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 423 for keep (0.03 sec)
-
cmd/metrics-v3.go
} // Bucket metrics are special, they always include the bucket label. These // metrics required a list of buckets to be passed to the loader, and the list // of buckets is not known until the request is made. So we keep a separate // map for bucket metrics and handle them specially. // Add the serverName and poolIndex labels to all non-cluster metrics. // // Also create metric group maps and set the cache.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Aug 02 00:55:27 UTC 2024 - 13.6K bytes - Viewed (0) -
cmd/storage-rest-client.go
// return 503 server closed error, consider it as an offline node case strings.Contains(err.Error(), http.ErrServerClosed.Error()): return true // Corner case, the server closed the connection with a keep-alive timeout // some requests are not retried internally, such as POST request with written body case strings.Contains(err.Error(), "server closed idle connection"): return true } return false }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Oct 13 13:07:21 UTC 2024 - 30.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FluentFuture.java
* AsyncFunction.apply}. Any heavyweight operations should occur in other threads responsible for * completing the returned {@code Future}.) * * <p>The returned {@code Future} attempts to keep its cancellation state in sync with that of the * input future and that of the future returned by the chain function. That is, if the returned
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 19.6K bytes - Viewed (0) -
cni/pkg/cmd/root.go
repair.StartRepair(ctx, cfg.RepairConfig) log.Info("initialization complete, watching node CNI dir") // installer.Run() will block indefinitely, and attempt to permanently "keep" // the CNI binary installed. if err = installer.Run(ctx); err != nil { if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) { log.Infof("installer complete: %v", err)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Aug 16 15:33:47 UTC 2024 - 12.7K bytes - Viewed (0) -
.github/actions/notify-translations/app/main.py
) -> Dict[str, Any]: headers = {"Authorization": f"token {settings.input_token.get_secret_value()}"} # some fields are only used by one query, but GraphQL allows unused variables, so # keep them here for simplicity variables = { "after": after, "category_id": category_id, "discussion_number": discussion_number, "discussion_id": discussion_id,
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Jul 29 23:35:07 UTC 2024 - 12.4K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/FeatureSpecificTestSuiteBuilder.java
* * <p>Note: in principle this should never need to be used, but it might be useful if the * semantics of an implementation disagree in unforeseen ways with the semantics expected by a * test, or to keep dependent builds clean in spite of an erroneous test. */ @CanIgnoreReturnValue public B suppressing(Method... methods) { return suppressing(asList(methods)); } @CanIgnoreReturnValue
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 10.4K bytes - Viewed (0) -
guava/src/com/google/common/base/Stopwatch.java
* behavior of the stopwatch. * * <p><b>Note:</b> This class is not thread-safe. * * <p><b>Warning for Android users:</b> a stopwatch with default behavior may not continue to keep * time while the device is asleep. Instead, create one like this: * * <pre>{@code * Stopwatch.createStarted( * new Ticker() { * public long read() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 31 14:20:11 UTC 2024 - 9.3K bytes - Viewed (0) -
callbacks/query.go
if v, ok := db.Statement.Clauses["FROM"].Expression.(clause.From); ok { fromClause := db.Statement.Clauses["FROM"] fromClause.Expression = clause.From{Tables: v.Tables, Joins: utils.RTrimSlice(v.Joins, len(db.Statement.Joins))} // keep the original From Joins db.Statement.Clauses["FROM"] = fromClause } if db.Error == nil && db.Statement.Schema != nil && !db.Statement.SkipHooks && db.Statement.Schema.AfterFind && db.RowsAffected > 0 {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Aug 22 11:03:42 UTC 2024 - 10.1K bytes - Viewed (1) -
docs/features/events.md
`callStartNanos`, to track the elapsed time of each event. This is handy, but it won’t work if multiple calls are executing concurrently. To accommodate this, use a `Factory` to create a new `EventListener` instance for each `Call`. This allows each listener to keep call-specific state. This [sample factory](https://github.com/square/okhttp/blob/master/samples/guide/src/main/java/okhttp3/recipes/PrintEvents.java) creates a unique ID for each call and uses that ID to differentiate calls in log messages....
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 7.7K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/Hashing.java
* assign all the old {@code alpha} traffic to {@code bravo} and all the old {@code bravo} * traffic to {@code charlie}, rather than letting {@code bravo} keep its traffic. * </ul> * * <p>See the <a href="http://en.wikipedia.org/wiki/Consistent_hashing">Wikipedia article on * consistent hashing</a> for more information. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jul 19 16:02:36 UTC 2024 - 29.3K bytes - Viewed (0)