Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for StartMonitors (0.15 sec)

  1. pkg/controller/resourcequota/resource_quota_monitor.go

    	return utilerrors.NewAggregate(errs)
    }
    
    // StartMonitors ensures the current set of monitors are running. Any newly
    // started monitors will also cause shared informers to be started.
    //
    // If called before Run, StartMonitors does nothing (as there is no stop channel
    // to support monitor/informer execution).
    func (qm *QuotaMonitor) StartMonitors(ctx context.Context) {
    	qm.monitorLock.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  2. pkg/controller/garbagecollector/graph_builder.go

    	return utilerrors.NewAggregate(errs)
    }
    
    // startMonitors ensures the current set of monitors are running. Any newly
    // started monitors will also cause shared informers to be started.
    //
    // If called before Run, startMonitors does nothing (as there is no stop channel
    // to support monitor/informer execution).
    func (gb *GraphBuilder) startMonitors(logger klog.Logger) {
    	gb.monitorLock.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  3. pkg/controller/resourcequota/resource_quota_controller.go

    	if rq.quotaMonitor == nil {
    		return nil
    	}
    
    	if err := rq.quotaMonitor.SyncMonitors(ctx, resources); err != nil {
    		return err
    	}
    	rq.quotaMonitor.StartMonitors(ctx)
    	return nil
    }
    
    // GetQuotableResources returns all resources that the quota system should recognize.
    // It requires a resource supports the following verbs: 'create','list','delete'
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  4. pkg/controller/garbagecollector/garbagecollector.go

    	if err := gc.dependencyGraphBuilder.syncMonitors(logger, deletableResources); err != nil {
    		return err
    	}
    	gc.dependencyGraphBuilder.startMonitors(logger)
    	return nil
    }
    
    // Run starts garbage collector workers.
    func (gc *GarbageCollector) Run(ctx context.Context, workers int) {
    	defer utilruntime.HandleCrash()
    	defer gc.attemptToDelete.ShutDown()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.9K bytes
    - Viewed (0)
Back to top