Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 111 - 120 of 728 for Encode (0.07 seconds)

  1. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15K bytes
    - Click Count (0)
  2. internal/grid/trace.go

    	switch typed := v.(type) {
    	case *MSS:
    		trace.Path += typed.ToQuery()
    	case map[string]string:
    		m := MSS(typed)
    		trace.Path += m.ToQuery()
    	case *URLValues:
    		trace.Path += typed.Values().Encode()
    	case *NoPayload, *Bytes:
    		trace.Path = fmt.Sprintf("%s?payload=%T", trace.Path, typed)
    	case string:
    		trace.Path = fmt.Sprintf("%s?%s", trace.Path, typed)
    	default:
    	}
    	trace.HTTP.ReqInfo.Path = trace.Path
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Jun 01 05:17:37 GMT 2024
    - 4.1K bytes
    - Click Count (0)
  3. 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 Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 06 16:57:30 GMT 2024
    - 5.2K bytes
    - Click Count (0)
  4. internal/config/identity/openid/provider/keycloak.go

    	if err != nil {
    		return err
    	}
    	req.Header.Set("Content-Type", "application/x-www-form-urlencoded")
    
    	resp, err := k.client.Do(req)
    	if err != nil {
    		return err
    	}
    	defer resp.Body.Close()
    
    	var accessToken Token
    	if err = json.NewDecoder(resp.Body).Decode(&accessToken); err != nil {
    		return err
    	}
    
    	k.Lock()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Jul 14 18:12:07 GMT 2024
    - 4.6K bytes
    - Click Count (0)
  5. docs/ru/docs/advanced/middleware.md

    ## Другие middleware { #other-middlewares }
    
    Существует много других ASGI middleware.
    
    Например:
    
    - <a href="https://github.com/encode/uvicorn/blob/master/uvicorn/middleware/proxy_headers.py" class="external-link" target="_blank">`ProxyHeadersMiddleware` от Uvicorn</a>
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  6. cmd/bucket-versioning-handler.go

    		writeErrorResponse(ctx, w, APIError{
    			Code:           "InvalidBucketState",
    			Description:    "An Object Lock configuration is present on this bucket, versioning cannot be suspended.",
    			HTTPStatusCode: http.StatusBadRequest,
    		}, r.URL)
    		return
    	}
    	if rc, _ := getReplicationConfig(ctx, bucket); rc != nil && v.Suspended() {
    		writeErrorResponse(ctx, w, APIError{
    			Code:           "InvalidBucketState",
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5K bytes
    - Click Count (0)
  7. docs/en/docs/advanced/middleware.md

    ## Other middlewares { #other-middlewares }
    
    There are many other ASGI middlewares.
    
    For example:
    
    * <a href="https://github.com/encode/uvicorn/blob/master/uvicorn/middleware/proxy_headers.py" class="external-link" target="_blank">Uvicorn's `ProxyHeadersMiddleware`</a>
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  8. docs/pt/docs/advanced/middleware.md

    ## Outros middlewares { #other-middlewares }
    
    Há muitos outros middlewares ASGI.
    
    Por exemplo:
    
    * <a href="https://github.com/encode/uvicorn/blob/master/uvicorn/middleware/proxy_headers.py" class="external-link" target="_blank">Uvicorn's `ProxyHeadersMiddleware`</a>
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  9. docs/zh/docs/advanced/middleware.md

    支持以下参数:
    
    * `minimum_size` - 小于最小字节的响应不使用 GZip。 默认值是 `500`。
    
    ## 其它中间件
    
    除了上述中间件外,FastAPI 还支持其它ASGI 中间件。
    
    例如:
    
    * <a href="https://github.com/encode/uvicorn/blob/master/uvicorn/middleware/proxy_headers.py" class="external-link" target="_blank">Uvicorn 的 `ProxyHeadersMiddleware`</a>
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Oct 11 17:48:49 GMT 2025
    - 3.5K bytes
    - Click Count (0)
  10. docs/sts/web-identity.go

    	}
    	v.Set("state", state)
    	v.Set("nonce", state)
    	if strings.Contains(c.Endpoint.AuthURL, "?") {
    		buf.WriteByte('&')
    	} else {
    		buf.WriteByte('?')
    	}
    	buf.WriteString(v.Encode())
    	return buf.String()
    }
    
    func main() {
    	flag.Parse()
    	if clientID == "" {
    		flag.PrintDefaults()
    		return
    	}
    
    	ddoc, err := parseDiscoveryDoc(configEndpoint)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 19 09:13:33 GMT 2023
    - 7.8K bytes
    - Click Count (0)
Back to Top