-
Notifications
You must be signed in to change notification settings - Fork 0
/
muses.go
49 lines (44 loc) · 1.14 KB
/
muses.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
package muses
import (
"fmt"
"github.com/yitume/muses/pkg/app"
"github.com/yitume/muses/pkg/common"
"github.com/yitume/muses/pkg/logger"
"github.com/yitume/muses/pkg/prom"
)
func Container(cfg interface{}, callerFuncs ...common.CallerFunc) (err error) {
var cfgByte []byte
switch cfg.(type) {
case string:
cfgByte, err = parseFile(cfg.(string))
if err != nil {
return
}
case []byte:
cfgByte = cfg.([]byte)
default:
return fmt.Errorf("type is error %s", cfg)
}
allCallers := []common.CallerFunc{app.Register, logger.Register, prom.Register}
allCallers = append(allCallers, callerFuncs...)
callers, err := sortCallers(allCallers)
if err != nil {
return
}
for _, caller := range callers {
name := getCallerName(caller)
fmt.Println("module", name, "start")
if err = caller.InitCfg(cfgByte); err != nil {
fmt.Println("module", name, "init config error")
return
}
fmt.Println("module", name, "init config ok")
if err = caller.InitCaller(); err != nil {
fmt.Println("module", name, "init caller error")
return
}
fmt.Println("module", name, "init caller ok")
fmt.Println("module", name, "end")
}
return nil
}