- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 811 for limiter (1.31 sec)
-
src/runtime/metrics.go
deps: makeStatDepSet(heapStatsDep), compute: func(in *statAggregate, out *metricValue) { out.kind = metricKindUint64 out.scalar = in.heapStats.tinyAllocCount }, }, "/gc/limiter/last-enabled:gc-cycle": { compute: func(_ *statAggregate, out *metricValue) { out.kind = metricKindUint64 out.scalar = uint64(gcCPULimiter.lastEnabledCycle.Load()) }, }, "/gc/pauses:seconds": {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 08 21:03:13 UTC 2024 - 26K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
dc.deletePod(logger, obj) }, }) dc.syncHandler = dc.syncDeployment dc.enqueueDeployment = dc.enqueue dc.dLister = dInformer.Lister() dc.rsLister = rsInformer.Lister() dc.podLister = podInformer.Lister() dc.dListerSynced = dInformer.Informer().HasSynced dc.rsListerSynced = rsInformer.Informer().HasSynced dc.podListerSynced = podInformer.Informer().HasSynced return dc, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repairip.go
interval: interval, client: client, serviceLister: serviceInformer.Lister(), servicesSynced: serviceInformer.Informer().HasSynced, serviceCIDRLister: serviceCIDRInformer.Lister(), serviceCIDRSynced: serviceCIDRInformer.Informer().HasSynced, ipAddressLister: ipAddressInformer.Lister(), ipAddressSynced: ipAddressInformer.Informer().HasSynced,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.7K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller.go
}, DeleteFunc: e.onServiceDelete, }) e.serviceLister = serviceInformer.Lister() e.servicesSynced = serviceInformer.Informer().HasSynced podInformer.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{ AddFunc: e.addPod, UpdateFunc: e.updatePod, DeleteFunc: e.deletePod, }) e.podLister = podInformer.Lister() e.podsSynced = podInformer.Informer().HasSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 26.3K bytes - Viewed (0) -
src/runtime/mheap.go
} } } // There are a few very limited circumstances where we won't have a P here. // It's OK to simply skip scavenging in these cases. Something else will notice // and pick up the tab. var now int64 if pp != nil && bytesToScavenge > 0 { // Measure how long we spent scavenging and add that measurement to the assist // time so we can track it for the GC CPU limiter. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 78K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller.go
"k8s.io/kubernetes/pkg/controller" "k8s.io/kubernetes/pkg/controller/daemon/util" ) const ( // BurstReplicas is a rate limiter for booting pods on a lot of pods. // The value of 250 is chosen b/c values that are too high can cause registry DoS issues. BurstReplicas = 250 // StatusUpdateRetries limits the number of retries if sending a status update to API server fails. StatusUpdateRetries = 1
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
src/runtime/runtime2.go
// Per-P GC state gcAssistTime int64 // Nanoseconds in assistAlloc gcFractionalMarkTime int64 // Nanoseconds in fractional mark worker (atomic) // limiterEvent tracks events for the GC CPU limiter. limiterEvent limiterEvent // gcMarkWorkerMode is the mode for the next mark worker to run in. // That is, this is used to communicate with the worker goroutine // selected for immediate execution by
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 47.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/lister.go
}} } result = obj.(T) return result, nil } type lister[T runtime.Object] struct { indexer cache.Indexer } func (w lister[T]) List(selector labels.Selector) (ret []T, err error) { err = cache.ListAll(w.indexer, selector, func(m interface{}) { ret = append(ret, m.(T)) }) return ret, err } func (w lister[T]) Get(name string) (T, error) { var result T
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 2.6K bytes - Viewed (0) -
clause/limit.go
// Limit limit clause type Limit struct { Limit *int Offset int } // Name where clause name func (limit Limit) Name() string { return "LIMIT" } // Build build where clause func (limit Limit) Build(builder Builder) { if limit.Limit != nil && *limit.Limit >= 0 { builder.WriteString("LIMIT ") builder.AddVar(builder, *limit.Limit) } if limit.Offset > 0 { if limit.Limit != nil && *limit.Limit >= 0 {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Tue Feb 06 02:54:40 UTC 2024 - 942 bytes - Viewed (0) -
clause/limit_test.go
"SELECT * FROM `users` LIMIT ? OFFSET ?", []interface{}{limit10, 30}, }, { []clause.Interface{clause.Select{}, clause.From{}, clause.Limit{Limit: &limit10, Offset: 20}, clause.Limit{Offset: 30}, clause.Limit{Offset: -10}}, "SELECT * FROM `users` LIMIT ?", []interface{}{limit10}, }, {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Tue Feb 06 02:54:40 UTC 2024 - 2.3K bytes - Viewed (0)