- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for queueKey (0.2 sec)
-
pkg/controller/serviceaccount/tokens_controller.go
} } func parseSecretQueueKey(key interface{}) (secretQueueKey, error) { queueKey, ok := key.(secretQueueKey) if !ok || len(queueKey.namespace) == 0 || len(queueKey.name) == 0 || len(queueKey.uid) == 0 || len(queueKey.saName) == 0 { return secretQueueKey{}, fmt.Errorf("invalid secret key: %#v", key) } return queueKey, nil } // produce the same key format as cache.MetaNamespaceKeyFunc
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 20.5K bytes - Viewed (0) -
pkg/controlplane/controller/legacytokentracking/controller.go
return true } func (c *Controller) syncConfigMap() error { obj, exists, err := c.configMapCache.GetByKey(queueKey) if err != nil { return err } now := c.clock.Now() if !exists { r := c.creationRatelimiter.ReserveN(now, 1) if delay := r.DelayFrom(now); delay > 0 { c.queue.AddAfter(queueKey, delay) r.CancelAt(now) return nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
if quit { return true } defer queue.Done(key) rq.workerLock.RLock() defer rq.workerLock.RUnlock() logger := klog.FromContext(ctx) logger = klog.LoggerWithValues(logger, "queueKey", key) ctx = klog.NewContext(ctx, logger) err := rq.syncHandler(ctx, key) if err == nil { queue.Forget(key) return false } utilruntime.HandleError(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go
// queueSetFactory implements the QueueSetFactory interface // queueSetFactory makes QueueSet objects. type queueSetFactory struct { clock eventclock.Interface promiseFactoryFactory promiseFactoryFactory } // promiseFactory returns a WriteOnce // - whose Set method is invoked with the queueSet locked, and // - whose Get method is invoked with the queueSet not locked. // The parameters are the same as for `promise.NewWriteOnce`.
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/util/flowcontrol/fairqueuing/interface.go
} // QueueSetCompleter finishes the two-step process of creating or // reconfiguring a QueueSet type QueueSetCompleter interface { // Complete returns a QueueSet configured by the given // dispatching configuration. Complete(DispatchingConfig) QueueSet } // QueueSet is the abstraction for the queuing and dispatching // functionality of one non-exempt priority level. It covers the
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/fairqueuing/queueset/types.go
fcrequest "k8s.io/apiserver/pkg/util/flowcontrol/request" ) // 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
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/fairqueuing/queueset/queueset_test.go
counter.Add(1) // account for the goroutine running this test queue, ok := qs.(*queueSet) if !ok { t.Fatalf("expected a QueueSet of type: %T but got: %T", &queueSet{}, qs) } if queue.totRequestsExecuting != 0 { t.Fatalf("precondition: expected total requests currently executing of the QueueSet to be 0, but got: %d", queue.totRequestsExecuting) } if queue.dCfg.ConcurrencyLimit != 1 {
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/doc.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ // Package queueset implements a technique called "fair queuing for // server requests". One QueueSet is a set of queues operating // according to this technique. // // Fair queuing for server requests is inspired by the fair queuing
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 08 12:33:30 UTC 2024 - 6.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/testing/no-restraint.go
return noRestraintCompleter{}, nil } func (noRestraintCompleter) Complete(dCfg fq.DispatchingConfig) fq.QueueSet { return noRestraint{} } func (noRestraint) BeginConfigChange(qCfg fq.QueuingConfig) (fq.QueueSetCompleter, error) { return noRestraintCompleter{}, nil } func (noRestraint) IsIdle() bool { return false
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/fifo_list_test.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package queueset import ( "math/rand" "reflect" "testing" "time" "github.com/google/go-cmp/cmp" fcrequest "k8s.io/apiserver/pkg/util/flowcontrol/request" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jul 28 08:48:40 UTC 2022 - 7.8K bytes - Viewed (0)