in polaris/limit/go-client/cmd/main.go [54:84]
func main() {
var userProvider = &UserProvider{}
var userProviderWithCustomRegistryGroupAndVersion = &UserProviderWithCustomGroupAndVersion{}
config.SetConsumerService(userProvider)
config.SetConsumerService(userProviderWithCustomRegistryGroupAndVersion)
hessian.RegisterPOJO(&User{})
err := config.Load()
if err != nil {
panic(err)
}
logger.Infof("\n\n\nstart to test dubbo")
var successCount, failCount int64
for i := 0; i < 10; i++ {
time.Sleep(50 * time.Millisecond)
user, err := userProvider.GetUser(context.TODO(), &User{Name: "Alex03"})
if err != nil {
failCount++
logger.Infof("error: %v\n", err)
} else {
successCount++
}
logger.Infof("response: %v\n", user)
}
logger.Infof("successCount=%v, failCount=%v\n", successCount, failCount)
if failCount == 0 {
panic(errors.New("need failCount > 0"))
}
}