- Sort Score
- Result 10 results
- Languages All
Results 211 - 220 of 393 for queues (0.18 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/impl/LogHelperImpl.java
* <li>Getting content</li> * <li>Handling redirects</li> * <li>Processing responses</li> * <li>Handling exceptions during crawling and child URL processing</li> * <li>Handling cases where no URL is in the queue</li> * <li>Handling cases where no response processor or rule is found</li> * <li>Handling system errors</li> * </ul> * * <p> * Each logging method checks the log level before logging the message.
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 14K bytes - Viewed (0) -
docs/throttle/README.md
MinIO server allows to throttle incoming requests: - limit the number of active requests allowed across the cluster - limit the wait duration for each request in the queue These values are enabled using server's configuration or environment variables. ## Examples ### Configuring connection limit
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 16 08:43:49 UTC 2024 - 1.5K bytes - Viewed (1) -
mockwebserver/src/main/kotlin/mockwebserver3/QueueDispatcher.kt
logger.info("served $requestLine") return MockResponse(code = HttpURLConnection.HTTP_NOT_FOUND) } if (failFastResponse != null && responseQueue.peek() == null) { // Fail fast if there's no response queued up. return failFastResponse!! } val result = responseQueue.take() // If take() returned because we're shutting down, then enqueue another dead letter so that any
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 14 16:09:26 UTC 2025 - 2.9K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt
// Cause acceptConnections() to break out. serverSocket.closeQuietly() // Await shutdown. for (queue in taskRunner.activeQueues()) { if (!queue.idleLatch().await(5, TimeUnit.SECONDS)) { throw AssertionError("Gave up waiting for queue to shut down") } } taskRunnerBackend.shutdown() } private fun serveConnection( connectionIndex: Int,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 02 20:36:00 UTC 2025 - 40.3K bytes - Viewed (0) -
fess-crawler-opensearch/src/main/resources/crawler_opensearch.xml
<arg>crawlerConfig</arg> </component> <component name="crawlerConfig" class="org.codelibs.fess.crawler.util.OpenSearchCrawlerConfig"> <property name="queueIndex">"fess_crawler.queue"</property> <property name="queueShards">5</property> <property name="queueReplicas">1</property> <property name="dataIndex">"fess_crawler.data"</property> <property name="dataShards">5</property>
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Thu Nov 07 04:44:10 UTC 2024 - 2.2K bytes - Viewed (0) -
docs/es/docs/tutorial/dependencies/classes-as-dependencies.md
Entonces, si tienes un objeto `something` (que podría _no_ ser una función) y puedes "llamarlo" (ejecutarlo) como: ```Python something() ``` o ```Python something(some_argument, some_keyword_argument="foo") ``` entonces es un "callable". ## Clases como dependencias Puedes notar que para crear una instance de una clase en Python, utilizas esa misma sintaxis. Por ejemplo:
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Dec 30 18:26:57 UTC 2024 - 6.9K bytes - Viewed (0) -
src/main/webapp/js/jquery-3.7.1.min.js
&&t||t&&!v(t)&&t};return ce.fx.off?r.duration=0:"number"!=typeof r.duration&&(r.duration in ce.fx.speeds?r.duration=ce.fx.speeds[r.duration]:r.duration=ce.fx.speeds._default),null!=r.queue&&!0!==r.queue||(r.queue="fx"),r.old=r.complete,r.complete=function(){v(r.old)&&r.old.call(this),r.queue&&ce.dequeue(this,r.queue)},r},ce.fn.extend({fadeTo:function(e,t,n,r){return this.filter(ee).css("opacity",0).show().end().animate({opacity:t},e,n,r)},animate:function(t,e,n,r){var i=ce.isEmptyObject(t),o=ce....
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Oct 26 01:07:52 UTC 2024 - 85.5K bytes - Viewed (0) -
cmd/metrics-v3-audit.go
auditFailedMessagesMD = NewCounterMD(auditFailedMessages, "Total number of messages that failed to send since start", targetID) auditTargetQueueLengthMD = NewGaugeMD(auditTargetQueueLength, "Number of unsent messages in queue for target", targetID) auditTotalMessagesMD = NewCounterMD(auditTotalMessages, "Total number of messages sent since start", targetID) ) // loadAuditMetrics - `MetricsLoaderFn` for audit
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri May 10 14:50:39 UTC 2024 - 1.9K bytes - Viewed (0) -
docs/es/docs/tutorial/testing.md
/// info | Información Ten en cuenta que el `TestClient` recibe datos que pueden ser convertidos a JSON, no modelos de Pydantic. Si tienes un modelo de Pydantic en tu prueba y quieres enviar sus datos a la aplicación durante las pruebas, puedes usar el `jsonable_encoder` descrito en [Codificador Compatible con JSON](encoder.md){.internal-link target=_blank}. /// ## Ejecútalo
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Mon Dec 30 18:26:57 UTC 2024 - 6.9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/log/LogType.java
/** Indicates an access exception during crawling. */ CRAWLING_ACCESS_EXCEPTION, /** Indicates a general exception during crawling. */ CRAWLING_EXCEPTION, /** Indicates no URL is available in the queue. */ NO_URL_IN_QUEUE, /** Indicates the start of a crawler thread. */ START_THREAD, /** Indicates the finish of a crawler thread. */ FINISHED_THREAD,
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 2.4K bytes - Viewed (0)