fix mcpbridge endpoint port (#1382)

2026-03-07 18:10:54 +08:00 · 2024-10-11 11:39:46 +08:00
parent ae6dab919d
commit 1a53c7b4d3
1 changed files with 1 additions and 1 deletions
--- a/registry/direct/watcher.go
+++ b/registry/direct/watcher.go
@@ -152,7 +152,7 @@ func (w *watcher) generateServiceEntry(host string) *v1alpha3.ServiceEntry {
 			}
 			endpoint = &v1alpha3.WorkloadEntry{
 				Address: pair[0],
-				Ports:   map[string]uint32{"http": uint32(port)},
+				Ports:   map[string]uint32{w.Protocol: uint32(port)},
 			}
 		} else if w.Type == string(registry.DNS) {
 			if !domainRegex.MatchString(ep) {