1 Star 0 Fork 0

h79/goutils

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
克隆/下载
client.go 2.15 KB
一键复制 编辑 原始数据 按行查看 历史
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
}
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
Go
1
https://gitee.com/h79/goutils.git
git@gitee.com:h79/goutils.git
h79
goutils
goutils
v1.3.6

搜索帮助

A270a887 8829481 3d7a4017 8829481