chore(CSI-161): opentelemetry schema fix

pkg/wekafs/nodeserver.go

@@ -19,7 +19,6 @@ package wekafs
 import (
 	"context"
 	"fmt"
-	"github.com/Djarvur/go-lsmod"
 	"github.com/container-storage-interface/spec/lib/go/csi"
 	"github.com/rs/zerolog"
 	"github.com/rs/zerolog/log"
@@ -110,12 +109,6 @@ func NewNodeServer(nodeId string, maxVolumesPerNode int64, api *ApiStore, mounte
 	}
 }
 
-func isWekaInstalled() bool {
-	log.Info().Msg("Checking if wekafs is installed on host")
-	ok, err := lsmod.IsLoaded(WekaKernelModuleName)
-	return err != nil && ok
-}
-
 func (ns *NodeServer) acquireSemaphore(ctx context.Context, op string) (error, releaseSempahore) {
 	logger := log.Ctx(ctx)
 	ns.initializeSemaphore(ctx, op)

pkg/wekafs/otel.go

@@ -5,7 +5,7 @@ import (
 	"go.opentelemetry.io/otel/exporters/jaeger"
 	"go.opentelemetry.io/otel/sdk/resource"
 	sdktrace "go.opentelemetry.io/otel/sdk/trace"
-	semconv "go.opentelemetry.io/otel/semconv/v1.17.0"
+	semconv "go.opentelemetry.io/otel/semconv/v1.21.0"
 	"os"
 )
 

pkg/wekafs/utilities.go

@@ -1,6 +1,7 @@
 package wekafs
 
 import (
+	"bufio"
 	"context"
 	"crypto/sha1"
 	"encoding/base32"
@@ -469,3 +470,22 @@ func volumeExistsAndMatchesCapacity(ctx context.Context, v *Volume, capacity int
 	matches := reportedCapacity == capacity
 	return exists, matches, err
 }
+
+func isWekaInstalled() bool {
+	log.Info().Msg("Checking if wekafs is installed on host")
+	file, err := os.Open("/proc/modules")
+	if err != nil {
+		log.Err(err).Msg("Failed to check for existence of Weka kernel module")
+		return false
+	}
+	defer func() { _ = file.Close() }()
+	scanner := bufio.NewScanner(file)
+	for scanner.Scan() {
+		s := strings.Split(scanner.Text(), " ")
+		name := s[0]
+		if name == WekaKernelModuleName {
+			return true
+		}
+	}
+	return false
+}