Merge pull request #30 from Kuri-su/feature-kurisu-optimization-consu…

…l-watcher-220705 feat: optimization consul watcher
micro · Jul 24, 2022 · 00666a4 · 00666a4
2 parents e3081cf + c0c846a
commit 00666a4
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 3 deletions.
diff --git a/v2/registry/consul/watcher.go b/v2/registry/consul/watcher.go
@@ -40,7 +40,10 @@ func newConsulWatcher(cr *consulRegistry, opts ...registry.WatchOption) (registr
 		services: make(map[string][]*registry.Service),
 	}
 
-	wp, err := watch.Parse(map[string]interface{}{"type": "services"})
+	wp, err := watch.Parse(map[string]interface{}{
+		"service": wo.Service,
+		"type":    "service",
+	})
 	if err != nil {
 		return nil, err
 	}

diff --git a/v3/registry/consul/watcher.go b/v3/registry/consul/watcher.go
@@ -38,7 +38,10 @@ func newConsulWatcher(cr *consulRegistry, opts ...registry.WatchOption) (registr
 		services: make(map[string][]*registry.Service),
 	}
 
-	wp, err := watch.Parse(map[string]interface{}{"type": "services"})
+	wp, err := watch.Parse(map[string]interface{}{
+		"service": wo.Service,
+		"type":    "service",
+	})
 	if err != nil {
 		return nil, err
 	}

diff --git a/v4/registry/consul/watcher.go b/v4/registry/consul/watcher.go
@@ -39,7 +39,10 @@ func newConsulWatcher(cr *consulRegistry, opts ...registry.WatchOption) (registr
 		services: make(map[string][]*registry.Service),
 	}
 
-	wp, err := watch.Parse(map[string]interface{}{"type": "services"})
+	wp, err := watch.Parse(map[string]interface{}{
+		"service": wo.Service,
+		"type":    "service",
+	})
 	if err != nil {
 		return nil, err
 	}