1 files changed, 37 insertions, 0 deletions
diff --git a/vnfs/DAaaS/microservices/GoApps/src/go-hdfs-writer/pkg/utils/hdfs-config.go b/vnfs/DAaaS/microservices/GoApps/src/go-hdfs-writer/pkg/utils/hdfs-config.go
new file mode 100644
index 00000000..ac33bc6a
--- /dev/null
+++ b/vnfs/DAaaS/microservices/GoApps/src/go-hdfs-writer/pkg/utils/hdfs-config.go
@@ -0,0 +1,37 @@
+package utils
+
+import (
+	"os"
+)
+
+// SetHdfsParametersByObjectMap set the value of the hdfs config parameters
+// and return HdfsConfig object
+func SetHdfsParametersByObjectMap(m map[string]interface{}) HdfsConfig{
+
+	hc := HdfsConfig{}
+	hc.hdfsURL = m["hdfs_url"].(string)
+	return hc
+
+}
+
+// SetHdfsParametersByEnvVariables sets the hdfs parameters
+func SetHdfsParametersByEnvVariables() HdfsConfig {
+	
+	slogger := GetLoggerInstance()
+	hdfsConfigObject := HdfsConfig{
+		hdfsURL: os.Getenv("HDFS_URL"),
+	}
+	slogger.Infof("::hdfsURL:: %s", hdfsConfigObject.hdfsURL)
+	return hdfsConfigObject
+	
+}
+
+// HdfsConfig contains hdfs related config items
+type HdfsConfig struct {
+	hdfsURL string
+}
+
+// GetHdfsURL returns HdfsURL
+func (h HdfsConfig) GetHdfsURL() string {
+	return h.hdfsURL
+}
+\ No newline at end of file