Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 551 - 560 of 808 for encodes (0.32 seconds)

  1. docs/ko/docs/advanced/middleware.md

    ## 다른 middleware { #other-middlewares }
    
    다른 ASGI middleware도 많이 있습니다.
    
    예를 들어:
    
    * [Uvicorn의 `ProxyHeadersMiddleware`](https://github.com/encode/uvicorn/blob/master/uvicorn/middleware/proxy_headers.py)
    * [MessagePack](https://github.com/florimondmanca/msgpack-asgi)
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Mar 20 14:06:26 GMT 2026
    - 4.7K bytes
    - Click Count (0)
  2. internal/pubsub/pubsub.go

    		var buf bytes.Buffer
    		enc := json.NewEncoder(&buf)
    		for {
    			select {
    			case <-doneCh:
    				return
    			case v, ok := <-subChT:
    				if !ok {
    					return
    				}
    				buf.Reset()
    				err := enc.Encode(v)
    				if err != nil {
    					return
    				}
    
    				select {
    				case subCh <- append(GetByteBuffer()[:0], buf.Bytes()...):
    					continue
    				case <-doneCh:
    					return
    				}
    			}
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 06 16:57:30 GMT 2024
    - 5.2K bytes
    - Click Count (0)
  3. internal/bucket/lifecycle/tag.go

    	errInvalidTagValue = Errorf("The TagValue you have provided is invalid")
    
    	errDuplicatedXMLTag = Errorf("duplicated XML Tag")
    	errUnknownXMLTag    = Errorf("unknown XML Tag")
    )
    
    // UnmarshalXML - decodes XML data.
    func (tag *Tag) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
    	var keyAlreadyParsed, valueAlreadyParsed bool
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Mar 06 16:56:10 GMT 2023
    - 2.4K bytes
    - Click Count (0)
  4. cmd/auth-handler_test.go

    		if err != nil {
    			t.Fatalf("Error initializing input HTTP request: %v", err)
    		}
    		q := inputReq.URL.Query()
    		q.Add(testCase.inputQueryKey, testCase.inputQueryValue)
    		inputReq.URL.RawQuery = q.Encode()
    		inputReq.ParseForm()
    
    		actualResult := isRequestPresignedSignatureV2(inputReq)
    		if testCase.expectedResult != actualResult {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 15.4K bytes
    - Click Count (0)
  5. internal/event/target/elasticsearch.go

    	doc := map[string]any{
    		"Records": []event.Event{eventData},
    	}
    	var buf bytes.Buffer
    	enc := json.NewEncoder(&buf)
    	err := enc.Encode(doc)
    	if err != nil {
    		return err
    	}
    	res, err := c.Index(
    		index,
    		&buf,
    		c.Index.WithDocumentID(key),
    		c.Index.WithContext(ctx),
    	)
    	if err != nil {
    		return err
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15K bytes
    - Click Count (0)
  6. src/main/java/jcifs/internal/smb2/persistent/DurableHandleV2Request.java

        public int size() {
            // Context header (16) + name length (4) + padding to 8-byte alignment (4) + data (32)
            return 16 + 4 + 4 + STRUCTURE_SIZE;
        }
    
        @Override
        public int encode(byte[] dst, int dstIndex) {
            int start = dstIndex;
    
            // Write context header
            SMBUtil.writeInt4(0, dst, dstIndex); // Next (offset to next context, 0 for last)
            dstIndex += 4;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 21 04:51:33 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  7. src/main/java/jcifs/internal/smb2/info/Smb2SetInfoRequest.java

            System.arraycopy(this.fileId, 0, dst, dstIndex, 16);
            dstIndex += 16;
    
            SMBUtil.writeInt2(dstIndex - getHeaderStart(), dst, bufferOffsetOffset);
            final int len = this.info.encode(dst, dstIndex);
            SMBUtil.writeInt4(len, dst, bufferLengthOffset);
            dstIndex += len;
            return dstIndex - start;
        }
    
        /**
         * {@inheritDoc}
         *
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  8. cmd/bucket-versioning-handler.go

    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Call site replication hook.
    	//
    	// We encode the xml bytes as base64 to ensure there are no encoding
    	// errors.
    	cfgStr := base64.StdEncoding.EncodeToString(configData)
    	replLogIf(ctx, globalSiteReplicationSys.BucketMetaHook(ctx, madmin.SRBucketMeta{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5K bytes
    - Click Count (0)
  9. docs/security/README.md

    - `X-Amz-Server-Side-Encryption-Customer-Key`: Base64 encoded new key.
    - `X-Amz-Copy-Source-Server-Side-Encryption-Customer-Key`: Base64 encoded current key.
    
    Such a special COPY request is also known as S3 SSE-C key rotation.
    
    ### Server-Side Encryption with a KMS
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Feb 26 09:25:50 GMT 2025
    - 13.8K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/MediaType.kt

      @Deprecated(
        message = "moved to val",
        replaceWith = ReplaceWith(expression = "subtype"),
        level = DeprecationLevel.ERROR,
      )
      fun subtype(): String = subtype
    
      /**
       * Returns the encoded media type, like "text/plain; charset=utf-8", appropriate for use in a
       * Content-Type header.
       */
      override fun toString(): String = mediaType
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 5.9K bytes
    - Click Count (0)
Back to Top