DataService/jy_publishing/tool/etcd.go

package tool

import (
	"github.com/zeromicro/go-zero/core/discov"
	"github.com/zeromicro/go-zero/zrpc"
	. "jy_publishing/Logger"
	util "jygit.jydev.jianyu360.cn/data_processing/common_utils"
	"strings"
)

func InitEtcd() {
	jyRpc := Sysconfig["jy_rpc"].(map[string]interface{})
	Logger.Debug("etcd 注册rpc服务, " + util.ObjToString(jyRpc["key"]))
	JyRpcClient = zrpc.MustNewClient(zrpc.RpcClientConf{
		Etcd: discov.EtcdConf{
			Hosts: strings.Split(util.ObjToString(jyRpc["addr"]), ","),
			Key:   util.ObjToString(jyRpc["key"]),
		},
	})
}