"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"
"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")
return newObjectName
}
+// nolint
func upload_object(mc *minio.Client, b []byte, objectName string, fsbucket string) {
contentType := "application/json"
if strings.HasSuffix(objectName, ".gz") {
}
}
+// nolint
func create_minio_bucket(mc *minio.Client, bucket string) error {
tctx := context.Background()
err := mc.MakeBucket(tctx, bucket, minio.MakeBucketOptions{})
return nil
}
+// nolint
func check_minio_bucket(mc *minio.Client, bucket string) bool {
tctx := context.Background()
exists, err := mc.BucketExists(tctx, bucket)
}
// Write gzipped data to a Writer
+// nolint
func gzipWrite(w io.Writer, data *[]byte) error {
gw, err1 := gzip.NewWriterLevel(w, gzip.BestSpeed)