- Sort Score
- Num 10 results
- Language All
Results 151 - 160 of 342 for queues (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
docs/es/docs/tutorial/body-fields.md
# Body - Campos { #body-fields } De la misma manera que puedes declarar validaciones adicionales y metadatos en los parámetros de las *path operation function* con `Query`, `Path` y `Body`, puedes declarar validaciones y metadatos dentro de los modelos de Pydantic usando `Field` de Pydantic. ## Importar `Field` { #import-field } Primero, tienes que importarlo: {* ../../docs_src/body_fields/tutorial001_an_py310.py hl[4] *} /// warning | AdvertenciaCreated: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Tue Dec 16 16:33:45 GMT 2025 - 2.6K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/Striped.java
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. private void drainQueue() { Reference<? extends L> ref; while ((ref = queue.poll()) != null) {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 16 22:01:32 GMT 2025 - 20.6K bytes - Click Count (0) -
internal/logger/target/kafka/kafka.go
types "github.com/minio/minio/internal/logger/target/loggertypes" "github.com/minio/minio/internal/once" "github.com/minio/minio/internal/store" xnet "github.com/minio/pkg/v3/net" ) // the suffix for the configured queue dir where the logs will be persisted. const kafkaLoggerExtension = ".kafka.log" const ( statusClosed = iota statusOffline statusOnline ) // Config - kafka target arguments. type Config struct {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 10.2K bytes - Click Count (0) -
internal/logger/help.go
Description: "Number of events per HTTP send to webhook target", Optional: true, Type: "number", }, config.HelpKV{ Key: QueueSize, Description: "configure channel queue size for webhook targets", Optional: true, Type: "number", }, config.HelpKV{ Key: QueueDir, Description: `staging dir for undelivered logger messages e.g. '/home/logger-events'`,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Sep 11 22:20:42 GMT 2024 - 7.4K bytes - Click Count (0) -
docs/es/docs/advanced/events.md
# Eventos de Lifespan { #lifespan-events } Puedes definir lógica (código) que debería ser ejecutada antes de que la aplicación **inicie**. Esto significa que este código será ejecutado **una vez**, **antes** de que la aplicación **comience a recibir requests**.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) -
docs/es/docs/how-to/extending-openapi.md
### Modificar el esquema de OpenAPI { #modify-the-openapi-schema } Ahora puedes añadir la extensión de ReDoc, agregando un `x-logo` personalizado al "objeto" `info` en el esquema de OpenAPI: {* ../../docs_src/extending_openapi/tutorial001_py39.py hl[22:24] *} ### Cachear el esquema de OpenAPI { #cache-the-openapi-schema } Puedes usar la propiedad `.openapi_schema` como un "cache", para almacenar tu esquema generado.Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 3.6K bytes - Click Count (0) -
docs/es/docs/tutorial/dependencies/dependencies-with-yield.md
Por lo tanto, puedes buscar esa excepción específica dentro de la dependencia con `except SomeException`. Del mismo modo, puedes usar `finally` para asegurarte de que los pasos de salida se ejecuten, sin importar si hubo una excepción o no. {* ../../docs_src/dependencies/tutorial007_py39.py hl[3,5] *} ## Sub-dependencias con `yield` { #sub-dependencies-with-yield }Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 13.7K bytes - Click Count (0) -
internal/store/batch_test.go
defer func() { if err := tearDownQueueStore(); err != nil { t.Fatalf("Failed to tear down store; %v", err) } }() store, err := setUpQueueStore(queueDir, 100) if err != nil { t.Fatalf("Failed to create a queue store; %v", err) } var limit uint32 = 100 batch := NewBatch[TestItem](BatchConfig[TestItem]{ Limit: limit, Store: store, CommitTimeout: 5 * time.Minute,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.6K bytes - Click Count (0) -
docs/es/docs/tutorial/body-nested-models.md
# Cuerpo - Modelos Anidados { #body-nested-models } Con **FastAPI**, puedes definir, validar, documentar y usar modelos anidados de manera arbitraria (gracias a Pydantic). ## Campos de lista { #list-fields } Puedes definir un atributo como un subtipo. Por ejemplo, una `list` en Python: {* ../../docs_src/body_nested_models/tutorial001_py310.py hl[12] *} Esto hará que `tags` sea una lista, aunque no declare el tipo de los elementos de la lista.Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 7.2K bytes - Click Count (0) -
build-logic-commons/basics/src/main/kotlin/gradlebuild/basics/BuildEnvironment.kt
// gh-readonly-queue/master/pr-1234-5678abcdef -> master fun toMergeQueueBaseBranch(actualBranch: String): String = when { actualBranch.startsWith("gh-readonly-queue/") -> actualBranch.substringAfter("/").substringBefore("/") else -> actualBranch } /** * The build environment. *
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Sat Dec 21 08:58:33 GMT 2024 - 4.7K bytes - Click Count (1)