Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 285 for poolId (0.03 sec)

  1. cmd/batch-handlers.go

    			VersionID: versionID,
    			// Since we are preserving a delete marker, we have to make sure this is always true.
    			// regardless of the current configuration of the bucket we must preserve all versions
    			// on the pool being batch replicated from source.
    			Versioned:          true,
    			MTime:              srcObjInfo.ModTime,
    			DeleteMarker:       srcObjInfo.DeleteMarker,
    			ReplicationRequest: true,
    		})
    		return err
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
  2. scan.go

    			}
    
    			if !isNilPtrValue { // ignore if value is nil
    				f := joinFields[idx][len(joinFields[idx])-1]
    				db.AddError(f.Set(db.Statement.Context, relValue, values[idx]))
    			}
    		}
    
    		// release data to pool
    		field.NewValuePool.Put(values[idx])
    	}
    }
    
    // ScanMode scan data mode
    type ScanMode uint8
    
    // scan modes
    const (
    	ScanInitialized         ScanMode = 1 << 0 // 1
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Sun May 25 07:40:40 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  3. internal/s3select/select.go

    	parquetSupport = env.Get("MINIO_API_SELECT_PARQUET", config.EnableOff) == config.EnableOn
    }
    
    var bufPool = bpool.Pool[*bytes.Buffer]{
    	New: func() *bytes.Buffer {
    		// make a buffer with a reasonable capacity.
    		return bytes.NewBuffer(make([]byte, 0, maxRecordSize))
    	},
    }
    
    var bufioWriterPool = bpool.Pool[*bufio.Writer]{
    	New: func() *bufio.Writer {
    		// io.Discard is just used to create the writer. Actual destination
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  4. docs/en/docs/advanced/events.md

    This can be very useful for setting up **resources** that you need to use for the whole app, and that are **shared** among requests, and/or that you need to **clean up** afterwards. For example, a database connection pool, or loading a shared machine learning model.
    
    ## Use Case { #use-case }
    
    Let's start with an example **use case** and then see how to solve it with this.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  5. docs/pt/docs/advanced/events.md

    Isso pode ser muito útil para configurar **recursos** que você precisa usar por toda a aplicação, e que são **compartilhados** entre as requisições e/ou que você precisa **limpar** depois. Por exemplo, um pool de conexões com o banco de dados ou o carregamento de um modelo de machine learning compartilhado.
    
    ## Caso de uso { #use-case }
    
    Vamos começar com um exemplo de **caso de uso** e então ver como resolvê-lo com isso.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 20:41:43 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  6. cmd/testdata/undeleteable-object.tgz

    š½0® îÊr ­f¬ \à¾×ég—! sÑ'ˆ3wi øÈ ëƒ:×ÖÛW,jŒ…,c'œ‰iä Ÿ %…2͚Ƨ» 1ì-Îe XϤ­âù ×Àw \ƃá (ELð15ûüètvë½ç;Ê’×ëŠ0Ñëºh "R ç(j?xÚ´ÄSvM¢ oÓj®:ëtÆé´D±¡±y ?=bœ³~5ï0ËDeí:ˆŠ÷'ºv?dÚ•ÊY>¼³Ÿ÷…^] &_Êï Î u²À 0Ÿ Ÿ‡qXF½Î%‹ %Ë multisitea/data/disterasure/xl3/.minio.sys/pool.bin/xl.meta XL2 Æ w Ä$•Ä Ó ÉŸþ¥¹ °Ä ºHØH Å Kƒ¤Type ¥V2ObjÞ ¢IDÄ ¤DDirÄ 5 A·DoCÁ§slÂ0RÿŦEcAlgo £EcM £EcN §EcBSizeÒ §EcIndex ¦EcDistœ ¨CSumAlgo ¨PartNums‘ ©PartETagsÀ©PartSizes‘kªPartASizes‘k¤Sizek¥MTimeÓ ÉŸþ¥¹ °§MetaSys ¼x-minio-internal-inline-dataÄ...
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 26 00:31:12 UTC 2024
    - 8.7M bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java

     * This processor supports searching with multiple searchers concurrently and merging their results based on
     * ranking scores to provide more comprehensive and accurate search results.
     *
     * The processor maintains a pool of searchers and an executor service for concurrent operations.
     * It implements rank fusion techniques to combine results from different search engines
     * and provides a unified search interface.
     */
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 27.5K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/collect/QueuesTest.java

            new LinkedBlockingDeque<Object>(),
            new LinkedBlockingDeque<Object>(10),
            new PriorityBlockingQueue<Object>(10, Ordering.arbitrary()));
      }
    
      /*
       * We need to perform operations in a thread pool, even for simple cases, because the queue might
       * be a SynchronousQueue.
       */
      private ExecutorService threadPool;
    
      @Override
      public void setUp() {
        threadPool = newCachedThreadPool();
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Nov 04 17:24:58 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

       * instance. This method is guaranteed to only be called once.
       *
       * <p>By default this returns a new {@link ScheduledExecutorService} with a single thread pool
       * that sets the name of the thread to the {@linkplain #serviceName() service name}. Also, the
       * pool will be {@linkplain ScheduledExecutorService#shutdown() shut down} when the service
       * {@linkplain Service.State#TERMINATED terminates} or {@linkplain Service.State#TERMINATED
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  10. cmd/endpoint-ellipses_test.go

    			if err != nil && testCase.success {
    				t.Fatalf("Test %d: unexpected error: %v", i+1, err)
    			}
    			_, _, err = createServerEndpoints(testCase.serverAddr, srvCtxt.Layout.pools, srvCtxt.Layout.legacy)
    			if err != nil && testCase.success {
    				t.Errorf("Test %d: Expected success but failed instead %s", i+1, err)
    			}
    			if err == nil && !testCase.success {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.1K bytes
    - Viewed (0)
Back to top