HDFSWriter microservice working copy

[demo.git] / vnfs / DAaaS / microservices / GoApps / src / go-hdfs-writer / pkg / utils / hdfs-config.go

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 (file)
index 0000000..ac33bc6
--- /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