Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 199 for Draining (0.04 sec)

  1. docs/distributed/DECOMMISSION.md

    ┌─────┬─────────────────────────────────┬──────────────────────────────────┬──────────┐
    │ ID  │ Pools                           │ Capacity                         │ Status   │
    │ 1st │ http://minio{1...2}/data{1...4} │ 439 GiB (used) / 561 GiB (total) │ Draining │
    └─────┴─────────────────────────────────┴──────────────────────────────────┴──────────┘
    ```
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Jul 11 14:59:49 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/Striped.java

            if (existing != null) {
              return existing;
            }
          }
          drainQueue();
          return created;
        }
    
        // N.B. Draining the queue is only necessary to ensure that we don't accumulate empty references
        // in the array. We could skip this if we decide we don't care about holding on to Reference
        // objects indefinitely.
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 16 22:01:32 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  3. CHANGELOG/CHANGELOG-1.2.md

    support Replica Sets). It’s recommended to use Deployment 1.2 with “kubectl
    rollout” commands instead, if you want to rolling update Replica Sets.
      * When live upgrading Kubelet to 1.2 without draining the pods running on the node,
    the containers will be restarted by Kubelet (see details in [#23104](https://github.com/kubernetes/kubernetes/issues/23104)).
    
    #### Docker Known Issues
    
    ##### 1.9.1
    
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Fri Dec 04 06:36:19 UTC 2020
    - 41.4K bytes
    - Viewed (0)
  4. internal/grid/connection.go

    func (c *Connection) reconnected() {
    	c.updateState(StateConnectionError)
    	c.reconnects.Add(1)
    
    	// Drain the outQueue, so any blocked messages can be sent.
    	// We keep the queue, but start draining it, if it gets full.
    	stopDraining := make(chan struct{})
    	var wg sync.WaitGroup
    	wg.Add(1)
    	defer func() {
    		close(stopDraining)
    		wg.Wait()
    	}()
    	go func() {
    		defer wg.Done()
    		for {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 46.9K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/base/OptionalTest.java

      public void testIsPresent_yes() {
        assertTrue(Optional.of("training").isPresent());
      }
    
      public void testGet_absent() {
        Optional<String> optional = Optional.absent();
        assertThrows(IllegalStateException.class, optional::get);
      }
    
      public void testGet_present() {
        assertEquals("training", Optional.of("training").get());
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.27.md

    - Upgraded `go-jose` to `v2.6.0` ([#115893](https://github.com/kubernetes/kubernetes/pull/115893), [@mgoltzsche](https://github.com/mgoltzsche))
    Registered: Fri Dec 26 09:05:12 UTC 2025
    - Last Modified: Wed Jul 17 07:48:22 UTC 2024
    - 466.3K bytes
    - Viewed (2)
  7. tests/test_multipart_installation.py

        monkeypatch.setattr("python_multipart.__version__", "0.0.12")
        with warnings.catch_warnings(record=True):
            warnings.simplefilter("always")
            monkeypatch.delattr("multipart.multipart.parse_options_header", raising=False)
        with pytest.raises(RuntimeError, match=multipart_incorrect_install_error):
            app = FastAPI()
    
            @app.post("/")
            async def root(username: str = Form()):
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Oct 27 21:46:26 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/job/ExecJob.java

         * @return this ExecJob instance for method chaining
         */
        public ExecJob jobExecutor(final JobExecutor jobExecutor) {
            this.jobExecutor = jobExecutor;
            return this;
        }
    
        /**
         * Sets the session ID for this job execution.
         *
         * @param sessionId the unique session identifier
         * @return this ExecJob instance for method chaining
         */
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/rank/fusion/SearchResult.java

             */
            public SearchResultBuilder addDocument(final Map<String, Object> doc) {
                documentList.add(doc);
                return this;
            }
    
            /**
             * Sets the facet response containing aggregated facet information.
             *
             * @param facetResponse The facet response
             * @return This builder instance for method chaining
             */
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  10. docs/tr/docs/advanced/index.md

    Onların kurslarını denemek isteyebilirsiniz:
    
    * <a href="https://training.talkpython.fm/fastapi-courses" class="external-link" target="_blank">Talk Python Training</a>
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sat Nov 09 16:39:20 UTC 2024
    - 1.9K bytes
    - Viewed (0)
Back to top