Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 1,181 for reaper (0.14 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/streaming-signature-v4.go

    	if len(wantTrailers) > 0 {
    		return io.ErrUnexpectedEOF
    	}
    	return nil
    }
    
    // readCRLF - check if reader only has '\r\n' CRLF character.
    // returns malformed encoding if it doesn't.
    func readCRLF(reader io.Reader) error {
    	buf := make([]byte, 2)
    	_, err := io.ReadFull(reader, buf[:2])
    	if err != nil {
    		return err
    	}
    	if buf[0] != '\r' || buf[1] != '\n' {
    		return errMalformedEncoding
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.2K bytes
    - Click Count (0)
  2. internal/crypto/sse.go

    	return key, err
    }
    
    // EncryptSinglePart encrypts an io.Reader which must be the
    // body of a single-part PUT request.
    func EncryptSinglePart(r io.Reader, key ObjectKey) io.Reader {
    	r, err := sio.EncryptReader(r, sio.Config{MinVersion: sio.Version20, Key: key[:]})
    	if err != nil {
    		logger.CriticalIf(context.Background(), errors.New("Unable to encrypt io.Reader using object key"))
    	}
    	return r
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

            .protocols(ONLY_HTTP1)
            .build()
        val request =
          originalRequest
            .newBuilder()
            .header("Upgrade", "websocket")
            .header("Connection", "Upgrade")
            .header("Sec-WebSocket-Key", key)
            .header("Sec-WebSocket-Version", "13")
            .header("Sec-WebSocket-Extensions", "permessage-deflate")
            .build()
        call = RealCall(webSocketClient, request, forWebSocket = true)
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 21.6K bytes
    - Click Count (0)
  4. internal/config/crypto.go

    // provided.
    func Decrypt(k *kms.KMS, ciphertext io.Reader, associatedData kms.Context) (io.Reader, error) {
    	const (
    		MaxMetadataSize = 1 << 20 // max. size of the metadata
    		Version         = 1
    	)
    
    	var header [5]byte
    	if _, err := io.ReadFull(ciphertext, header[:]); err != nil {
    		return nil, err
    	}
    	if header[0] != Version {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  5. cmd/object-multipart-handlers.go

    	var idxCb func() []byte
    	if isCompressed {
    		wantEncryption := crypto.Requested(r.Header) || isEncrypted
    		s2c, cb := newS2CompressReader(reader, actualPartSize, wantEncryption)
    		idxCb = cb
    		defer s2c.Close()
    		reader = etag.Wrap(s2c, reader)
    		length = -1
    	}
    
    	srcInfo.Reader, err = hash.NewReader(ctx, reader, length, "", "", actualPartSize)
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 07 16:13:09 GMT 2025
    - 39.5K bytes
    - Click Count (1)
  6. docs/ko/docs/tutorial/header-params.md

    # 헤더 매개변수 { #header-parameters }
    
    헤더 매개변수를 `Query`, `Path` 그리고 `Cookie` 매개변수들과 같은 방식으로 정의할 수 있습니다.
    
    ## `Header` 임포트 { #import-header }
    
    먼저 `Header`를 임포트합니다:
    
    {* ../../docs_src/header_params/tutorial001_an_py310.py hl[3] *}
    
    ## `Header` 매개변수 선언 { #declare-header-parameters }
    
    `Path`, `Query` 그리고 `Cookie`를 사용한 동일한 구조를 이용하여 헤더 매개변수를 선언합니다.
    
    첫 번째 값은 기본값이며, 추가 검증이나 어노테이션 매개변수 모두 전달할 수 있습니다:
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Jan 11 00:15:26 GMT 2026
    - 3.4K bytes
    - Click Count (0)
  7. docs/pt/docs/tutorial/header-params.md

    # Parâmetros de Cabeçalho { #header-parameters }
    
    Você pode definir parâmetros de Cabeçalho da mesma maneira que define paramêtros com `Query`, `Path` e `Cookie`.
    
    ## Importe `Header` { #import-header }
    
    Primeiro importe `Header`:
    
    {* ../../docs_src/header_params/tutorial001_an_py310.py hl[3] *}
    
    ## Declare parâmetros de `Header` { #declare-header-parameters }
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Feb 13 13:48:53 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  8. docs/zh-hant/docs/tutorial/header-params.md

    # Header 參數 { #header-parameters }
    
    你可以用與定義 `Query`、`Path`、`Cookie` 參數相同的方式來定義 Header 參數。
    
    ## 匯入 `Header` { #import-header }
    
    先匯入 `Header`:
    
    {* ../../docs_src/header_params/tutorial001_an_py310.py hl[3] *}
    
    ## 宣告 `Header` 參數 { #declare-header-parameters }
    
    接著使用與 `Path`、`Query`、`Cookie` 相同的結構來宣告標頭參數。
    
    你可以設定預設值,以及所有額外的驗證或註解參數:
    
    {* ../../docs_src/header_params/tutorial001_an_py310.py hl[9] *}
    
    /// note | 注意
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sat Feb 14 08:15:26 GMT 2026
    - 2.7K bytes
    - Click Count (0)
  9. docs/site-replication/run-replication-with-checksum-header.sh

    	exit_1
    fi
    
    echo "Set default encryption on "
    
    # test if checksum header is replicated for encrypted objects
    # Enable SSE KMS for test-bucket bucket
    ./mc encrypt set sse-kms minio-default-key minio1/test-bucket --insecure
    
    # Load objects to source site with checksum header
    echo "Loading objects to source MinIO instance"
    OBJ_CHKSUM=$(openssl dgst -sha256 -binary </tmp/data/obj | base64)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Jan 20 14:49:07 GMT 2025
    - 11.5K bytes
    - Click Count (0)
  10. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerAdapter.kt

       *
       * If there's nothing to read and no default value, this will throw an exception.
       */
      fun fromDer(reader: DerReader): T
    
      fun fromDer(byteString: ByteString): T {
        val buffer = Buffer().write(byteString)
        val reader = DerReader(buffer)
        return fromDer(reader)
      }
    
      /**
       * Writes [value] to this adapter, unless it is the default value and can be safely omitted.
       *
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 4.2K bytes
    - Click Count (0)
Back to Top