32 lines
720 B
Go
32 lines
720 B
Go
package servicecomb
|
|
|
|
import (
|
|
servicecombKratos "github.com/go-kratos/kratos/contrib/registry/servicecomb/v2"
|
|
"github.com/go-kratos/kratos/v2/log"
|
|
|
|
servicecombClient "github.com/go-chassis/sc-client"
|
|
|
|
conf "github.com/tx7do/kratos-bootstrap/api/gen/go/conf/v1"
|
|
)
|
|
|
|
// NewRegistry 创建一个注册发现客户端 - Servicecomb
|
|
func NewRegistry(c *conf.Registry) *servicecombKratos.Registry {
|
|
if c == nil || c.Servicecomb == nil {
|
|
return nil
|
|
}
|
|
|
|
cfg := servicecombClient.Options{
|
|
Endpoints: c.Servicecomb.Endpoints,
|
|
}
|
|
|
|
var cli *servicecombClient.Client
|
|
var err error
|
|
if cli, err = servicecombClient.NewClient(cfg); err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
|
|
reg := servicecombKratos.NewRegistry(cli)
|
|
|
|
return reg
|
|
}
|