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