vnfs/DAaaS/microservices/GoApps/src/go-hdfs-writer/pkg/utils/hdfs-config.go

   1 package utils
   2
   3 import (
   4         "os"
   5 )
   6
   7 // SetHdfsParametersByObjectMap set the value of the hdfs config parameters
   8 // and return HdfsConfig object
   9 func SetHdfsParametersByObjectMap(m map[string]interface{}) HdfsConfig{
  10
  11         hc := HdfsConfig{}
  12         hc.hdfsURL = m["hdfs_url"].(string)
  13         return hc
  14
  15 }
  16
  17 // SetHdfsParametersByEnvVariables sets the hdfs parameters
  18 func SetHdfsParametersByEnvVariables() HdfsConfig {
  19
  20         slogger := GetLoggerInstance()
  21         hdfsConfigObject := HdfsConfig{
  22                 hdfsURL: os.Getenv("HDFS_URL"),
  23         }
  24         slogger.Infof("::hdfsURL:: %s", hdfsConfigObject.hdfsURL)
  25         return hdfsConfigObject
  26
  27 }
  28
  29 // HdfsConfig contains hdfs related config items
  30 type HdfsConfig struct {
  31         hdfsURL string
  32 }
  33
  34 // GetHdfsURL returns HdfsURL
  35 func (h HdfsConfig) GetHdfsURL() string {
  36         return h.hdfsURL
  37 }