From 4f2eace2c668c0e56c4cb616cc088b7f159beb35 Mon Sep 17 00:00:00 2001 From: Tanghui Lin Date: Fri, 17 May 2019 10:42:13 +0800 Subject: [PATCH 1/2] fix nodesproc --- CHANGELOG.md | 3 +++ discovery/syncup.go | 1 - 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 8ae0295..b6b5da8 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,4 +1,7 @@ #### Discovery +##### Version 1.0.2 +> 1.fix nodesproc. get all zone nodes. + ##### Version 1.0.1 > 1.rename import path diff --git a/discovery/syncup.go b/discovery/syncup.go index 5cfc066..1757a75 100644 --- a/discovery/syncup.go +++ b/discovery/syncup.go @@ -107,7 +107,6 @@ func (d *Discovery) nodesproc() { for { arg := &model.ArgPolls{ AppID: []string{model.AppID}, - Zone: d.c.Env.Zone, Env: d.c.Env.DeployEnv, Hostname: d.c.Env.Host, LatestTimestamp: []int64{lastTs}, From a1451a00448d1b0b3c9ed68165983de1e8802c5a Mon Sep 17 00:00:00 2001 From: Tanghui Lin Date: Fri, 17 May 2019 11:07:32 +0800 Subject: [PATCH 2/2] fix test --- discovery/syncup.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/discovery/syncup.go b/discovery/syncup.go index 1757a75..be89e5b 100644 --- a/discovery/syncup.go +++ b/discovery/syncup.go @@ -131,7 +131,7 @@ func (d *Discovery) nodesproc() { for _, addr := range in.Addrs { u, err := url.Parse(addr) if err == nil && u.Scheme == "http" { - if in.Zone == arg.Zone { + if in.Zone == d.c.Env.Zone { nodes = append(nodes, u.Host) } else { zones[in.Zone] = append(zones[in.Zone], u.Host)