31 lines
676 B
Go
31 lines
676 B
Go
package server
|
|
|
|
import (
|
|
"github.com/go-kratos/kratos/contrib/registry/etcd/v2"
|
|
"github.com/go-kratos/kratos/v2/log"
|
|
"github.com/go-kratos/kratos/v2/registry"
|
|
etcdclient "go.etcd.io/etcd/client/v3"
|
|
"sandc/app/eonline/internal/conf"
|
|
)
|
|
|
|
func newEtcd(conf *conf.Server) *etcd.Registry {
|
|
client, err := etcdclient.New(etcdclient.Config{
|
|
Endpoints: conf.Etcd.Addr,
|
|
Username: conf.Etcd.Username,
|
|
Password: conf.Etcd.Password,
|
|
})
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
r := etcd.New(client)
|
|
return r
|
|
}
|
|
|
|
func NewDiscovery(conf *conf.Server) registry.Discovery {
|
|
return newEtcd(conf)
|
|
}
|
|
|
|
func NewRegistrar(conf *conf.Server) registry.Registrar {
|
|
return newEtcd(conf)
|
|
}
|