@@ -148,7 +148,7 @@ func NewResourceQuotaController(options *ResourceQuotaControllerOptions) (*Resou
148
148
rq .resyncPeriod (),
149
149
)
150
150
151
- if options .DiscoveryFunc != nil {
151
+ if options .DiscoveryFunc != nil {
152
152
qm := & QuotaMonitor {
153
153
informersStarted : options .InformersStarted ,
154
154
informerFactory : options .InformerFactory ,
@@ -277,7 +277,7 @@ func (rq *ResourceQuotaController) Run(workers int, stopCh <-chan struct{}) {
277
277
glog .Infof ("Starting resource quota controller" )
278
278
defer glog .Infof ("Shutting down resource quota controller" )
279
279
280
- if rq .quotaMonitor != nil {
280
+ if rq .quotaMonitor != nil {
281
281
go rq .quotaMonitor .Run (stopCh )
282
282
}
283
283
@@ -460,7 +460,7 @@ func (rq *ResourceQuotaController) Sync(discoveryFunc NamespacedResourcesFunc, p
460
460
// resyncMonitors starts or stops quota monitors as needed to ensure that all
461
461
// (and only) those resources present in the map are monitored.
462
462
func (rq * ResourceQuotaController ) resyncMonitors (resources map [schema.GroupVersionResource ]struct {}) error {
463
- if rq .quotaMonitor == nil {
463
+ if rq .quotaMonitor == nil {
464
464
return nil
465
465
}
466
466
@@ -478,7 +478,7 @@ func GetQuotableResources(discoveryFunc NamespacedResourcesFunc) (map[schema.Gro
478
478
if err != nil {
479
479
return nil , fmt .Errorf ("failed to discover resources: %v" , err )
480
480
}
481
- quotableResources := discovery .FilteredBy (discovery.SupportsAllVerbs {Verbs : []string {"create" , "list" , "delete" }}, possibleResources )
481
+ quotableResources := discovery .FilteredBy (discovery.SupportsAllVerbs {Verbs : []string {"create" , "list" , "watch" , " delete" }}, possibleResources )
482
482
quotableGroupVersionResources , err := discovery .GroupVersionResources (quotableResources )
483
483
if err != nil {
484
484
return nil , fmt .Errorf ("Failed to parse resources: %v" , err )
0 commit comments