- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 210 for Fsname (0.29 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
qs.qCfg.Name, fsName, descr1, descr2, workEstimate, qs.totSeatsInUse, qs.totRequestsExecuting, qs.dCfg.ConcurrencyLimit) qs.totRequestsRejected++ metrics.AddReject(ctx, qs.qCfg.Name, fsName, "concurrency-limit") return nil, qs.isIdleLocked() } req = qs.dispatchSansQueueLocked(ctx, workEstimate, flowDistinguisher, fsName, descr1, descr2) return req, false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 16:59:21 UTC 2024 - 42.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
if !synced { names = append(names, objType.Name()) } } return names } func newConfiguration(fsName, plName, user string, concurrency int32, queueLength int32) []runtime.Object { fs := &flowcontrol.FlowSchema{ ObjectMeta: metav1.ObjectMeta{ Name: fsName, UID: types.UID(fsName), }, Spec: flowcontrol.FlowSchemaSpec{ MatchingPrecedence: 1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter.go
if queued { observeQueueWaitTime(ctx, pl.Name, fs.Name, strconv.FormatBool(req != nil), cfgCtlr.clock.Since(startWaitingTime)) } klog.V(7).Infof("Handle(%#+v) => fsName=%q, distMethod=%#+v, plName=%q, isExempt=%v, reject", requestDigest, fs.Name, fs.Spec.DistinguisherMethod, pl.Name, isExempt) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:35 UTC 2023 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter_test.go
var fsObj *flowcontrol.FlowSchema var plcObj *flowcontrol.PriorityLevelConfiguration cfgObjs := []runtime.Object{} plName := "test-pl" username := "test-user" fsName := "test-fs" lendable := int32(0) borrowingLimit := int32(0) fsObj = &flowcontrol.FlowSchema{ ObjectMeta: metav1.ObjectMeta{ Name: fsName, }, Spec: flowcontrol.FlowSchemaSpec{ MatchingPrecedence: 100,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 5.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/no-restraint.go
return noRestraintCompleter{}, nil } func (noRestraint) IsIdle() bool { return false } func (noRestraint) StartRequest(ctx context.Context, workEstimate *fcrequest.WorkEstimate, hashValue uint64, flowDistinguisher, fsName string, descr1, descr2 interface{}, queueNoteFn fq.QueueNoteFn) (fq.Request, bool) { return noRestraintRequest{}, false } func (noRestraint) Dump(bool) debug.QueueSetDump { return debug.QueueSetDump{} }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 17:37:20 UTC 2022 - 2.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go
uss.expectedInqueueSeats = uss.expectedInqueueSeats + fmt.Sprintf(` apiserver_flowcontrol_current_inqueue_seats{flow_schema=%q,priority_level=%q} 0%s`, fsName, uss.name, "\n") for j := 0; j < uc.nThreads; j++ { ust := uniformScenarioThread{ uss: uss, i: i, j: j,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 58.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/types.go
// request is a temporary container for "requests" with additional // tracking fields required for QueueSet functionality. type request struct { ctx context.Context qs *queueSet flowDistinguisher string fsName string // The relevant queue. Is nil if this request did not go through // a queue. queue *queue // estimated amount of work of the request workEstimate completedWorkEstimate
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 17:38:43 UTC 2023 - 6.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/controller_test.go
} if a := matchFS.Name == fs.Name; expectedMatch != a { t.Errorf("Fail at %s/%s: rd=%#+v, expectedMatch=%v, actualMatch=%v, matchFSName=%q, catchAlls=%#+v", trialName, fs.Name, rdu, expectedMatch, a, matchFS.Name, catchAlls) } if matchFS.Name == fs.Name {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 18.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/interface.go
Finish(execute func()) (idle bool) } // QueuingConfig defines the configuration of the queuing aspect of a QueueSet. type QueuingConfig struct { // Name is used to identify a queue set, allowing for descriptive information about its intended use Name string // DesiredNumQueues is the number of queues that the API says // should exist now. This may be non-positive, in which case
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 6.4K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/ztypes_zos_s390x.go
_ [4]byte } type W_Mntent struct { Fstype uint32 Mode uint32 Dev uint32 Parentdev uint32 Rootino uint32 Status byte Ddname [9]byte Fstname [9]byte Fsname [45]byte Pathlen uint32 Mountpoint [1024]byte Jobname [8]byte PID int32 Parmoffset int32 Parmlen int16 Owner [8]byte
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 16:12:58 UTC 2024 - 8.6K bytes - Viewed (0)