Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 162 for Websockets (0.1 sec)

  1. .github/workflows/mint/nginx.conf

                # This is necessary to pass the correct IP to be hashed
                real_ip_header X-Real-IP;
    
                proxy_connect_timeout 300;
                
                # To support websocket
                proxy_http_version 1.1;
                proxy_set_header Upgrade $http_upgrade;
                proxy_set_header Connection "upgrade";
                
                chunked_transfer_encoding off;
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 15 16:52:29 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  2. istioctl/pkg/proxyconfig/testdata/config_dump.json

                            "server_name": "istio-envoy",
                            "use_remote_address": false,
                            "upgrade_configs": [
                              {
                                "upgrade_type": "websocket"
                              }
                            ],
                            "stream_idle_timeout": "0s",
                            "normalize_path": true,
                            "request_id_extension": {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jan 03 23:08:06 UTC 2024
    - 54.8K bytes
    - Viewed (0)
  3. go.mod

    	github.com/google/shlex v0.0.0-20191202100458-e7afc7fbc510 // indirect
    	github.com/googleapis/enterprise-certificate-proxy v0.3.2 // indirect
    	github.com/googleapis/gax-go/v2 v2.13.0 // indirect
    	github.com/gorilla/websocket v1.5.3 // indirect
    	github.com/hashicorp/errwrap v1.1.0 // indirect
    	github.com/hashicorp/go-multierror v1.1.1 // indirect
    	github.com/hashicorp/go-uuid v1.0.3 // indirect
    	github.com/hashicorp/golang-lru v1.0.2 // indirect
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    // IsOnline - returns whether client failed to connect or not.
    func (client *storageRESTClient) IsOnline() bool {
    	return client.restClient.IsOnline() || client.IsOnlineWS()
    }
    
    // IsOnlineWS - returns whether websocket client failed to connect or not.
    func (client *storageRESTClient) IsOnlineWS() bool {
    	return client.gridConn.State() == grid.StateConnected
    }
    
    // LastConn - returns when the disk is seen to be connected the last time
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

    import okhttp3.internal.ws.WebSocketProtocol.validateCloseCode
    import okio.Buffer
    import okio.BufferedSink
    import okio.ByteString
    
    /**
     * An [RFC 6455][rfc_6455]-compatible WebSocket frame writer.
     *
     * This class is not thread safe.
     *
     * [rfc_6455]: http://tools.ietf.org/html/rfc6455
     */
    class WebSocketWriter(
      private val isClient: Boolean,
      val sink: BufferedSink,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  6. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockResponse.kt

        }
    
      fun withWebSocketUpgrade(listener: WebSocketListener) =
        apply {
          status = "HTTP/1.1 101 Switching Protocols"
          setHeader("Connection", "Upgrade")
          setHeader("Upgrade", "websocket")
          body = null
          webSocketListener = listener
        }
    
      override fun toString(): String = status
    
      companion object {
        private const val CHUNKED_BODY_HEADER = "Transfer-encoding: chunked"
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  7. internal/http/listener.go

    	Interface   string           // This is a VRF device passed via `--interface` flag
    	Trace       func(msg string) // Trace when starting.
    }
    
    // ForWebsocket returns TCPOptions valid for websocket net.Conn
    func (t TCPOptions) ForWebsocket() TCPOptions {
    	return TCPOptions{
    		UserTimeout: t.UserTimeout,
    		Interface:   t.Interface,
    		SendBufSize: t.SendBufSize,
    		RecvBufSize: t.RecvBufSize,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  8. internal/grid/grid.go

    		}
    		dialer.TLSConfig = tls
    
    		conn, br, _, err := dialer.Dial(ctx, toDial)
    		if br != nil {
    			ws.PutReader(br)
    		}
    		return conn, err
    	}
    }
    
    // ConnectWS returns a function that dials a websocket connection to the given address.
    // Route and auth are added to the connection.
    func ConnectWS(dial ContextDialer, auth AuthFn, tls *tls.Config) func(ctx context.Context, remote string) (net.Conn, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/Dispatcher.kt

       *
       * If more than [maxRequestsPerHost] requests are in flight when this is invoked, those requests
       * will remain in flight.
       *
       * WebSocket connections to hosts **do not** count against this limit.
       */
      var maxRequestsPerHost = 5
        get() = this.withLock { field }
        set(maxRequestsPerHost) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Jun 20 14:10:53 UTC 2024
    - 9K bytes
    - Viewed (0)
  10. docs/changelogs/changelog_4x.md

     [fun_interface]: https://kotlinlang.org/docs/reference/fun-interfaces.html
     [iana_websocket]: https://www.iana.org/assignments/websocket/websocket.txt
     [jetty_8_252]: https://webtide.com/jetty-alpn-java-8u252/
     [kotlin_1_3_71]: https://github.com/JetBrains/kotlin/releases/tag/v1.3.71
     [kotlin_1_4_10]: https://github.com/JetBrains/kotlin/releases/tag/v1.4.10
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
Back to top