use go mod, and minor fixes

go.mod

@@ -0,0 +1,13 @@
+module github.com/Huawei/eSDK_K8S_Plugin
+
+go 1.15
+
+require (
+	github.com/container-storage-interface/spec v1.3.0
+	github.com/golang/protobuf v1.4.3
+	github.com/sirupsen/logrus v1.7.0
+	golang.org/x/crypto v0.0.0-20201221181555-eec23a3978ad
+	golang.org/x/sys v0.0.0-20210104204734-6f8348627aad
+	google.golang.org/grpc v1.34.0
+	k8s.io/apimachinery v0.20.1
+)

src/connector/connector.go

@@ -2,7 +2,8 @@ package connector
 
 import (
 	"fmt"
-	"utils/log"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 const (

src/connector/connector_utils.go

@@ -6,8 +6,9 @@ import (
 	"regexp"
 	"strings"
 	"time"
-	"utils"
-	"utils/log"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 func GetDevice(findDeviceMap map[string]string, tgtLunGuid string) (string, error) {

src/connector/fibrechannel/fc.go

@@ -1,12 +1,13 @@
 package fibrechannel
 
 import (
-	"connector"
-	"dev"
 	"errors"
 	"fmt"
 	"time"
-	"utils/log"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/connector"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/dev"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 type FibreChannel struct{}

src/connector/fibrechannel/fc_helper.go

@@ -1,8 +1,8 @@
 package fibrechannel
 
 import (
-	"utils"
-	"utils/log"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 func scanHost() {

src/connector/iscsi/iscsi.go

@@ -1,11 +1,12 @@
 package iscsi
 
 import (
-	"connector"
-	"dev"
 	"strings"
 	"time"
-	"utils/log"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/connector"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/dev"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 type iSCSI struct{}

src/connector/iscsi/iscsi_helper.go

@@ -1,16 +1,17 @@
 package iscsi
 
 import (
-	"connector"
 	"errors"
 	"fmt"
 	"math"
 	"runtime/debug"
 	"strings"
 	"sync"
 	"time"
-	"utils"
-	"utils/log"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/connector"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 type connectorInfo struct {
@@ -203,8 +204,7 @@ func findTgtMultiPath(lenIndex int, iscsiShareData *shareData, conn *connectorIn
 	var wwnAdded bool
 	var lastTryOn int64
 	for {
-		if (int64(lenIndex) == iscsiShareData.stoppedThreads && iscsiShareData.foundDevices == nil) || (
-			mPath != "" && int64(lenIndex) == iscsiShareData.numLogin+iscsiShareData.failedLogin) {
+		if (int64(lenIndex) == iscsiShareData.stoppedThreads && iscsiShareData.foundDevices == nil) || (mPath != "" && int64(lenIndex) == iscsiShareData.numLogin+iscsiShareData.failedLogin) {
 			break
 		}
 
@@ -239,7 +239,7 @@ func tryConnectVolume(connMap map[string]interface{}) (string, error) {
 		return "", err
 	}
 
-    // must ignore the error
+	// must ignore the error
 	allSessions, _ := utils.ExecShellCmd("iscsiadm -m session")
 
 	var mPath string

src/connector/nvme/nvme.go

@@ -1,11 +1,12 @@
 package nvme
 
 import (
-	"connector"
 	"errors"
 	"fmt"
 	"time"
-	"utils/log"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/connector"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 type FCNVMe struct{}
@@ -22,7 +23,7 @@ func (fc *FCNVMe) ConnectVolume(conn map[string]interface{}) (string, error) {
 		log.Errorln(msg)
 		return "", errors.New(msg)
 	}
-	connectInfo := map[string]interface{} {
+	connectInfo := map[string]interface{}{
 		"protocol": "fc",
 	}
 	connector.ScanNVMe(connectInfo)

src/connector/roce/roce.go

@@ -1,10 +1,11 @@
 package roce
 
 import (
-	"connector"
 	"strings"
 	"time"
-	"utils/log"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/connector"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 type RoCE struct{}

src/connector/roce/roce_helper.go

@@ -1,20 +1,21 @@
 package roce
 
 import (
-	"connector"
 	"errors"
 	"fmt"
 	"math"
 	"runtime/debug"
 	"strings"
 	"sync"
 	"time"
-	"utils"
-	"utils/log"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/connector"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 type connectorInfo struct {
-	tgtPortals []string
+	tgtPortals  []string
 	tgtLunGuids []string
 }
 
@@ -97,8 +98,8 @@ func singleConnectVolume(allSessions, tgtPortal, tgtLunGuid string, nvmeShareDat
 		nvmeShareData.failedLogin += 1
 	} else {
 		nvmeShareData.numLogin += 1
-		connectInfo := map[string]interface{} {
-			"protocol": "iscsi",
+		connectInfo := map[string]interface{}{
+			"protocol":  "iscsi",
 			"targetNqn": tgtNqn,
 		}
 		for i := 1; i < 4; i++ {
@@ -165,8 +166,7 @@ func findTgtMultiPath(lenIndex int, nvmeShareData *shareData, conn *connectorInf
 	var mPath string
 	var lastTryOn int64
 	for {
-		if (int64(lenIndex) == nvmeShareData.stoppedThreads && nvmeShareData.foundDevices == nil) || (
-			mPath != "" && int64(lenIndex) == nvmeShareData.numLogin+nvmeShareData.failedLogin) {
+		if (int64(lenIndex) == nvmeShareData.stoppedThreads && nvmeShareData.foundDevices == nil) || (mPath != "" && int64(lenIndex) == nvmeShareData.numLogin+nvmeShareData.failedLogin) {
 			break
 		}
 

src/csi/backend/backend.go

@@ -1,13 +1,14 @@
 package backend
 
 import (
-	"csi/backend/plugin"
 	"errors"
 	"fmt"
 	"regexp"
 	"sync"
-	"utils"
-	"utils/log"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/csi/backend/plugin"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 var (
@@ -168,8 +169,7 @@ func updateMetroBackends() {
 				continue
 			}
 
-			if (i.MetroDomain != "" && i.MetroDomain == j.MetroDomain) || (
-				i.MetrovStorePairID != "" && i.MetrovStorePairID == j.MetrovStorePairID) {
+			if (i.MetroDomain != "" && i.MetroDomain == j.MetroDomain) || (i.MetrovStorePairID != "" && i.MetrovStorePairID == j.MetrovStorePairID) {
 				i.MetroBackend, j.MetroBackend = j, i
 				i.Plugin.UpdateMetroRemotePlugin(j.Plugin)
 				j.Plugin.UpdateMetroRemotePlugin(i.Plugin)

src/csi/backend/capability.go

@@ -6,7 +6,8 @@ import (
 	"os"
 	"runtime/debug"
 	"sync"
-	"utils/log"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 func updateBackendCapabilities(backend *Backend, sync bool) error {

src/csi/backend/plugin/fusionstorage-nas.go

@@ -1,18 +1,19 @@
 package plugin
 
 import (
-	"dev"
 	"errors"
 	"fmt"
 	"net"
-	"storage/fusionstorage/volume"
-	"utils"
-	"utils/log"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/dev"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/storage/fusionstorage/volume"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 type FusionStorageNasPlugin struct {
 	FusionStoragePlugin
-	portal   string
+	portal string
 }
 
 func init() {

src/csi/backend/plugin/fusionstorage-san.go

@@ -1,16 +1,17 @@
 package plugin
 
 import (
-	"dev"
 	"errors"
 	"fmt"
 	"net"
-	"proto"
-	"storage/fusionstorage/attacher"
-	"storage/fusionstorage/volume"
 	"strings"
-	"utils"
-	"utils/log"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/dev"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/proto"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/storage/fusionstorage/attacher"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/storage/fusionstorage/volume"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 type FusionStorageSanPlugin struct {

src/csi/backend/plugin/fusionstorage.go

@@ -2,11 +2,12 @@ package plugin
 
 import (
 	"errors"
-	"storage/fusionstorage/client"
 	"strings"
-	"utils"
-	"utils/log"
-	"utils/pwd"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/storage/fusionstorage/client"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/pwd"
 )
 
 const (
@@ -15,7 +16,7 @@ const (
 
 type FusionStoragePlugin struct {
 	basePlugin
-	cli      *client.Client
+	cli *client.Client
 }
 
 func (p *FusionStoragePlugin) init(config map[string]interface{}, keepLogin bool) error {

src/csi/backend/plugin/oceanstor-nas.go

@@ -1,12 +1,13 @@
 package plugin
 
 import (
-	"dev"
 	"errors"
-	"storage/oceanstor/client"
-	"storage/oceanstor/volume"
-	"utils"
-	"utils/log"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/dev"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/storage/oceanstor/client"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/storage/oceanstor/volume"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 const (

src/csi/backend/plugin/oceanstor-san.go

@@ -1,17 +1,18 @@
 package plugin
 
 import (
-	"dev"
 	"encoding/json"
 	"errors"
 	"fmt"
-	"proto"
 	"reflect"
-	"storage/oceanstor/attacher"
-	"storage/oceanstor/client"
-	"storage/oceanstor/volume"
-	"utils"
-	"utils/log"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/dev"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/proto"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/storage/oceanstor/attacher"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/storage/oceanstor/client"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/storage/oceanstor/volume"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
 )
 
 const (

src/csi/backend/plugin/oceanstor.go

@@ -2,12 +2,13 @@ package plugin
 
 import (
 	"errors"
-	"storage/oceanstor/client"
 	"strconv"
 	"strings"
-	"utils"
-	"utils/log"
-	"utils/pwd"
+
+	"github.com/Huawei/eSDK_K8S_Plugin/src/storage/oceanstor/client"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/log"
+	"github.com/Huawei/eSDK_K8S_Plugin/src/utils/pwd"
 )
 
 const (
@@ -175,8 +176,7 @@ func (p *OceanstorPlugin) updatePoolCapabilities(poolNames []string, usageType s
 	for _, name := range poolNames {
 		if pool, exist := pools[name].(map[string]interface{}); exist {
 			poolType, exist := pool["NEWUSAGETYPE"].(string)
-			if (pool["USAGETYPE"] == usageType || pool["USAGETYPE"] == DORADO_V6_POOL_USAGE_TYPE) || (
-				exist && poolType == DORADO_V6_POOL_USAGE_TYPE) {
+			if (pool["USAGETYPE"] == usageType || pool["USAGETYPE"] == DORADO_V6_POOL_USAGE_TYPE) || (exist && poolType == DORADO_V6_POOL_USAGE_TYPE) {
 				validPools = append(validPools, pool)
 			} else {
 				log.Warningf("Pool %s is not for %s", name, usageType)