File tree 2 files changed +14
-4
lines changed
internal/application/server
2 files changed +14
-4
lines changed Original file line number Diff line number Diff line change 5
5
"fmt"
6
6
"os"
7
7
"os/signal"
8
+ "strings"
8
9
"syscall"
9
10
"time"
10
11
@@ -29,6 +30,7 @@ type Config struct {
29
30
DeviceDBPath string `env:"DEVICE_DB_PATH,required"`
30
31
GeoDBPath string `env:"GEO_DB_PATH,required"`
31
32
DSPAdaptersConfigFilesPath string `env:"DSP_ADAPTERS_CONFIG_FILES_PATH,required"`
33
+ EnabledDSPApdapters string `env:"ENABLED_DSP_ADAPTERS,required"`
32
34
}
33
35
34
36
func main () {
@@ -99,8 +101,15 @@ func main() {
99
101
100
102
app := core .New (s , l )
101
103
102
- enabledDSPAdapters := []interfaces.DSPName {
103
- "demo-dsp-1" ,
104
+ enabledDSPAdapters := []interfaces.DSPName {}
105
+
106
+ dspNames := strings .Split (config .EnabledDSPApdapters , "," )
107
+ if len (dspNames ) < 1 {
108
+ l .Errorf ("len of enabled dsp in config is: %d\n " , len (dspNames ))
109
+ os .Exit (1 )
110
+ }
111
+ for _ , dspName := range dspNames {
112
+ enabledDSPAdapters = append (enabledDSPAdapters , interfaces .DSPName (dspName ))
104
113
}
105
114
106
115
dspConfigProvider , err := default_config_provider .New (
Original file line number Diff line number Diff line change @@ -21,7 +21,8 @@ type Server struct {
21
21
listenAddr string
22
22
}
23
23
24
- func New (l interfaces.Logger ,
24
+ func New (
25
+ l interfaces.Logger ,
25
26
network , addr string ,
26
27
) * Server {
27
28
return & Server {
@@ -85,7 +86,7 @@ func (i *Server) Start(
85
86
<- ctx .Done ()
86
87
err := i .httpServer .Shutdown ()
87
88
if err != nil {
88
- i .logger .Errorf ("server shutdown" , "error " , err .Error ())
89
+ i .logger .Errorf ("server shutdown: %s " , err .Error ())
89
90
}
90
91
}()
91
92
You can’t perform that action at this time.
0 commit comments