- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 971 for handle (0.07 sec)
-
internal/grid/README.md
The result will be discarded. ### Typed handlers Typed handlers are handlers that have a specific type for the request and response payloads. These must provide `msgp` serialization and deserialization. In the examples we use a `MSS` type, which is a `map[string]string` that is `msgp` serializable. ```go handler := func(request *grid.MSS) (*grid.MSS, *grid.RemoteErr) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 9.4K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
s := &CniPluginServer{ handlers: handlers, dataplane: dataplane, cniListenServer: &http.Server{ Handler: mux, }, cniListenServerCancel: cancel, sockAddress: pluginSocket, ctx: ctx, } mux.HandleFunc(pconstants.CNIAddEventPath, s.handleAddEvent) return s } func (s *CniPluginServer) Stop() { s.cniListenServerCancel() }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Jul 02 18:48:50 UTC 2024 - 6.7K bytes - Viewed (0) -
internal/grid/connection_test.go
} errFatal := func(err error) { t.Helper() if err != nil { t.Fatal(err) } } wrapServer := func(handler http.Handler) http.Handler { return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { t.Logf("Got a %s request for: %v", r.Method, r.URL) handler.ServeHTTP(w, r) }) } connReady := make(chan struct{}) // We fake a local and remote server. localHost := hosts[0]
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 08 21:44:00 UTC 2024 - 5.9K bytes - Viewed (0) -
internal/config/certsinfo.go
package config import ( "crypto/x509" "crypto/x509/pkix" "fmt" "net/http" "strings" color "github.com/minio/minio/internal/color" ) // Extra ASN1 OIDs that we may need to handle var ( oidEmailAddress = []int{1, 2, 840, 113549, 1, 9, 1} ) // printName prints the fields of a distinguished name, which include such // things as its common name and locality.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Nov 16 17:28:29 UTC 2021 - 3.1K bytes - Viewed (0) -
docs/zh/docs/tutorial/dependencies/dependencies-with-yield.md
participant client as Client participant handler as Exception handler participant dep as Dep with yield participant operation as Path Operation participant tasks as Background tasks Note over client,operation: Can raise exceptions, including HTTPException client ->> dep: Start request Note over dep: Run code up to yield opt raise Exception dep -->> handler: Raise Exception
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 13.3K bytes - Viewed (0) -
src/main/java/jcifs/smb/JAASAuthenticator.java
getSubject(); return this; } /** * {@inheritDoc} * * @see javax.security.auth.callback.CallbackHandler#handle(javax.security.auth.callback.Callback[]) */ @Override public void handle ( Callback[] callbacks ) throws IOException, UnsupportedCallbackException { for ( Callback cb : callbacks ) { if ( log.isDebugEnabled() ) {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 8.1K bytes - Viewed (0) -
docs/en/docs/how-to/custom-docs-ui-assets.md
You can probably right-click each link and select an option similar to `Save link as...`. **Swagger UI** uses the files: * <a href="https://cdn.jsdelivr.net/npm/swagger-ui-dist@5/swagger-ui-bundle.js" class="external-link" target="_blank">`swagger-ui-bundle.js`</a> * <a href="https://cdn.jsdelivr.net/npm/swagger-ui-dist@5/swagger-ui.css" class="external-link" target="_blank">`swagger-ui.css`</a> And **ReDoc** uses the file:
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Mon Oct 28 10:42:34 UTC 2024 - 7.3K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/YubikeyClientAuth.kt
if (!response.isSuccessful) throw IOException("Unexpected code $response") println(response.body.string()) } } } object ConsoleCallbackHandler : CallbackHandler { override fun handle(callbacks: Array<Callback>) { for (callback in callbacks) { if (callback is PasswordCallback) { val console = System.console() if (console != null) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
import java.util.concurrent.Executor; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import javax.annotation.CheckForNull; /** * Base class for implementing services that can handle {@link #doStart} and {@link #doStop} * requests, responding to them with {@link #notifyStarted()} and {@link #notifyStopped()} * callbacks. Its subclasses must manage threads manually; consider {@link
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.4K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ReaderInputStream.java
return bigger; } /** Handle the case of underflow caused by needing more input characters. */ private void readMoreChars() throws IOException { // Possibilities: // 1) array has space available on right-hand side (between limit and capacity) // 2) array has space available on left-hand side (before position) // 3) array has no space available //
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 9.3K bytes - Viewed (0)