|
|
@@ -2,6 +2,7 @@ package client
|
|
|
|
|
|
import (
|
|
|
"git.ikuban.com/server/kratos-nacos/registry"
|
|
|
+ "git.ikuban.com/server/pw-protobuf/api/activity"
|
|
|
"git.ikuban.com/server/pw-protobuf/api/user"
|
|
|
"github.com/go-kratos/kratos/v2/log"
|
|
|
)
|
|
|
@@ -17,3 +18,15 @@ func NewUserClient(r *registry.Registry, logger log.Logger) user.UserClient {
|
|
|
client := user.NewUserClient(conn)
|
|
|
return client
|
|
|
}
|
|
|
+
|
|
|
+func NewActivityClient(r *registry.Registry, logger log.Logger) activity.ActivityClient {
|
|
|
+ conn, err := getDialInsecure(r, logger, "discovery://pw/pw-user")
|
|
|
+ if err != nil {
|
|
|
+ panic(err)
|
|
|
+ }
|
|
|
+ if conn == nil {
|
|
|
+ return nil
|
|
|
+ }
|
|
|
+ client := activity.NewActivityClient(conn)
|
|
|
+ return client
|
|
|
+}
|