@@ -57,7 +57,7 @@ import (
57
57
nfdv1alpha1 "sigs.k8s.io/node-feature-discovery/api/nfd/v1alpha1"
58
58
"sigs.k8s.io/node-feature-discovery/pkg/apis/nfd/nodefeaturerule"
59
59
"sigs.k8s.io/node-feature-discovery/pkg/apis/nfd/validate"
60
- "sigs.k8s.io/node-feature-discovery/pkg/features"
60
+ nfdfeatures "sigs.k8s.io/node-feature-discovery/pkg/features"
61
61
pb "sigs.k8s.io/node-feature-discovery/pkg/labeler"
62
62
"sigs.k8s.io/node-feature-discovery/pkg/utils"
63
63
"sigs.k8s.io/node-feature-discovery/pkg/version"
@@ -318,7 +318,7 @@ func (m *nfdMaster) Run() error {
318
318
grpcErr := make (chan error )
319
319
// If the NodeFeature API is enabled, don'tregister the labeler API
320
320
// server. Otherwise, register the labeler server.
321
- if ! features .NFDFeatureGate .Enabled (features .NodeFeatureAPI ) {
321
+ if ! nfdfeatures .NFDFeatureGate .Enabled (nfdfeatures .NodeFeatureAPI ) {
322
322
go m .runGrpcServer (grpcErr )
323
323
}
324
324
@@ -373,7 +373,7 @@ func (m *nfdMaster) Run() error {
373
373
m .nodeUpdaterPool .start (m .config .NfdApiParallelism )
374
374
375
375
// Update all nodes when the configuration changes
376
- if m .nfdController != nil && features .NFDFeatureGate .Enabled (features .NodeFeatureAPI ) {
376
+ if m .nfdController != nil && nfdfeatures .NFDFeatureGate .Enabled (nfdfeatures .NodeFeatureAPI ) {
377
377
m .nfdController .updateAllNodesChan <- struct {}{}
378
378
}
379
379
@@ -471,7 +471,7 @@ func (m *nfdMaster) runGrpcServer(errChan chan<- error) {
471
471
func (m * nfdMaster ) nfdAPIUpdateHandler () {
472
472
// We want to unconditionally update all nodes at startup if gRPC is
473
473
// disabled (i.e. NodeFeature API is enabled)
474
- updateAll := features .NFDFeatureGate .Enabled (features .NodeFeatureAPI )
474
+ updateAll := nfdfeatures .NFDFeatureGate .Enabled (nfdfeatures .NodeFeatureAPI )
475
475
updateNodes := make (map [string ]struct {})
476
476
rateLimit := time .After (time .Second )
477
477
for {
@@ -1363,7 +1363,7 @@ func (m *nfdMaster) startNfdApiController() error {
1363
1363
}
1364
1364
klog .InfoS ("starting the nfd api controller" )
1365
1365
m .nfdController , err = newNfdController (kubeconfig , nfdApiControllerOptions {
1366
- DisableNodeFeature : ! features .NFDFeatureGate .Enabled (features .NodeFeatureAPI ),
1366
+ DisableNodeFeature : ! nfdfeatures .NFDFeatureGate .Enabled (nfdfeatures .NodeFeatureAPI ),
1367
1367
ResyncPeriod : m .config .ResyncPeriod .Duration ,
1368
1368
})
1369
1369
if err != nil {
0 commit comments