client.go 497 B

1234567891011121314151617181920
  1. package api
  2. import (
  3. "context"
  4. "go-common/library/net/rpc/warden"
  5. "google.golang.org/grpc"
  6. )
  7. // AppID unique app id for service discovery
  8. const AppID = "bbq.service.topic"
  9. // NewClient new member grpc client
  10. func NewClient(cfg *warden.ClientConfig, opts ...grpc.DialOption) (TopicClient, error) {
  11. client := warden.NewClient(cfg, opts...)
  12. conn, err := client.Dial(context.Background(), "discovery://default/"+AppID)
  13. if err != nil {
  14. return nil, err
  15. }
  16. return NewTopicClient(conn), nil
  17. }