Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 521 - 530 of 1,064 for pool (0.02 seconds)

  1. internal/http/transports.go

    	DialTimeout time.Duration
    
    	// TLS Settings
    	RootCAs          *x509.CertPool
    	CipherSuites     []uint16
    	CurvePreferences []tls.CurveID
    
    	// HTTP2
    	EnableHTTP2 bool
    
    	// TCP Options
    	TCPOptions TCPOptions
    }
    
    func (s ConnSettings) getDefaultTransport(maxIdleConnsPerHost int) *http.Transport {
    	if maxIdleConnsPerHost <= 0 {
    		maxIdleConnsPerHost = 1024
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 08 17:51:53 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  2. internal/deadlineconn/deadlineconn.go

    	writeDeadline           time.Duration // sets the write deadline on a connection.
    	writeSetAt              time.Time
    	abortReads, abortWrites atomic.Bool // A deadline was set to indicate caller wanted the conn to time out.
    	infReads, infWrites     atomic.Bool
    	mu                      sync.Mutex
    }
    
    // Unwrap will unwrap the connection and remove the deadline if applied.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Dec 02 13:21:17 GMT 2024
    - 5.1K bytes
    - Click Count (0)
  3. internal/config/lambda/event/targetlist.go

    package event
    
    import (
    	"fmt"
    	"maps"
    	"net/http"
    	"strings"
    	"sync"
    )
    
    // Target - lambda target interface
    type Target interface {
    	ID() TargetID
    	IsActive() (bool, error)
    	Send(Event) (*http.Response, error)
    	Stat() TargetStat
    	Close() error
    }
    
    // TargetStats is a collection of stats for multiple targets.
    type TargetStats struct {
    	TargetStats map[string]TargetStat
    }
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  4. docs_src/response_model/tutorial003_04_py39.py

    from typing import Union
    
    from fastapi import FastAPI, Response
    from fastapi.responses import RedirectResponse
    
    app = FastAPI()
    
    
    @app.get("/portal")
    async def get_portal(teleport: bool = False) -> Union[Response, dict]:
        if teleport:
            return RedirectResponse(url="https://www.youtube.com/watch?v=dQw4w9WgXcQ")
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 17 20:41:43 GMT 2025
    - 384 bytes
    - Click Count (0)
  5. docs_src/header_param_models/tutorial003_py39.py

    from typing import Union
    
    from fastapi import FastAPI, Header
    from pydantic import BaseModel
    
    app = FastAPI()
    
    
    class CommonHeaders(BaseModel):
        host: str
        save_data: bool
        if_modified_since: Union[str, None] = None
        traceparent: Union[str, None] = None
        x_tag: list[str] = []
    
    
    @app.get("/items/")
    async def read_items(headers: CommonHeaders = Header(convert_underscores=False)):
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Mar 23 20:48:54 GMT 2025
    - 415 bytes
    - Click Count (0)
  6. docs_src/header_param_models/tutorial003_an_py39.py

    from typing import Annotated, Union
    
    from fastapi import FastAPI, Header
    from pydantic import BaseModel
    
    app = FastAPI()
    
    
    class CommonHeaders(BaseModel):
        host: str
        save_data: bool
        if_modified_since: Union[str, None] = None
        traceparent: Union[str, None] = None
        x_tag: list[str] = []
    
    
    @app.get("/items/")
    async def read_items(
        headers: Annotated[CommonHeaders, Header(convert_underscores=False)],
    ):
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Mar 23 20:48:54 GMT 2025
    - 443 bytes
    - Click Count (0)
  7. cmd/bucket-metadata-sys.go

    	"golang.org/x/sync/singleflight"
    )
    
    // BucketMetadataSys captures all bucket metadata for a given cluster.
    type BucketMetadataSys struct {
    	objAPI ObjectLayer
    
    	sync.RWMutex
    	initialized bool
    	group       *singleflight.Group
    	metadataMap map[string]BucketMetadata
    }
    
    // Count returns number of bucket metadata map entries.
    func (sys *BucketMetadataSys) Count() int {
    	sys.RLock()
    	defer sys.RUnlock()
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.4K bytes
    - Click Count (0)
  8. docs_src/dependencies/tutorial011_an_py39.py

                return self.fixed_content in q
            return False
    
    
    checker = FixedContentQueryChecker("bar")
    
    
    @app.get("/query-checker/")
    async def read_query_check(fixed_content_included: Annotated[bool, Depends(checker)]):
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Mar 18 12:29:59 GMT 2023
    - 544 bytes
    - Click Count (0)
  9. internal/bucket/lifecycle/delmarker-expiration.go

    	Days    int      `xml:"Days,omitempty"`
    }
    
    // Empty returns if a DelMarkerExpiration XML element is empty.
    // Used to detect if lifecycle.Rule contained a DelMarkerExpiration element.
    func (de DelMarkerExpiration) Empty() bool {
    	return de.Days == 0
    }
    
    // UnmarshalXML decodes a single XML element into a DelMarkerExpiration value
    func (de *DelMarkerExpiration) UnmarshalXML(dec *xml.Decoder, start xml.StartElement) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 2.3K bytes
    - Click Count (0)
  10. internal/config/etcd/etcd_test.go

    )
    
    // TestParseEndpoints - tests parseEndpoints function with valid and invalid inputs.
    func TestParseEndpoints(t *testing.T) {
    	testCases := []struct {
    		s         string
    		endpoints []string
    		secure    bool
    		success   bool
    	}{
    		// Invalid inputs
    		{"https://localhost:2379,http://localhost:2380", nil, false, false},
    		{",,,", nil, false, false},
    		{"", nil, false, false},
    		{"ftp://localhost:2379", nil, false, false},
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 2.1K bytes
    - Click Count (0)
Back to Top