- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for clients (0.16 sec)
-
docs/en/docs/advanced/websockets.md
To try it out: * Open the app with several browser tabs. * Write messages from them. * Then close one of the tabs. That will raise the `WebSocketDisconnect` exception, and all the other clients will receive a message like: ``` Client #1596980209979 left the chat ``` !!! tip The app above is a minimal and simple example to demonstrate how to handle and broadcast messages to several WebSocket connections.
Plain Text - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu May 02 22:37:31 GMT 2024 - 6.2K bytes - Viewed (0) -
internal/http/dial_linux.go
// https://blog.cloudflare.com/when-tcp-sockets-refuse-to-die/ // This is a sensitive configuration, it is better to set it to high values, > 60 secs since it can // affect clients reading data with a very slow pace (disappropriate with socket buffer sizes) _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_USER_TIMEOUT, opts.UserTimeout) if opts.Interface != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 4.3K bytes - Viewed (3) -
docs/en/mkdocs.yml
- advanced/testing-database.md - advanced/async-tests.md - advanced/settings.md - advanced/openapi-callbacks.md - advanced/openapi-webhooks.md - advanced/wsgi.md - advanced/generate-clients.md - fastapi-cli.md - Deployment: - deployment/index.md - deployment/versions.md - deployment/https.md - deployment/manually.md - deployment/concepts.md - deployment/cloud.md
Others - Registered: Sun May 05 07:19:11 GMT 2024 - Last Modified: Thu May 02 22:37:31 GMT 2024 - 9.1K bytes - Viewed (0) -
gradle/libs.versions.toml
guava-jre = "com.google.guava:guava:33.1.0-jre" hamcrestLibrary = "org.hamcrest:hamcrest-library:2.2" httpClient5 = "org.apache.httpcomponents.client5:httpclient5:5.3" jettyClient = "org.eclipse.jetty:jetty-client:9.4.54.v20240208" jnr-unixsocket = "com.github.jnr:jnr-unixsocket:0.38.22" jsoup = "org.jsoup:jsoup:1.17.2" junit = "junit:junit:4.13.2" junit-ktx = "androidx.test.ext:junit-ktx:1.1.5"
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 22 19:34:32 GMT 2024 - 7.2K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
client := kube.NewFakeClient(ns, pod) // We are expecting at most 1 calls to the mock, wait for them wg, waitForMockCalls := NewWaitForNCalls(t, 1) fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, pod, util.GetPodIPsIfPresent(pod), valid.Netns, ).Return(nil) dpServer := &meshDataplane{ kubeClient: client.Kube(), netServer: fs, }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 5.4K bytes - Viewed (0) -
docs/ftp/README.md
# MinIO FTP/SFTP Server MinIO natively supports FTP/SFTP protocol, this allows any ftp/sftp client to upload and download files. Currently supported `FTP/SFTP` operations are as follows: | ftp-client commands | supported | |:-------------------:|:----------| | get | yes | | put | yes | | ls | yes | | mkdir | yes | | rmdir | yes |
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:15:45 GMT 2024 - 7.1K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
ctx context.Context kubeClient kube.Client handlers K8sHandlers dataplane MeshDataplane isReady *atomic.Value cniServerStopFunc func() } func NewServer(ctx context.Context, ready *atomic.Value, pluginSocket string, args AmbientArgs) (*Server, error) { client, err := buildKubeClient(args.KubeConfig) if err != nil { return nil, fmt.Errorf("error initializing kube client: %w", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
architecture/runtimes.md
- CLI client. This is the `gradle` or `gradlew` command, and is responsible for locating, starting and interacting with the Gradle daemon, potentially downloading the Gradle distribution. - Tooling API client. This a library that is embedded into applications, such as IDEs or CI agents, that allows them to act as a Gradle client.
Plain Text - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Thu May 02 06:42:46 GMT 2024 - 2.3K bytes - Viewed (0) -
istioctl/pkg/util/ambient/util.go
"istio.io/api/label" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/kube" ) func IsZtunnelPod(client kube.CLIClient, podName, podNamespace string) bool { isZtunnel := strings.HasPrefix(podName, "ztunnel") if client == nil { return isZtunnel } pod, err := client.Kube().CoreV1().Pods(podNamespace).Get(context.Background(), podName, metav1.GetOptions{}) if err != nil { return isZtunnel }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 21:29:40 GMT 2024 - 1.7K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
ctx context.Context dataplane MeshDataplane systemNamespace string queue controllers.Queue pods kclient.Client[*corev1.Pod] namespaces kclient.Client[*corev1.Namespace] } func setupHandlers(ctx context.Context, kubeClient kube.Client, dataplane MeshDataplane, systemNamespace string) *InformerHandlers { s := &InformerHandlers{ctx: ctx, dataplane: dataplane, systemNamespace: systemNamespace}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0)