- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 800 for queuesa (0.13 sec)
-
staging/src/k8s.io/apiserver/pkg/server/options/feature.go
fs.BoolVar(&o.EnablePriorityAndFairness, "enable-priority-and-fairness", o.EnablePriorityAndFairness, ""+ "If true, replace the max-in-flight handler with an enhanced one that queues and dispatches with priority and fairness") } func (o *FeatureOptions) ApplyTo(c *server.Config, clientset kubernetes.Interface, informers informers.SharedInformerFactory) error { if o == nil { return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 18:51:27 UTC 2024 - 3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/indexer/IndexUpdater.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 24.2K bytes - Viewed (0) -
internal/logger/target/http/http.go
atomic.AddInt64(&h.failedMessages, 1) return err } // Delete the event from store. return h.store.Del(key.Name) } // Send the log message 'entry' to the http target. // Messages are queued in the disk if the store is enabled // If Cancel has been called the message is ignored. func (h *Target) Send(ctx context.Context, entry interface{}) error { if atomic.LoadInt32(&h.status) == statusClosed {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 14.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/request/webhook_duration.go
if tracker, ok := LatencyTrackersFrom(ctx); ok { tracker.ResponseWriteTracker.TrackDuration(d) } } // TrackAPFQueueWaitLatency is used to track latency incurred // by priority and fairness queues. func TrackAPFQueueWaitLatency(ctx context.Context, d time.Duration) { if tracker, ok := LatencyTrackersFrom(ctx); ok { tracker.APFQueueWaitTracker.TrackDuration(d) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 13 22:15:37 UTC 2024 - 11.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/apis/flowcontrol/bootstrap/default.go
LendablePercent: ptr.To(int32(33)), LimitResponse: flowcontrol.LimitResponse{ Type: flowcontrol.LimitResponseTypeQueue, Queuing: &flowcontrol.QueuingConfiguration{ Queues: 64, HandSize: 6, QueueLengthLimit: 50, }, }, }, }) SuggestedPriorityLevelConfigurationNodeHigh = newPriorityLevelConfiguration( "node-high",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 20.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/CacheLoaderTest.java
* limitations under the License. */ package com.google.common.cache; import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableMap; import com.google.common.collect.Queues; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; import java.util.Deque; import java.util.Map; import java.util.concurrent.Executor;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Aug 05 17:21:46 UTC 2022 - 3.6K bytes - Viewed (0) -
pkg/apis/flowcontrol/validation/validation_test.go
Type: flowcontrol.LimitResponseTypeQueue, Queuing: &flowcontrol.QueuingConfiguration{ Queues: 512, HandSize: 4, QueueLengthLimit: 100, }}}}, }, expectedErrors: field.ErrorList{}, }, { name: "customized priority level w/ overflowing handSize/queues should fail 1", priorityLevelConfiguration: &flowcontrol.PriorityLevelConfiguration{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:22:51 UTC 2023 - 54.7K bytes - Viewed (0) -
cmd/metrics-v3-replication.go
"Average number of active replication workers") replicationAverageQueuedBytesMD = NewGaugeMD(replicationAverageQueuedBytes, "Average number of bytes queued for replication since server start") replicationAverageQueuedCountMD = NewGaugeMD(replicationAverageQueuedCount, "Average number of objects queued for replication since server start") replicationAverageDataTransferRateMD = NewGaugeMD(replicationAverageDataTransferRate,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 07:41:18 UTC 2024 - 4.4K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
/** * A bounded {@linkplain BlockingQueue blocking queue} backed by an array. This queue orders * elements FIFO (first-in-first-out). The head of the queue is that element that has been * on the queue the longest time. The tail of the queue is that element that has been on * the queue the shortest time. New elements are inserted at the tail of the queue, and the queue * retrieval operations obtain elements at the head of the queue.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 19 19:24:36 UTC 2023 - 22.5K bytes - Viewed (0) -
src/cmd/go/internal/modload/buildlist.go
for len(queue) > 0 { roots = tidy.rootModules mg, err := tidy.Graph(ctx) if err != nil { return nil, err } prevQueue := queue queue = nil for _, pkg := range prevQueue { m := pkg.mod if m.Path == "" { continue } for _, dep := range pkg.imports { if !queued[dep] { queue = append(queue, dep) queued[dep] = true } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 16:04:44 UTC 2024 - 53.8K bytes - Viewed (0)