- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 354 for limiter (0.18 sec)
-
pkg/controller/certificates/certificate_controller.go
// 10 qps, 100 bucket size. This is only for retry speed and its only the overall factor (not per item) &workqueue.TypedBucketRateLimiter[string]{Limiter: rate.NewLimiter(rate.Limit(10), 100)}, ), workqueue.TypedRateLimitingQueueConfig[string]{ Name: "certificate", }, ), handler: handler, } // Manage the addition/update of certificate requests
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
docs/fr/docs/advanced/path-operation-advanced-configuration.md
```Python hl_lines="6" {!../../../docs_src/path_operation_advanced_configuration/tutorial003.py!} ``` ## Description avancée de docstring Vous pouvez limiter le texte utilisé de la docstring d'une *fonction de chemin* qui sera affiché sur OpenAPI. L'ajout d'un `\f` (un caractère d'échappement "form feed") va permettre à **FastAPI** de tronquer la sortie utilisée pour OpenAPI à ce stade.
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Thu Apr 18 19:53:19 UTC 2024 - 8K bytes - Viewed (0) -
pkg/kube/controllers/queue.go
} // WithName sets a name for the queue. This is used for logging func WithName(name string) func(q *Queue) { return func(q *Queue) { q.name = name } } // WithRateLimiter allows defining a custom rate limiter for the queue func WithRateLimiter(r workqueue.RateLimiter) func(q *Queue) { return func(q *Queue) { q.queue = workqueue.NewRateLimitingQueue(r) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/controller/namespace/namespace_controller.go
// 10 qps, 100 bucket size. This is only for retry speed and its only the overall factor (not per item) &workqueue.TypedBucketRateLimiter[string]{Limiter: rate.NewLimiter(rate.Limit(10), 100)}, ) } // enqueueNamespace adds an object to the controller work queue // obj could be an *v1.Namespace, or a DeletionFinalStateUnknown item.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/lister.go
}} } result = obj.(T) return result, nil } type lister[T runtime.Object] struct { indexer cache.Indexer } func (w lister[T]) List(selector labels.Selector) (ret []T, err error) { err = cache.ListAll(w.indexer, selector, func(m interface{}) { ret = append(ret, m.(T)) }) return ret, err } func (w lister[T]) Get(name string) (T, error) { var result T
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 2.6K bytes - Viewed (0) -
clause/limit.go
// Limit limit clause type Limit struct { Limit *int Offset int } // Name where clause name func (limit Limit) Name() string { return "LIMIT" } // Build build where clause func (limit Limit) Build(builder Builder) { if limit.Limit != nil && *limit.Limit >= 0 { builder.WriteString("LIMIT ") builder.AddVar(builder, *limit.Limit) } if limit.Offset > 0 { if limit.Limit != nil && *limit.Limit >= 0 {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Tue Feb 06 02:54:40 UTC 2024 - 942 bytes - Viewed (0) -
clause/limit_test.go
"SELECT * FROM `users` LIMIT ? OFFSET ?", []interface{}{limit10, 30}, }, { []clause.Interface{clause.Select{}, clause.From{}, clause.Limit{Limit: &limit10, Offset: 20}, clause.Limit{Offset: 30}, clause.Limit{Offset: -10}}, "SELECT * FROM `users` LIMIT ?", []interface{}{limit10}, }, {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Tue Feb 06 02:54:40 UTC 2024 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/cel/limits.go
Alexander Zielenski <******@****.***> 1709172273 -0800
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 23 17:22:44 UTC 2024 - 2K bytes - Viewed (0) -
docs/minio-limits.md
# MinIO Server Limits Per Tenant For optimal production setup MinIO recommends Linux kernel version 4.x and later. ## Erasure Code (Multiple Drives / Servers) | Item | Specification | |:----------------------------------------------------------------|:--------------| | Maximum number of servers per cluster | no-limit |
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 5.9K bytes - Viewed (0) -
src/cmd/go/internal/base/limit.go
import ( "fmt" "internal/godebug" "runtime" "strconv" "sync" ) var NetLimitGodebug = godebug.New("#cmdgonetlimit") // NetLimit returns the limit on concurrent network operations // configured by GODEBUG=cmdgonetlimit, if any. // // A limit of 0 (indicated by 0, true) means that network operations should not // be allowed. func NetLimit() (int, bool) { netLimitOnce.Do(func() { s := NetLimitGodebug.Value()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 19 02:47:12 UTC 2023 - 1.9K bytes - Viewed (0)