- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 68 for stopCh (0.15 sec)
-
plugin/pkg/admission/resourcequota/admission_test.go
return createHandlerWithConfig(kubeClient, informerFactory, nil, stopCh) } func createHandlerWithConfig(kubeClient kubernetes.Interface, informerFactory informers.SharedInformerFactory, config *resourcequotaapi.Configuration, stopCh chan struct{}) (*resourcequota.QuotaAdmission, error) { if config == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 21:28:42 UTC 2024 - 84.1K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
cacher.reflector = reflector go cacher.dispatchEvents() go progressRequester.Run(stopCh) cacher.stopWg.Add(1) go func() { defer cacher.stopWg.Done() defer cacher.terminateAllWatchers() wait.Until( func() { if !cacher.isStopped() { cacher.startCaching(stopCh) } }, time.Second, stopCh, ) }() return cacher, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller_test.go
if svc != nil { t.Fatalf("expected nil, got %v", svc) } } func BenchmarkServiceEntryHandler(b *testing.B) { _, sd := initServiceDiscoveryWithoutEvents(b) stopCh := make(chan struct{}) go sd.Run(stopCh) defer close(stopCh) for i := 0; i < b.N; i++ { sd.serviceEntryHandler(config.Config{}, *httpDNS, model.EventAdd) sd.serviceEntryHandler(config.Config{}, *httpDNSRR, model.EventAdd)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.9K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller_test.go
for _, tc := range tests { t.Run(tc.name, func(t *testing.T) { ns := metav1.NamespaceDefault client, esController := newController(t, []string{"node-1"}, tc.batchPeriod) stopCh := make(chan struct{}) defer close(stopCh) _, ctx := ktesting.NewTestContext(t) go esController.Run(ctx, 1) esController.serviceStore.Add(&v1.Service{ ObjectMeta: metav1.ObjectMeta{Name: "foo", Namespace: ns},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 65.5K bytes - Viewed (0) -
pkg/controller/nodelifecycle/node_lifecycle_controller.go
func (nc *Controller) doNodeProcessingPassWorker(ctx context.Context) { logger := klog.FromContext(ctx) for { obj, shutdown := nc.nodeUpdateQueue.Get() // "nodeUpdateQueue" will be shutdown when "stopCh" closed; // we do not need to re-check "stopCh" again. if shutdown { return } nodeName := obj if err := nc.doNoScheduleTaintingPass(ctx, nodeName); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
pred.AllowWatchBookmarks = true // run the collision test for 3 seconds to let ~2 buckets expire stopCh := make(chan struct{}) var watchErr error time.AfterFunc(3*time.Second, func() { close(stopCh) }) wg := &sync.WaitGroup{} wg.Add(1) go func() { defer wg.Done() for { select { case <-stopCh: return default: ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
func TestReverseProxyFlushIntervalHeaders(t *testing.T) { const expected = "hi" stopCh := make(chan struct{}) backend := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { w.Header().Add("MyHeader", expected) w.WriteHeader(200) w.(http.Flusher).Flush() <-stopCh })) defer backend.Close() defer close(stopCh) backendURL, err := url.Parse(backend.URL) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
o.logger = &logger } } // defaultFrameworkOptions are applied when no option corresponding to those fields exist. func defaultFrameworkOptions(stopCh <-chan struct{}) frameworkOptions { return frameworkOptions{ metricsRecorder: metrics.NewMetricsAsyncRecorder(1000, time.Second, stopCh), parallelizer: parallelize.NewParallelizer(parallelize.DefaultParallelism), } } var _ framework.Framework = &frameworkImpl{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
cmd/batch-handlers.go
go func() { defer wk.Give() stopFn := globalBatchJobsMetrics.trace(batchJobMetricReplication, job.ID, attempts) success := true if err := r.ReplicateFromSource(ctx, api, core, oi, retry); err != nil { // object must be deleted concurrently, allow these failures but do not count them if isErrVersionNotFound(err) || isErrObjectNotFound(err) { return } stopFn(oi, err) batchLogIf(ctx, err)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 56K bytes - Viewed (0)