feat(CSI-259): report mount transport in node topology

pkg/wekafs/interfaces.go

@@ -6,6 +6,11 @@ import (
 	"time"
 )
 
+const (
+	dataTransportNfs    DataTransport = "nfs"
+	dataTransportWekafs DataTransport = "wekafs"
+)
+
 type AnyServer interface {
 	getMounter() AnyMounter
 	getApiStore() *ApiStore
@@ -24,12 +29,13 @@ type AnyMounter interface {
 	gcInactiveMounts()
 	schedulePeriodicMountGc()
 	getGarbageCollector() *innerPathVolGc
+	getTransport() DataTransport
 }
 
 type mountsMapPerFs map[string]AnyMount
 type mountsMap map[string]mountsMapPerFs
 type nfsMountsMap map[string]int // we only follow the mountPath and number of references
-
+type DataTransport string
 type UnmountFunc func()
 
 type AnyMount interface {

pkg/wekafs/nfsmounter.go

@@ -162,3 +162,7 @@ func (m *nfsMounter) schedulePeriodicMountGc() {
 		}
 	}()
 }
+
+func (m *nfsMounter) getTransport() DataTransport {
+	return dataTransportNfs
+}

pkg/wekafs/nodeserver.go

@@ -41,6 +41,7 @@ const (
 	TopologyKeyNode                  = "topology.wekafs.csi/node"
 	TopologyLabelNode                = "topology.csi.weka.io/node"
 	TopologyLabelWeka                = "topology.csi.weka.io/global"
+	TopologyLabelTransport           = "topology.csi.weka.io/transport"
 	WekaKernelModuleName             = "wekafsgw"
 	NodeServerAdditionalMountOptions = MountOptionWriteCache + "," + MountOptionSyncOnClose
 )
@@ -564,9 +565,10 @@ func (ns *NodeServer) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoReque
 	}()
 	topology := &csi.Topology{
 		Segments: map[string]string{
-			TopologyKeyNode:   ns.nodeID, // required exactly same way as this is how node is accessed by K8s
-			TopologyLabelNode: ns.nodeID,
-			TopologyLabelWeka: "true",
+			TopologyKeyNode:        ns.nodeID, // required exactly same way as this is how node is accessed by K8s
+			TopologyLabelNode:      ns.nodeID,
+			TopologyLabelWeka:      "true",
+			TopologyLabelTransport: string(ns.getMounter().getTransport()),
 		},
 	}
 

pkg/wekafs/wekafsmounter.go

@@ -170,3 +170,7 @@ func (m *wekafsMounter) schedulePeriodicMountGc() {
 		}
 	}()
 }
+
+func (m *wekafsMounter) getTransport() DataTransport {
+	return dataTransportWekafs
+}