代码拉取完成,页面将自动刷新
package local
import (
"gitee.com/h79/goutils/common/logger"
"gitee.com/h79/goutils/common/server"
"gitee.com/h79/goutils/discovery/config"
"gitee.com/h79/goutils/discovery/errors"
"gitee.com/h79/goutils/discovery/resolver"
"gitee.com/h79/goutils/discovery/resolver/builder"
"gitee.com/h79/goutils/discovery/service"
)
var _ service.Client = (*defClient)(nil)
var _ builder.Builder = (*defClient)(nil)
type defClient struct {
node config.Node
endPoints config.EndPoints
resolver resolver.Resolver
}
func NewDefaultClient(conf config.Config, points config.EndPoints, resol resolver.Resolver) (service.Client, error) {
build := &defClient{
node: conf.Node,
endPoints: points,
resolver: resol,
}
resolver.Register(build)
return build, nil
}
func (cli *defClient) Start() error {
return nil
}
func (cli *defClient) Stop() {
}
// Set service.Config interface
func (cli *defClient) Set(data service.Data) error {
return errors.ErrNotSupported
}
// Get service.Config interface
func (cli *defClient) Get(key service.Key) ([]*service.Data, error) {
return nil, errors.ErrNotSupported
}
// Resolve service.Client and resolver.Builder interface
func (cli *defClient) Resolve(target builder.Target) []builder.Address {
if cli.resolver != nil {
return cli.resolver.Resolve(target)
}
return cli.defResolve(target)
}
func (cli *defClient) defResolve(target builder.Target) []builder.Address {
var adders []builder.Address
for _, ad := range cli.endPoints.Servers {
s := server.Address{
Scheme: ad.Scheme,
Host: ad.Host,
Port: ad.Port,
}
s.Adjust()
address := builder.Address{Addr: s.To(), ServerName: target.SchemeWith("")}
adders = append(adders, address)
}
return adders
}
// Build
// builder.Builder interface
func (cli *defClient) Build(target builder.Target, cc builder.Connector) (builder.Resolver, error) {
logger.Info("def.Client: Build target: %+v", target)
cr := resolver.NewResolver(target, cc, cli)
return cr, nil
}
// Scheme
// builder.Builder interface
func (cli *defClient) Scheme() string {
return cli.node.Scheme
}
// Type
// builder.Builder interface
func (cli *defClient) Type() string {
return cli.node.Type
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。