项目文件夹

文件

项目文件夹

0
T

69 行
1.1 KiB
Go

2021-07-06 11:12:19 +01:00
package web_test
import (
"context"
"sync"
"testing"
"time"
2021-11-08 08:52:39 +00:00
"github.com/urfave/cli/v2"
"go-micro.dev/v6"
"go-micro.dev/v6/logger"
"go-micro.dev/v6/web"
2021-07-06 11:12:19 +01:00
)
func TestWeb(t *testing.T) {
for i := 0; i < 10; i++ {
testFunc()
}
}
func testFunc() {
ctx, cancel := context.WithTimeout(context.Background(), time.Millisecond*250)
defer cancel()
service := micro.NewService("test", micro.Context(ctx),
2021-07-06 11:12:19 +01:00
micro.HandleSignal(false),
micro.Flags(
&cli.StringFlag{
Name: "test.timeout",
},
&cli.BoolFlag{
Name: "test.v",
},
&cli.StringFlag{
Name: "test.run",
},
&cli.StringFlag{
Name: "test.testlogfile",
},
),
)
w := web.NewService(
2022-09-30 20:32:55 +02:00
web.MicroService(service),
2021-07-06 11:12:19 +01:00
web.Context(ctx),
web.HandleSignal(false),
)
2022-09-30 16:27:07 +02:00
// s.Init()
2022-09-30 20:32:55 +02:00
// w.Init()
2021-07-06 11:12:19 +01:00
var wg sync.WaitGroup
wg.Add(2)
go func() {
defer wg.Done()
2022-09-30 20:32:55 +02:00
err := service.Run()
2021-07-06 11:12:19 +01:00
if err != nil {
logger.Logf(logger.ErrorLevel, "micro run error: %v", err)
2021-07-06 11:12:19 +01:00
}
}()
go func() {
defer wg.Done()
err := w.Run()
if err != nil {
logger.Logf(logger.ErrorLevel, "web run error: %v", err)
2021-07-06 11:12:19 +01:00
}
}()
wg.Wait()
}