modify variable name

Author: xuchenCN

cmd/k8s-rdma-shared-dp/main.go

@@ -68,8 +68,8 @@ func main() {
 	useCdi := false
 	flag.BoolVar(&useCdi, "use-cdi", false,
 		"Use Container Device Interface to expose devices in containers")
-	pluginMode := false
-	flag.BoolVar(&pluginMode, "plugin-mode", true,
+	kubeletPluginMode := false
+	flag.BoolVar(&kubeletPluginMode, "kubelet-plugin-mode", true,
 		"Using Kubelet Plugin Registry Mode if true, else to using Deprecated Device Plugin Registry Path ")
 	flag.Parse()
 	if versionOpt {
@@ -83,7 +83,7 @@ func main() {
 
 	log.Println("Starting K8s RDMA Shared Device Plugin version=", version)
 
-	rm := resources.NewResourceManagerWithPluginMode(configFilePath, useCdi, pluginMode)
+	rm := resources.NewResourceManager(configFilePath, useCdi, kubeletPluginMode)
 
 	log.Println("resource manager reading configs")
 	if err := rm.ReadConfig(); err != nil {

pkg/resources/resources_manager.go

@@ -90,12 +90,8 @@ type resourceManager struct {
 	useCdi                 bool
 }
 
-func NewResourceManager(configFile string, useCdi bool) types.ResourceManager {
-	return NewResourceManagerWithPluginMode(configFile, useCdi, detectPluginWatchMode(activeSockDir))
-}
-
-func NewResourceManagerWithPluginMode(configFile string, useCdi, pluginMode bool) types.ResourceManager {
-	if pluginMode {
+func NewResourceManager(configFile string, useCdi, kubeletPluginMode bool) types.ResourceManager {
+	if kubeletPluginMode {
 		fmt.Println("Using Kubelet Plugin Registry Mode")
 	} else {
 		fmt.Println("Using Deprecated Device Plugin Registry Path")
@@ -104,7 +100,7 @@ func NewResourceManagerWithPluginMode(configFile string, useCdi, pluginMode bool
 		configFile:            configFile,
 		defaultResourcePrefix: rdmaHcaResourcePrefix,
 		socketSuffix:          socketSuffix,
-		watchMode:             pluginMode,
+		watchMode:             kubeletPluginMode,
 		netlinkManager:        &netlinkManager{},
 		rds:                   NewRdmaDeviceSpec(requiredRdmaDevices),
 		useCdi:                useCdi,