- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 419 for attempted (0.07 seconds)
-
internal/event/target/kafka_scram_client_contrib.go
if err != nil { return err } x.ClientConversation = x.NewConversation() return nil } // Step takes a string provided from a server (or just an empty string for the // very first conversation step) and attempts to move the authentication // conversation forward. It returns a string to be sent to the server or an // error if the server message is invalid. Calling Step after a conversation // completes is also an error.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 3.2K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.14.md
* kubeadm now attempts to detect an installed CRI by its usual domain socket, so that --cri-socket can be omitted from the command line if Docker is not...
Created: Fri Dec 26 09:05:12 GMT 2025 - Last Modified: Mon Jun 14 22:06:39 GMT 2021 - 271.5K bytes - Click Count (0) -
cmd/batch-expire.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Apr 22 11:16:32 GMT 2025 - 23K bytes - Click Count (0) -
internal/rest/client.go
// Protect against integer overflow panic("unit cannot exceed one hour") } return func(attempt uint) time.Duration { if attempt > 16 { // Protect against integer overflow attempt = 16 } // sleep = random_between(unit, min(cap, base * 2 ** attempt)) sleep := min(unit*time.Duration(1<<attempt), maxSleep) sleep -= time.Duration(r.Float64() * float64(sleep-unit)) return sleep } }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 14.7K bytes - Click Count (0) -
internal/logger/target/kafka/kafka_scram_client_contrib.go
if err != nil { return err } x.ClientConversation = x.NewConversation() return nil } // Step takes a string provided from a server (or just an empty string for the // very first conversation step) and attempts to move the authentication // conversation forward. It returns a string to be sent to the server or an // error if the server message is invalid. Calling Step after a conversation // completes is also an error.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 3.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
* * <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 * {@code Future} is cancelled, it will attempt to cancel the other two, and if either of the * other two is cancelled, the returned {@code Future} will receive a callback in which it will * attempt to cancel itself. *Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 19.7K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.23.md
- Fixed bug where using kubectl patch with $deleteFromPrimitiveList on a nonexistent or empty list would add the item to the list (#105421, @brianpursley) [SIG API Machinery]
Created: Fri Dec 26 09:05:12 GMT 2025 - Last Modified: Tue Feb 28 21:06:52 GMT 2023 - 424.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/TrailersTest.kt
} /** * If the client closes the connection while it is consuming the response body, attempts to peek * or read the trailers should throw. * * This test needs to make two interventions to prevent OkHttp from reading the entire response * body, which it will attempt to do otherwise: * * * Don't cache the response. The cache will try to read the entire response body so that it
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 08 21:45:04 GMT 2025 - 18.8K bytes - Click Count (0) -
android/guava/src/com/google/common/net/HostSpecifier.java
return new HostSpecifier(domain.toString()); } throw new IllegalArgumentException( "Domain name does not have a recognized public suffix: " + host); } /** * Attempts to return a {@code HostSpecifier} for the given string, throwing an exception if * parsing fails. Always use this method in preference to {@link #fromValid(String)} for a * specifier that is not already known to be valid.
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 6K bytes - Click Count (0) -
CHANGELOG.md
| com.squareup.okhttp3:mockwebserver:5.0.0 | okhttp3.mockwebserver | Obsolete. Depends on JUnit 4. | **OkHttp now supports Happy Eyeballs ([RFC 8305][rfc_8305]) for IPv4+IPv6 networks.** It attempts both IPv6 and IPv4 connections concurrently, keeping whichever connects first. **We’ve improved our Kotlin APIs.** You can skip the builder: ```kotlin val request = Request(
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 05 16:02:59 GMT 2025 - 36.2K bytes - Click Count (2)