Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 852 for limiter (0.1 sec)

  1. src/runtime/mgcmark.go

    func gcDumpObject(label string, obj, off uintptr) {
    	s := spanOf(obj)
    	print(label, "=", hex(obj))
    	if s == nil {
    		print(" s=nil\n")
    		return
    	}
    	print(" s.base()=", hex(s.base()), " s.limit=", hex(s.limit), " s.spanclass=", s.spanclass, " s.elemsize=", s.elemsize, " s.state=")
    	if state := s.state.get(); 0 <= state && int(state) < len(mSpanStateNames) {
    		print(mSpanStateNames[state], "\n")
    	} else {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top