Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 354 for limiter (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top