Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 133 for streaming (0.09 sec)

  1. CHANGELOG/CHANGELOG-1.6.md

    * Use full package path for definition name in OpenAPI spec ([#40124](https://github.com/kubernetes/kubernetes/pull/40124), [@mbohlool](https://github.com/mbohlool))
    * Follow redirects for streaming requests (exec/attach/port-forward) in the apiserver by default (alpha -> beta). ([#40039](https://github.com/kubernetes/kubernetes/pull/40039), [@timstclair](https://github.com/timstclair))
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 304K bytes
    - Viewed (0)
  2. cmd/testdata/undeleteable-object.tgz

    key":"tls","value":"off"},{"key":"tls_skip_verify","value":"off"},{"key":"cert_authority","value":""},{"key":"client_cert","value":""},{"key":"client_key","value":""},{"key":"ping_interval","value":"0"},{"key":"jetstream","value":"off"},{"key":"streaming","value":"off"},{"key":"streaming_async","value":"off"},{"key":"streaming_max_pub_acks_in_flight","value":"0"},{"key":"streaming_cluster_id","value":""},{"key":"queue_dir","value":""},{"key":"queue_limit","value":"0"}]},"notify_nsq":{"_":[{"key"...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 26 00:31:12 UTC 2024
    - 8.7M bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt

            logger.fine(
              frameLogWindowUpdate(
                inbound = false,
                streamId = streamId,
                length = 4,
                windowSizeIncrement = windowSizeIncrement,
              ),
            )
          }
          frameHeader(
            streamId = streamId,
            length = 4,
            type = TYPE_WINDOW_UPDATE,
            flags = FLAG_NONE,
          )
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

        streamId: Int,
        requestHeaders: List<Header>,
      ) {
        this.withLock {
          if (streamId in currentPushRequests) {
            writeSynResetLater(streamId, ErrorCode.PROTOCOL_ERROR)
            return
          }
          currentPushRequests.add(streamId)
        }
        pushQueue.execute("$connectionName[$streamId] onRequest") {
          val cancel = pushObserver.onRequest(streamId, requestHeaders)
          ignoreIoExceptions {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

          inFinished: Boolean,
          streamId: Int,
          source: BufferedSource,
          length: Int,
        ) {
          check(type == -1)
          this.type = Http2.TYPE_DATA
          this.inFinished = inFinished
          this.streamId = streamId
          this.data = source.readByteString(length.toLong()).toByteArray()
        }
    
        override fun rstStream(
          streamId: Int,
          errorCode: ErrorCode,
        ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

          TYPE_DATA -> readData(handler, length, flags, streamId)
          TYPE_HEADERS -> readHeaders(handler, length, flags, streamId)
          TYPE_PRIORITY -> readPriority(handler, length, flags, streamId)
          TYPE_RST_STREAM -> readRstStream(handler, length, flags, streamId)
          TYPE_SETTINGS -> readSettings(handler, length, flags, streamId)
          TYPE_PUSH_PROMISE -> readPushPromise(handler, length, flags, streamId)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

      }
    
      @Test fun streamIdHasReservedBit() {
        val writer = Http2Writer(Buffer(), true)
        assertFailsWith<IllegalArgumentException> {
          var streamId = 3
          streamId = streamId or (1L shl 31).toInt() // set reserved bit
          writer.frameHeader(streamId, Http2.INITIAL_MAX_FRAME_SIZE, Http2.TYPE_DATA, FLAG_NONE)
        }.also { expected ->
          assertThat(expected.message).isEqualTo("reserved bit set: -2147483645")
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/http2/BaseTestHandler.kt

      override fun data(
        inFinished: Boolean,
        streamId: Int,
        source: BufferedSource,
        length: Int,
      ) {
        fail("")
      }
    
      override fun headers(
        inFinished: Boolean,
        streamId: Int,
        associatedStreamId: Int,
        headerBlock: List<Header>,
      ) {
        fail("")
      }
    
      override fun rstStream(
        streamId: Int,
        errorCode: ErrorCode,
      ) {
        fail("")
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.19.md

    ### (No, really, you MUST read this before you upgrade)
    
    - The StreamingProxyRedirects feature and `--redirect-container-streaming` flag are deprecated, and will be removed in a future release. The default behavior (proxy streaming requests through the kubelet) will be the only supported option.
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Jan 05 05:42:32 UTC 2022
    - 489.7K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt

       *
       * ```
       * direction streamID length type flags
       * ```
       *
       * Where direction is `<<` for inbound and `>>` for outbound.
       *
       * For example, the following would indicate a HEAD request sent from the client.
       * ```
       * `<< 0x0000000f    12 HEADERS       END_HEADERS|END_STREAM
       * ```
       */
      fun frameLog(
        inbound: Boolean,
        streamId: Int,
        length: Int,
        type: Int,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.7K bytes
    - Viewed (0)
Back to top