Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 327 for fairness (0.14 sec)

  1. pkg/registry/flowcontrol/rest/storage_flowcontrol.go

    type RESTStorageProvider struct {
    	InformerFactory informers.SharedInformerFactory
    }
    
    // PostStartHookName is the name of the post-start-hook provided by flow-control storage
    const PostStartHookName = "priority-and-fairness-config-producer"
    
    // NewRESTStorage creates a new rest storage for flow-control api models.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 12.3K bytes
    - Viewed (0)
  2. pkg/controlplane/apiserver/options/options_test.go

    		"--contention-profiling=true",
    		"--egress-selector-config-file=/var/run/kubernetes/egress-selector/connectivity.yaml",
    		"--enable-aggregator-routing=true",
    		"--enable-priority-and-fairness=false",
    		"--enable-logs-handler=false",
    		"--etcd-keyfile=/var/run/kubernetes/etcd.key",
    		"--etcd-certfile=/var/run/kubernetes/etcdce.crt",
    		"--etcd-cafile=/var/run/kubernetes/etcdca.crt",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/config.go

    	}
    
    	// Add PostStartHooks for maintaining the watermarks for the Priority-and-Fairness and the Max-in-Flight filters.
    	if c.FlowControl != nil {
    		const priorityAndFairnessFilterHookName = "priority-and-fairness-filter"
    		if !s.isPostStartHookRegistered(priorityAndFairnessFilterHookName) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 47.7K bytes
    - Viewed (0)
  4. cmd/kube-apiserver/app/options/options_test.go

    		"--contention-profiling=true",
    		"--egress-selector-config-file=/var/run/kubernetes/egress-selector/connectivity.yaml",
    		"--enable-aggregator-routing=true",
    		"--enable-priority-and-fairness=false",
    		"--enable-logs-handler=false",
    		"--endpoint-reconciler-type=" + string(reconcilers.LeaseEndpointReconcilerType),
    		"--etcd-keyfile=/var/run/kubernetes/etcd.key",
    		"--etcd-certfile=/var/run/kubernetes/etcdce.crt",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics.go

    		&compbasemetrics.HistogramOpts{
    			Subsystem: APIServerComponent,
    			Name:      "request_slo_duration_seconds",
    			Help:      "Response latency distribution (not counting webhook duration and priority & fairness queue wait times) in seconds for each verb, group, version, resource, subresource, scope and component.",
    			// This metric is supplementary to the requestLatencies metric.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 07:29:19 UTC 2023
    - 35K bytes
    - Viewed (0)
  6. pkg/registry/flowcontrol/ensurer/strategy.go

    	"k8s.io/apimachinery/pkg/labels"
    	"k8s.io/apimachinery/pkg/runtime"
    	"k8s.io/apimachinery/pkg/util/sets"
    	"k8s.io/klog/v2"
    )
    
    const (
    	fieldManager = "api-priority-and-fairness-config-producer-v1"
    )
    
    // EnsureStrategy provides a maintenance strategy for APF configuration objects.
    // We have two types of strategy, corresponding to the two types of config objetcs:
    //
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:40 UTC 2023
    - 14K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/Monitor.java

        return lock.tryLock(time, unit);
      }
    
      /**
       * Enters this monitor if it is possible to do so immediately. Does not block.
       *
       * <p><b>Note:</b> This method disregards the fairness setting of this monitor.
       *
       * @return whether the monitor was entered
       */
      public boolean tryEnter() {
        return lock.tryLock();
      }
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Dec 04 18:22:01 UTC 2023
    - 38.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

     * acquired, permits need not be released.
     *
     * <p>{@code RateLimiter} is safe for concurrent use: It will restrict the total rate of calls from
     * all threads. Note, however, that it does not guarantee fairness.
     *
     * <p>Rate limiters are often used to restrict the rate at which some physical or logical resource
     * is accessed. This is in contrast to {@link java.util.concurrent.Semaphore} which restricts the
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 18.2K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/Monitor.java

        return lock.tryLock(time, unit);
      }
    
      /**
       * Enters this monitor if it is possible to do so immediately. Does not block.
       *
       * <p><b>Note:</b> This method disregards the fairness setting of this monitor.
       *
       * @return whether the monitor was entered
       */
      public boolean tryEnter() {
        return lock.tryLock();
      }
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Dec 04 18:22:01 UTC 2023
    - 42.5K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/RateLimiter.java

     * acquired, permits need not be released.
     *
     * <p>{@code RateLimiter} is safe for concurrent use: It will restrict the total rate of calls from
     * all threads. Note, however, that it does not guarantee fairness.
     *
     * <p>Rate limiters are often used to restrict the rate at which some physical or logical resource
     * is accessed. This is in contrast to {@link java.util.concurrent.Semaphore} which restricts the
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 21.5K bytes
    - Viewed (0)
Back to top