- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 356 for queuesa (0.13 sec)
-
test/fixedbugs/issue33355.go
qr := gwc.gatewayInterest(acc.Name, subj) queues = queuesa[:0] for i := 0; i < len(qr.qsubs); i++ { qsubs := qr.qsubs[i] queue := qsubs[0].queue add := true for _, qn := range qgroups { if bytes.Equal(queue, qn) { add = false break } } if add { qgroups = append(qgroups, queue) } } if len(queues) == 0 { continue } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 01 02:15:18 UTC 2019 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/doc.go
// request executing: the last virtual finish time is the queue’s // virtual start time. When a request is dequeued for service the // queue’s virtual start time is advanced by G. When a request // finishes being served, and the actual service time was S, the // queue’s virtual start time is decremented by G - S.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 08 12:33:30 UTC 2024 - 6.1K bytes - Viewed (0) -
src/cmd/go/internal/par/queue.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package par import "fmt" // Queue manages a set of work items to be executed in parallel. The number of // active work items is limited, and excess items are queued sequentially. type Queue struct { maxActive int st chan queueState } type queueState struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 24 21:08:46 UTC 2020 - 1.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/types.go
// index is the position of this queue among those in its queueSet. index int // seatsInUse is the total number of "seats" currently occupied // by all the requests that are currently executing in this queue. seatsInUse int } // queueSum tracks the sum of initial seats, max seats, and // totalWork from all requests in a given queue type queueSum struct { // InitialSeatsSum is the sum of InitialSeats
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 17:38:43 UTC 2023 - 6.9K bytes - Viewed (0) -
pkg/kube/controllers/queue.go
log *istiolog.Scope } // 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) -
src/internal/fuzz/queue.go
// The queue is full (until grow is called) when end = begin + N - 1 (mod N) // where N = cap(elems). elems []any head, len int } func (q *queue) cap() int { return len(q.elems) } func (q *queue) grow() { oldCap := q.cap() newCap := oldCap * 2 if newCap == 0 { newCap = 8 } newElems := make([]any, newCap) oldLen := q.len for i := 0; i < oldLen; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Nov 05 21:02:45 UTC 2022 - 1.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/interface.go
QueueLengthLimit int // HandSize is a parameter of shuffle sharding. Upon arrival of a request, a queue is chosen by randomly // dealing a "hand" of this many queues and then picking one of minimum length. HandSize int } // DispatchingConfig defines the configuration of the dispatching aspect of a QueueSet. type DispatchingConfig struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 6.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller_debug.go
if !ok { continue } queueSetDigest := plState.queues.Dump(false) activeQueueNum := 0 for _, q := range queueSetDigest.Queues { if len(q.Requests) > 0 { activeQueueNum++ } } tabPrint(tabWriter, rowForPriorityLevel( plState.pl.Name, // 1 activeQueueNum, // 2 plState.queues.IsIdle(), // 3 plState.quiescing, // 4
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 17:38:43 UTC 2023 - 7.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/debug/dump.go
Cancelled int } // QueueDump is an instant dump of one queue in a queue-set. type QueueDump struct { QueueSum QueueSum Requests []RequestDump // just the waiting ones RequestsExecuting []RequestDump NextDispatchR string ExecutingRequests int SeatsInUse int } type QueueSum struct { InitialSeatsSum int MaxSeatsSum int TotalWorkSum string }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 17:38:43 UTC 2023 - 1.8K bytes - Viewed (0) -
pkg/queue/metrics.go
// See the License for the specific language governing permissions and // limitations under the License. package queue import ( "time" "k8s.io/utils/clock" "istio.io/istio/pilot/pkg/features" "istio.io/istio/pkg/monitoring" ) var ( queueIDTag = monitoring.CreateLabel("queueID") enableMetric = monitoring.WithEnabled(func() bool { return features.EnableControllerQueueMetrics })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jul 21 16:30:36 UTC 2023 - 1.9K bytes - Viewed (0)