Mod:recycle refer

metadata/instance.go → config/instance/metedata_report.go

@@ -15,26 +15,27 @@
  * limitations under the License.
  */
 
-package metadata
+package instance
+
+import (
+	"sync"
+)
 
 import (
 	"github.com/apache/dubbo-go/common"
 	"github.com/apache/dubbo-go/common/extension"
-	"sync"
+	"github.com/apache/dubbo-go/metadata"
 )
 
 var (
-	instance MetadataReport
+	instance metadata.MetadataReport
 	once     sync.Once
 )
 
-// GetEnvInstance ...
-func Init(url *common.URL) {
+// GetMetadataReportInstance ...
+func GetMetadataReportInstance(url *common.URL) metadata.MetadataReport {
 	once.Do(func() {
-		instance = extension.GetMetadataReportFactory(url.Protocol).createMetadataReport(url)
+		instance = extension.GetMetadataReportFactory(url.Protocol).CreateMetadataReport(url)
 	})
-}
-
-func GetMetadataReportInstance() MetadataReport {
 	return instance
 }

config/metadata_report_config.go

@@ -18,9 +18,9 @@
 package config
 
 import (
-	"github.com/apache/dubbo-go/metadata"
 	"net/url"
 )
+
 import (
 	"github.com/creasty/defaults"
 	perrors "github.com/pkg/errors"
@@ -29,6 +29,7 @@ import (
 import (
 	"github.com/apache/dubbo-go/common"
 	"github.com/apache/dubbo-go/common/constant"
+	"github.com/apache/dubbo-go/config/instance"
 )
 
 // MethodConfig ...
@@ -93,7 +94,7 @@ func startMetadataReport() error {
 			return perrors.New("MetadataConfig address can not be empty.")
 		}
 		if url, err := consumerConfig.MetadataReportConfig.ToUrl(); err == nil {
-			metadata.Init(url)
+			instance.GetMetadataReportInstance(url)
 		} else {
 			return perrors.New("MetadataConfig is invalid!")
 		}

metadata/report_factory.go

@@ -24,5 +24,5 @@ var (
 )
 
 type MetadataReportFactory interface {
-	createMetadataReport(*common.URL) MetadataReport
+	CreateMetadataReport(*common.URL) MetadataReport
 }