diff options
Diffstat (limited to 'service')
| -rw-r--r-- | service/env/provider.go | 2 | ||||
| -rw-r--r-- | service/env/service.go | 4 | ||||
| -rw-r--r-- | service/http/service.go | 7 |
3 files changed, 9 insertions, 4 deletions
diff --git a/service/env/provider.go b/service/env/provider.go index 75a1e31b..2918f18c 100644 --- a/service/env/provider.go +++ b/service/env/provider.go @@ -4,5 +4,5 @@ package env // values from external sources. type Provider interface { // GetEnv must return list of env variables. - GetEnv() map[string]string + GetEnv() (map[string]string, error) } diff --git a/service/env/service.go b/service/env/service.go index 95e99093..a90b0c48 100644 --- a/service/env/service.go +++ b/service/env/service.go @@ -16,6 +16,6 @@ func (s *Service) Init(cfg *Config) (bool, error) { } // GetEnv must return list of env variables. -func (s *Service) GetEnv() map[string]string { - return s.cfg.Values +func (s *Service) GetEnv() (map[string]string, error) { + return s.cfg.Values, nil } diff --git a/service/http/service.go b/service/http/service.go index a8f99669..9f62f5af 100644 --- a/service/http/service.go +++ b/service/http/service.go @@ -61,7 +61,12 @@ func (s *Service) Serve() error { s.mu.Lock() if s.env != nil { - for k, v := range s.env.GetEnv() { + values, err := s.env.GetEnv() + if err != nil { + return err + } + + for k, v := range values { s.cfg.Workers.SetEnv(k, v) } } |