- Sort Score
- Num 10 results
- Language All
Results 141 - 150 of 259 for poolId (0.04 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Connection.kt
* * Typically instances of this class are created, connected and exercised automatically by the HTTP * client. Applications may use this class to monitor HTTP connections as members of a * [connection pool][ConnectionPool]. * * Do not confuse this class with the misnamed `HttpURLConnection`, which isn't so much a connection * as a single request/response exchange. * * ## Modern TLS *
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 4.3K bytes - Click Count (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 {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 15.1K bytes - Click Count (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
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 21.2K bytes - Click Count (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Ä...
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Apr 26 00:31:12 GMT 2024 - 8.7M bytes - Click Count (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. */
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 27.5K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbFile.java
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 103.2K bytes - Click Count (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(); }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Nov 04 17:24:58 GMT 2025 - 12.6K bytes - Click Count (0) -
docs/es/docs/advanced/events.md
Esto puede ser muy útil para configurar **recursos** que necesitas usar para toda la app, y que son **compartidos** entre requests, y/o que necesitas **limpiar** después. Por ejemplo, un pool de conexiones a una base de datos, o cargando un modelo de machine learning compartido. ## Caso de Uso { #use-case } Empecemos con un ejemplo de **caso de uso** y luego veamos cómo resolverlo con esto.Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 8.5K bytes - Click Count (0) -
helm-releases/minio-2.0.1.tgz
If defined, it must be a sub-directory of the path specified in {{ .Values.mountPath }} ## bucketRoot: "" # Number of drives attached to a node drivesPerNode: 1 # Number of MinIO containers running replicas: 16 # Number of expanded MinIO clusters pools: 1 ## TLS Settings for MinIO tls: enabled: false ## Create a secret with private.key and public.crt files and pass that here. Ref: https://github.com/minio/minio/tree/master/docs/tls/kubernetes#2-create-kubernetes-secret certSecret: "" publicCrt: public.crt...Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 31 09:09:09 GMT 2021 - 13.6K bytes - Click Count (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#TERMINATEDCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 27.8K bytes - Click Count (0)