Fix: xds enhancement

common/proxy/proxy_factory/default.go

@@ -67,6 +67,7 @@ func (factory *DefaultProxyFactory) GetAsyncProxy(invoker protocol.Invoker, call
 	// create proxy
 	attachments := map[string]string{}
 	attachments[constant.AsyncKey] = url.GetParam(constant.AsyncKey, "false")
+	attachments[constant.EnvironmentKey] = url.GetParam(constant.EnvironmentKey, "dev")
 	return proxy.NewProxy(invoker, callBack, attachments)
 }
 

registry/xds/registry.go

@@ -60,23 +60,24 @@ func getCategory(url *common.URL) string {
 	return category
 }
 
+// getServiceName return serviceName $(providers_or_consumers):$(interfaceName)
 func getServiceName(url *common.URL) string {
 	var buffer bytes.Buffer
 
 	buffer.Write([]byte(getCategory(url)))
 	appendParam(&buffer, url, constant.InterfaceKey)
-	appendParam(&buffer, url, constant.VersionKey)
-	appendParam(&buffer, url, constant.GroupKey)
 	return buffer.String()
 }
 
+// getSubscribeName returns subscribeName is providers:$(interfaceName)
 func getSubscribeName(url *common.URL) string {
 	var buffer bytes.Buffer
 
 	buffer.Write([]byte(common.DubboNodes[common.PROVIDER]))
 	appendParam(&buffer, url, constant.InterfaceKey)
-	appendParam(&buffer, url, constant.VersionKey)
-	appendParam(&buffer, url, constant.GroupKey)
+	// We would not append group or version to this name, as istio ecosystem only cares about 'hostname' during cds procedure.
+	// The subscribe name is used to find the real hostName.
+	// Group or version are managed by traffic policy, not dubbo-go.
 	return buffer.String()
 }