Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 18 for encodeTo (0.06 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/HttpUrl.kt

     * query the fragment is not sent to the webserver: it's private to the client.
     *
     * ## Encoding
     *
     * Each component must be encoded before it is embedded in the complete URL. As we saw above, the
     * string `cute #puppies` is encoded as `cute%20%23puppies` when used as a query parameter value.
     *
     * ### Percent encoding
     *
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon May 05 16:01:00 GMT 2025
    - 63.5K bytes
    - Click Count (0)
  2. cmd/storage-datatypes_gen_test.go

    	v := BaseOptions{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    
    	m := v.Msgsize()
    	if buf.Len() > m {
    		t.Log("WARNING: TestEncodeDecodeBaseOptions Msgsize() is inaccurate")
    	}
    
    	vn := BaseOptions{}
    	err := msgp.Decode(&buf, &vn)
    	if err != nil {
    		t.Error(err)
    	}
    
    	buf.Reset()
    	msgp.Encode(&buf, &v)
    	err = msgp.NewReader(&buf).Skip()
    	if err != nil {
    		t.Error(err)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 73.9K bytes
    - Click Count (0)
  3. cmd/test-utils_test.go

    	queryStr := strings.ReplaceAll(query.Encode(), "+", "%20")
    	canonicalRequest := getCanonicalRequest(extractedSignedHeaders, unsignedPayload, queryStr, req.URL.Path, req.Method)
    	stringToSign := getStringToSign(canonicalRequest, date, scope)
    	signingKey := getSigningKey(secretAccessKey, date, region, serviceS3)
    	signature := getSignature(signingKey, stringToSign)
    
    	req.URL.RawQuery = query.Encode()
    
    	// Add signature header to RawQuery.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
  4. docs/changelogs/changelog_3x.md

     *  Fix: Update the stored timestamp on conditional cache hits.
     *  New: Optimized HTTP/2 request header encoding. More headers are HPACK-encoded and string
        literals are now Huffman-encoded.
     *  New: Expose `Part` headers and body in `Multipart`.
     *  New: Make `ResponseBody.string()` and `ResponseBody.charStream()` BOM-aware. If your HTTP
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 06 14:55:54 GMT 2022
    - 50.8K bytes
    - Click Count (0)
  5. cmd/peer-rest-server.go

    	for {
    		select {
    		case <-ctx.Done():
    			grid.PutByteBuffer(buf.Bytes())
    			return nil
    		case ev := <-ch:
    			buf.Reset()
    			tmpEvt.Records[0] = ev
    			if err := enc.Encode(tmpEvt); err != nil {
    				peersLogOnceIf(ctx, err, "event: Encode failed")
    				continue
    			}
    			out <- grid.NewBytesWithCopyOf(buf.Bytes())
    		}
    	}
    }
    
    // TraceHandler sends http trace messages back to peer rest client
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/HttpUrlTest.kt

        assertThat(url.queryParameter("a")).isEqualTo("!$(),/:;?@[]\\^`{|}~")
      }
    
      /**
       * When callers use `addEncodedQueryParameter()` we only encode what's strictly required. We
       * retain the encoded (or non-encoded) state of the input.
       */
      @Test
      fun queryCharactersNotReencodedWhenComposedWithAddEncoded() {
        val url =
          HttpUrl
            .Builder()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Aug 04 07:38:48 GMT 2025
    - 69.9K bytes
    - Click Count (0)
  7. cmd/bucket-handlers.go

    					Host:         handlers.GetSourceIP(r),
    				})
    			}
    
    			if done {
    				break
    			}
    		}
    
    		enc := json.NewEncoder(w)
    		for i, fanOutResp := range fanOutResp {
    			if err = enc.Encode(&fanOutResp); err != nil {
    				writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    				return
    			}
    
    			// Notify object created events.
    			sendEvent(eventArgsList[i])
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 63.9K bytes
    - Click Count (0)
  8. docs/bucket/notifications/README.md

    "bucketName/objectName" for an object that exists in the bucket, and the value is the JSON-encoded event data about the operation that created/replaced the object in MinIO. When objects are updated or deleted, the corresponding entry in the hash is also updated or deleted.
    
    When the _access_ format is used, MinIO appends events to a list using [RPUSH](https://redis.io/commands/rpush). Each item in the list is a JSON encoded list with two items, where the first item is a timestamp string, and the second...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 84.2K bytes
    - Click Count (0)
  9. cmd/erasure-object.go

    			defer grid.PutByteBuffer(buf)
    			writers[i] = newStreamingBitrotWriterBuffer(inlineBuffers[i], DefaultBitrotAlgorithm, erasure.ShardSize())
    		}
    	}
    
    	n, erasureErr := erasure.Encode(ctx, data, writers, buffer, writeQuorum)
    	closeErrs := closeBitrotWriters(writers)
    	if erasureErr != nil {
    		return ObjectInfo{}, toObjectErr(erasureErr, minioMetaBucket, key)
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  10. cmd/xl-storage-format-v2.go

    		if err != nil {
    			return err
    		}
    		ver.meta = meta
    
    		// Fix inconsistent compression index due to https://github.com/minio/minio/pull/20575
    		// First search marshaled content for encoded values.
    		// We have bumped metaV to make this check cheaper.
    		if metaV < 3 && ver.header.Type == ObjectType && bytes.Contains(meta, []byte("\xa7PartIdx")) &&
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 65.6K bytes
    - Click Count (1)
Back to Top