- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 285 for poolId (0.52 sec)
-
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) -
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 // 1Registered: Sun Dec 28 09:35:17 UTC 2025 - Last Modified: Sun May 25 07:40:40 UTC 2025 - 10.4K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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#TERMINATEDRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0) -
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)