()
| 1063 | } |
| 1064 | |
| 1065 | func startHTTP() (*http.Server, chan struct{}) { |
| 1066 | cfg, err := loadConfig() |
| 1067 | if err != nil { |
| 1068 | panic(fmt.Sprintf("error while loading config: %s", err)) |
| 1069 | } |
| 1070 | if err = applyConfig(cfg); err != nil { |
| 1071 | panic(fmt.Sprintf("error while applying config: %s", err)) |
| 1072 | } |
| 1073 | done := make(chan struct{}) |
| 1074 | ln, err := net.Listen("tcp4", cfg.Server.HTTP.ListenAddr) |
| 1075 | if err != nil { |
| 1076 | panic(fmt.Sprintf("cannot listen for %q: %s", cfg.Server.HTTP.ListenAddr, err)) |
| 1077 | } |
| 1078 | h := http.HandlerFunc(serveHTTP) |
| 1079 | s := newServer(ln, h, config.TimeoutCfg{}) |
| 1080 | go func() { |
| 1081 | s.Serve(ln) |
| 1082 | close(done) |
| 1083 | }() |
| 1084 | return s, done |
| 1085 | } |
| 1086 | |
| 1087 | // TODO randomise port for each instance of the mock |
| 1088 | func startRedis(t *testing.T) *miniredis.Miniredis { |
nothing calls this directly
no test coverage detected