Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 58 for qps (0.02 sec)

  1. pkg/kubelet/images/image_manager_test.go

    				{[]string{"GetImageRef", "PullImage", "GetImageSize"}, nil, true, true},
    			}},
    		// image present, non-zero qps, try to pull when qps exceeded
    		{containerImage: "present_image",
    			testName:   "image present and excessive qps rate, pull",
    			policy:     v1.PullAlways,
    			inspectErr: nil,
    			pullerErr:  nil,
    			qps:        2000.0,
    			burst:      0,
    			expected: []pullerExpects{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 19K bytes
    - Viewed (0)
  2. pkg/controller/nodelifecycle/scheduler/rate_limited_queue_test.go

    	qps := evictor.limiter.QPS()
    	if qps != fakeAlways.QPS() {
    		t.Fatalf("QPS does not match create one: %v instead of %v", qps, fakeAlways.QPS())
    	}
    
    	evictor.SwapLimiter(0)
    	qps = evictor.limiter.QPS()
    	fakeNever := flowcontrol.NewFakeNeverRateLimiter()
    	if qps != fakeNever.QPS() {
    		t.Fatalf("QPS does not match create one: %v instead of %v", qps, fakeNever.QPS())
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 17:40:33 UTC 2023
    - 10K bytes
    - Viewed (0)
  3. cmd/kubemark/app/hollow_node.go

    	fs.StringVar(&c.ContentType, "kube-api-content-type", "application/vnd.kubernetes.protobuf", "ContentType of requests sent to apiserver.")
    	fs.Float32Var(&c.QPS, "kube-api-qps", 10, "QPS indicates the maximum QPS to the apiserver.")
    	fs.IntVar(&c.Burst, "kube-api-burst", 20, "Burst indicates maximum burst for throttle to the apiserver.")
    
    	bindableNodeLabels := cliflag.ConfigurationMap(c.NodeLabels)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 08:58:18 UTC 2024
    - 11K bytes
    - Viewed (0)
  4. pkg/scheduler/apis/config/v1/defaults_test.go

    					ResourceLock:      "leases",
    					ResourceNamespace: "kube-system",
    					ResourceName:      "kube-scheduler",
    				},
    				ClientConnection: componentbaseconfig.ClientConnectionConfiguration{
    					QPS:         50,
    					Burst:       100,
    					ContentType: "application/vnd.kubernetes.protobuf",
    				},
    				PercentageOfNodesToScore: ptr.To[int32](config.DefaultPercentageOfNodesToScore),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 06 15:03:04 UTC 2024
    - 27.9K bytes
    - Viewed (0)
  5. cmd/kube-scheduler/app/options/options.go

    	}
    	if deprecated.Changed("kube-api-content-type") {
    		o.ComponentConfig.ClientConnection.ContentType = o.Deprecated.ContentType
    	}
    	if deprecated.Changed("kube-api-qps") {
    		o.ComponentConfig.ClientConnection.QPS = o.Deprecated.QPS
    	}
    	if deprecated.Changed("kube-api-burst") {
    		o.ComponentConfig.ClientConnection.Burst = o.Deprecated.Burst
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 17 17:06:29 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. cmd/kube-scheduler/app/options/options_test.go

    					ResourceNamespace: "kube-system",
    					ResourceName:      "kube-scheduler",
    				},
    				ClientConnection: componentbaseconfig.ClientConnectionConfiguration{
    					Kubeconfig:  configKubeconfig,
    					QPS:         50,
    					Burst:       100,
    					ContentType: "application/vnd.kubernetes.protobuf",
    				},
    				PercentageOfNodesToScore: defaultPercentageOfNodesToScore,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 13 07:42:19 UTC 2023
    - 30.3K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       * calling thread wait for that time.
       *
       * The simplest way to maintain a rate of QPS is to keep the timestamp of the last granted
       * request, and ensure that (1/QPS) seconds have elapsed since then. For example, for a rate of
       * QPS=5 (5 tokens per second), if we ensure that a request isn't granted earlier than 200ms after
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 19.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       * calling thread wait for that time.
       *
       * The simplest way to maintain a rate of QPS is to keep the timestamp of the last granted
       * request, and ensure that (1/QPS) seconds have elapsed since then. For example, for a rate of
       * QPS=5 (5 tokens per second), if we ensure that a request isn't granted earlier than 200ms after
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 19.3K bytes
    - Viewed (0)
  9. pkg/controlplane/apiserver/options/options_test.go

    		"--audit-log-mode=blocking",
    		"--audit-log-batch-buffer-size=46",
    		"--audit-log-batch-max-size=47",
    		"--audit-log-batch-max-wait=48s",
    		"--audit-log-batch-throttle-enable=true",
    		"--audit-log-batch-throttle-qps=49.5",
    		"--audit-log-batch-throttle-burst=50",
    		"--audit-log-truncate-enabled=true",
    		"--audit-log-truncate-max-batch-size=45",
    		"--audit-log-truncate-max-event-size=44",
    		"--audit-log-version=audit.k8s.io/v1",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 17:57:37 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/server/options/audit.go

    	defaultBatchMaxWait       = 30 * time.Second // Send events at least twice a minute.
    	defaultBatchThrottleQPS   = 10               // Limit the send rate by 10 QPS.
    	defaultBatchThrottleBurst = 15               // Allow up to 15 QPS burst.
    )
    
    func appendBackend(existing, newBackend audit.Backend) audit.Backend {
    	if existing == nil {
    		return newBackend
    	}
    	if newBackend == nil {
    		return existing
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 24 06:30:04 UTC 2022
    - 20.3K bytes
    - Viewed (0)
Back to top