X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pm-file-converter%2Fcomponents%2Fminiocollector%2Fminiocollector.go;h=ac8ce0544f740befd5173c18795071789a197f8b;hb=32670048f87df57299d2578d54c95eccc8732e9b;hp=1663194885024ceae4e8193a6b6148677d9450fa;hpb=0bb219edead30bb0459abd2cd2163326c97ca92d;p=nonrtric%2Fplt%2Franpm.git

diff --git a/pm-file-converter/components/miniocollector/miniocollector.go b/pm-file-converter/components/miniocollector/miniocollector.go
index 1663194..ac8ce05 100644
--- a/pm-file-converter/components/miniocollector/miniocollector.go
+++ b/pm-file-converter/components/miniocollector/miniocollector.go
@@ -24,10 +24,6 @@ import (
 	"compress/gzip"
 	"context"
 	"fmt"
-	jsoniter "github.com/json-iterator/go"
-	"github.com/minio/minio-go/v7"
-	"github.com/minio/minio-go/v7/pkg/credentials"
-	log "github.com/sirupsen/logrus"
 	"io"
 	"main/common/dataTypes"
 	"main/components/xmltransform"
@@ -35,8 +31,14 @@ import (
 	"os"
 	"strings"
 	"time"
+
+	jsoniter "github.com/json-iterator/go"
+	"github.com/minio/minio-go/v7"
+	"github.com/minio/minio-go/v7/pkg/credentials"
+	log "github.com/sirupsen/logrus"
 )
 
+// nolint
 func Xml_to_json_conv(evt_data *dataTypes.XmlFileEventHeader) string {
 	filestoreUser := os.Getenv("FILESTORE_USER")
 	filestorePwd := os.Getenv("FILESTORE_PWD")
@@ -76,6 +78,7 @@ func Xml_to_json_conv(evt_data *dataTypes.XmlFileEventHeader) string {
 	return newObjectName
 }
 
+// nolint
 func upload_object(mc *minio.Client, b []byte, objectName string, fsbucket string) {
 	contentType := "application/json"
 	if strings.HasSuffix(objectName, ".gz") {
@@ -109,6 +112,7 @@ func upload_object(mc *minio.Client, b []byte, objectName string, fsbucket strin
 	}
 }
 
+// nolint
 func create_minio_bucket(mc *minio.Client, bucket string) error {
 	tctx := context.Background()
 	err := mc.MakeBucket(tctx, bucket, minio.MakeBucketOptions{})
@@ -127,6 +131,7 @@ func create_minio_bucket(mc *minio.Client, bucket string) error {
 	return nil
 }
 
+// nolint
 func check_minio_bucket(mc *minio.Client, bucket string) bool {
 	tctx := context.Background()
 	exists, err := mc.BucketExists(tctx, bucket)
@@ -139,6 +144,7 @@ func check_minio_bucket(mc *minio.Client, bucket string) bool {
 }
 
 // Write gzipped data to a Writer
+// nolint
 func gzipWrite(w io.Writer, data *[]byte) error {
 	gw, err1 := gzip.NewWriterLevel(w, gzip.BestSpeed)