linka-cloud/grpc-toolkit
2
0
Fork 0
mirror of https://github.com/linka-cloud/grpc.git synced 2025-06-22 09:12:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

deps: upgrade grpc

Browse Source 
Signed-off-by: Adphi <philippe.adrien.nousse@gmail.com>
This commit is contained in:
Adphi
2023-02-21 14:47:43 +01:00
parent 8f75b6aca4
commit 2bb79e6c11
3 changed files with 565 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
resolver/resolver.go
View File

@ -35,11 +35,11 @@ type resolvr struct {
func (r *resolvr) run() {
if r.reg.String() == "noop" {
r.cc.UpdateState(resolver.State{Addresses: []resolver.Address{{Addr: r.target.Endpoint}}})
r.cc.UpdateState(resolver.State{Addresses: []resolver.Address{{Addr: r.target.Endpoint()}}})
return
}
var name, version string
parts := strings.Split(r.target.Endpoint, ":")
parts := strings.Split(r.target.Endpoint(), ":")
name = parts[0]
if len(parts) > 1 {
version = parts[1]
@ -57,7 +57,7 @@ func (r *resolvr) run() {
}
}
r.cc.UpdateState(resolver.State{Addresses: r.addrs})
w, err := r.reg.Watch(registry.WatchService(r.target.Endpoint))
w, err := r.reg.Watch(registry.WatchService(r.target.Endpoint()))
if err != nil {
return
}
@ -80,7 +80,7 @@ func (r *resolvr) run() {
func (r *resolvr) ResolveNow(options resolver.ResolveNowOptions) {
if r.reg.String() == "noop" {
r.cc.UpdateState(resolver.State{Addresses: []resolver.Address{{Addr: r.target.Endpoint}}})
r.cc.UpdateState(resolver.State{Addresses: []resolver.Address{{Addr: r.target.Endpoint()}}})
}
}