unistack-org/micro
4
0
Fork 2
Code Issues 18 Pull Requests Actions Packages Projects Releases 331 Wiki Activity

propagate updates to local watchers

Browse Source
This commit is contained in:
Asim Aslam
2019-06-18 14:42:56 +01:00
parent ed54384bf4
commit 6459cdfc21
1 changed files with 13 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
registry/gossip/gossip.go
View File

@@ -734,6 +734,12 @@ func (g *gossipRegistry) Register(s *registry.Service, opts ...registry.Register
notify: nil, notify: nil,
}) })
// send update to local watchers
g.updates <- &update{
Update: up,
Service: s,
}
// wait // wait
<-time.After(g.interval * 2) <-time.After(g.interval * 2)
@@ -770,6 +776,13 @@ func (g *gossipRegistry) Deregister(s *registry.Service) error {
notify: nil, notify: nil,
}) })
// send update to local watchers
// send update to local watchers
g.updates <- &update{
Update: up,
Service: s,
}
// wait // wait
<-time.After(g.interval * 2) <-time.After(g.interval * 2)