(config string)
| 1358 | } |
| 1359 | |
| 1360 | func startTestServer(config string) error { |
| 1361 | var err error |
| 1362 | server, err = srv.NewServer(config) |
| 1363 | if err != nil { |
| 1364 | return err |
| 1365 | } |
| 1366 | |
| 1367 | go func() { |
| 1368 | err := server.Start() |
| 1369 | if err != nil { |
| 1370 | panic(err) |
| 1371 | } |
| 1372 | }() |
| 1373 | |
| 1374 | retry := 3 |
| 1375 | for { |
| 1376 | conn, err := net.Dial("tcp", server.Address()) |
| 1377 | if err == nil { |
| 1378 | conn.Close() |
| 1379 | break |
| 1380 | } |
| 1381 | retry-- |
| 1382 | if retry == 0 { |
| 1383 | return errors.New("server not started") |
| 1384 | } |
| 1385 | time.Sleep(50 * time.Millisecond) |
| 1386 | } |
| 1387 | server.SetRunning(true) |
| 1388 | |
| 1389 | return nil |
| 1390 | } |
| 1391 | |
| 1392 | func getNetwork(color string, tenant string) map[string]interface{} { |
| 1393 | return map[string]interface{}{ |
no test coverage detected