Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 852 for limiter (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. pkg/controller/endpointslicemirroring/endpointslicemirroring_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: "endpoint_slice_mirroring",
    			},
    		),
    		workerLoopPeriod: time.Second,
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 23:18:31 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  5. pkg/controller/endpointslice/endpointslice_controller.go

    	})
    	c.serviceLister = serviceInformer.Lister()
    	c.servicesSynced = serviceInformer.Informer().HasSynced
    
    	podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    c.addPod,
    		UpdateFunc: c.updatePod,
    		DeleteFunc: c.deletePod,
    	})
    	c.podLister = podInformer.Lister()
    	c.podsSynced = podInformer.Informer().HasSynced
    
    	c.nodeLister = nodeInformer.Lister()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  6. pkg/controller/servicecidrs/servicecidrs_controller.go

    		DeleteFunc: c.deleteServiceCIDR,
    	})
    	c.serviceCIDRLister = serviceCIDRInformer.Lister()
    	c.serviceCIDRsSynced = serviceCIDRInformer.Informer().HasSynced
    
    	_, _ = ipAddressInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
    		AddFunc:    c.addIPAddress,
    		DeleteFunc: c.deleteIPAddress,
    	})
    
    	c.ipAddressLister = ipAddressInformer.Lister()
    	c.ipAddressSynced = ipAddressInformer.Informer().HasSynced
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 18K bytes
    - Viewed (0)
  7. src/runtime/mgc.go

    	clearpools()
    
    	work.cycles.Add(1)
    
    	// Assists and workers can start the moment we start
    	// the world.
    	gcController.startCycle(now, int(gomaxprocs), trigger)
    
    	// Notify the CPU limiter that assists may begin.
    	gcCPULimiter.startGCTransition(true, now)
    
    	// In STW mode, disable scheduling of user Gs. This may also
    	// disable scheduling of this goroutine, so it may block as
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
  8. src/runtime/mgcpacer.go

    	// That is, it'll reduce the heap goal by this many extra bytes off of the
    	// base calculation, at minimum.
    	memoryLimitMinHeapGoalHeadroom = 1 << 20
    
    	// memoryLimitHeapGoalHeadroomPercent is how headroom the memory-limit-based
    	// heap goal should have as a percent of the maximum possible heap goal allowed
    	// to maintain the memory limit.
    	memoryLimitHeapGoalHeadroomPercent = 3
    )
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 25 19:53:03 UTC 2024
    - 55.4K bytes
    - Viewed (0)
  9. pkg/controller/nodelifecycle/node_lifecycle_controller.go

    	// - if the new state is "partialDisruption" we call a user defined function that returns a new limiter to use,
    	// - if the new state is "normal" we resume normal operation (go back to default limiter settings),
    	// - if new state is "fullDisruption" we restore normal eviction rate,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  10. pilot/pkg/xds/discovery.go

    	ProxyNeedsPush func(proxy *model.Proxy, req *model.PushRequest) bool
    
    	// concurrentPushLimit is a semaphore that limits the amount of concurrent XDS pushes.
    	concurrentPushLimit chan struct{}
    	// RequestRateLimit limits the number of new XDS requests allowed. This helps prevent thundering hurd of incoming requests.
    	RequestRateLimit *rate.Limiter
    
    	// InboundUpdates describes the number of configuration updates the discovery server has received
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 20:21:09 UTC 2024
    - 19K bytes
    - Viewed (0)
Back to top