Search Options

Results per page
Sort
Preferred Languages
Advance

Results 211 - 220 of 701 for pools (0.13 sec)

  1. utils/tests/models.go

    type User struct {
    	gorm.Model
    	Name      string
    	Age       uint
    	Birthday  *time.Time
    	Account   Account
    	Pets      []*Pet
    	NamedPet  *Pet
    	Toys      []Toy   `gorm:"polymorphic:Owner"`
    	Tools     []Tools `gorm:"polymorphicType:Type;polymorphicId:CustomID"`
    	CompanyID *int
    	Company   Company
    	ManagerID *uint
    	Manager   *User
    	Team      []User     `gorm:"foreignkey:ManagerID"`
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Dec 15 08:36:08 UTC 2023
    - 2.1K bytes
    - Viewed (0)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt

      var uriPort: Int = 1
    
      fun newConnection(
        pool: RealConnectionPool,
        route: Route,
        idleAtNanos: Long = Long.MAX_VALUE,
        taskRunner: TaskRunner = this.taskRunner,
      ): RealConnection {
        val result =
          RealConnection.newTestConnection(
            taskRunner = taskRunner,
            connectionPool = pool,
            route = route,
            socket = Socket(),
            idleAtNs = idleAtNanos,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  3. docs/contribute/concurrency.md

    ## Connection Pool
    
    A primary responsibility for any HTTP client is to efficiently manage network connections. Creating and establishing new connections require a fair amount of overhead and added latency. OkHttp will make every effort to reuse existing connections to avoid this overhead and added latency.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  4. internal/handlers/forwarder.go

    	}
    
    	return f
    }
    
    type bufPool struct {
    	sz   int
    	pool sync.Pool
    }
    
    func (b *bufPool) Put(buf []byte) {
    	if cap(buf) < b.sz || cap(buf) > b.sz*2 {
    		// Buffer too small or will likely leak memory after being expanded.
    		// Drop it.
    		return
    	}
    	b.pool.Put(&buf)
    }
    
    func (b *bufPool) Get() []byte {
    	bufp := b.pool.Get().(*[]byte)
    	return (*bufp)[:b.sz]
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 07 05:42:10 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  5. tests/preload_test.go

    			Name: "TestMergeNestedPreloadWithNestedJoin-1",
    			Manager: &User{
    				Name: "Alexis Manager",
    				Tools: []Tools{
    					{Name: "Alexis Tool 1"},
    					{Name: "Alexis Tool 2"},
    				},
    			},
    		},
    		{
    			Name: "TestMergeNestedPreloadWithNestedJoin-2",
    			Manager: &User{
    				Name: "Jinzhu Manager",
    				Tools: []Tools{
    					{Name: "Jinzhu Tool 1"},
    					{Name: "Jinzhu Tool 2"},
    				},
    			},
    		},
    	}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 12 10:00:47 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  6. docs/en/docs/reference/security/index.md

    # Security Tools
    
    When you need to declare dependencies with OAuth2 scopes you use `Security()`.
    
    But you still need to define what is the dependable, the callable that you pass as a parameter to `Depends()` or `Security()`.
    
    There are multiple tools that you can use to create those dependables, and they get integrated into OpenAPI so they are shown in the automatic docs UI, they can be used by automatically generated clients and SDKs, etc.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Apr 18 19:53:19 UTC 2024
    - 1.6K bytes
    - Viewed (0)
  7. cmd/metacache-set_gen.go

    		case "StopDiskAtLimit":
    			z.StopDiskAtLimit, err = dc.ReadBool()
    			if err != nil {
    				err = msgp.WrapError(err, "StopDiskAtLimit")
    				return
    			}
    		case "pool":
    			z.pool, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "pool")
    				return
    			}
    		case "set":
    			z.set, err = dc.ReadInt()
    			if err != nil {
    				err = msgp.WrapError(err, "set")
    				return
    			}
    		default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Mar 19 20:23:12 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/Protocol.kt

     * https, etc.) of the URL, not the protocol (http/1.1, spdy/3.1, etc.). OkHttp uses the word
     * *protocol* to identify how HTTP messages are framed.
     *
     * [ietf_alpn]: http://tools.ietf.org/html/draft-ietf-tls-applayerprotoneg
     */
    enum class Protocol(private val protocol: String) {
      /**
       * An obsolete plaintext framing that does not use persistent sockets by default.
       */
      HTTP_1_0("http/1.0"),
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 06 04:17:33 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  9. cmd/handler-api.go

    		ctx := r.Context()
    		select {
    		case pool <- struct{}{}:
    			defer func() { <-pool }()
    			globalHTTPStats.addRequestsInQueue(-1)
    			if contextCanceled(ctx) {
    				w.WriteHeader(499)
    				return
    			}
    			f.ServeHTTP(w, r)
    		case <-r.Context().Done():
    			globalHTTPStats.addRequestsInQueue(-1)
    			// When the client disconnects before getting the S3 handler
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  10. docs/en/docs/deployment/index.md

    ## Deployment Strategies
    
    There are several ways to do it depending on your specific use case and the tools that you use.
    
    You could **deploy a server** yourself using a combination of tools, you could use a **cloud service** that does part of the work for you, or other possible options.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Jan 11 16:31:18 UTC 2024
    - 1.2K bytes
    - Viewed (0)
Back to top