user.go 764 B

1234567891011121314151617181920212223242526272829303132
  1. package client
  2. import (
  3. "git.ikuban.com/server/kratos-nacos/registry"
  4. "git.ikuban.com/server/pw-protobuf/api/activity"
  5. "git.ikuban.com/server/pw-protobuf/api/user"
  6. "github.com/go-kratos/kratos/v2/log"
  7. )
  8. func NewUserClient(r *registry.Registry, logger log.Logger) user.UserClient {
  9. conn, err := getDialInsecure(r, logger, "discovery://pw/pw-user")
  10. if err != nil {
  11. panic(err)
  12. }
  13. if conn == nil {
  14. return nil
  15. }
  16. client := user.NewUserClient(conn)
  17. return client
  18. }
  19. func NewActivityClient(r *registry.Registry, logger log.Logger) activity.ActivityClient {
  20. conn, err := getDialInsecure(r, logger, "discovery://pw/pw-activity")
  21. if err != nil {
  22. panic(err)
  23. }
  24. if conn == nil {
  25. return nil
  26. }
  27. client := activity.NewActivityClient(conn)
  28. return client
  29. }