add consul config center

cluster/master/options.go

@@ -2,7 +2,7 @@ package master
 
 import (
 	"context"
-	"github.com/dobyte/due/v2/config/configurator"
+	"github.com/dobyte/due/v2/config"
 	"github.com/dobyte/due/v2/crypto"
 	"github.com/dobyte/due/v2/encoding"
 	"github.com/dobyte/due/v2/etc"
@@ -29,17 +29,17 @@ const (
 type Option func(o *options)
 
 type options struct {
-	id           string                    // 实例ID
-	name         string                    // 实例名称
-	ctx          context.Context           // 上下文
-	codec        encoding.Codec            // 编解码器
-	timeout      time.Duration             // RPC调用超时时间
-	locator      locate.Locator            // 用户定位器
-	registry     registry.Registry         // 服务注册器
-	transporter  transport.Transporter     // 消息传输器
-	encryptor    crypto.Encryptor          // 消息加密器
-	configSource configurator.Source       // 配置源
-	configurator configurator.Configurator // 配置器
+	id           string                // 实例ID
+	name         string                // 实例名称
+	ctx          context.Context       // 上下文
+	codec        encoding.Codec        // 编解码器
+	timeout      time.Duration         // RPC调用超时时间
+	locator      locate.Locator        // 用户定位器
+	registry     registry.Registry     // 服务注册器
+	transporter  transport.Transporter // 消息传输器
+	encryptor    crypto.Encryptor      // 消息加密器
+	configSource config.Source         // 配置源
+	configurator config.Configurator   // 配置器
 }
 
 func defaultOptions() *options {
@@ -118,8 +118,8 @@ func WithEncryptor(encryptor crypto.Encryptor) Option {
 }
 
 // WithConfigSource 设置配置源
-func WithConfigSource(configSource configurator.Source) Option {
+func WithConfigSource(source config.Source) Option {
 	return func(o *options) {
-		o.configSource, o.configurator = configSource, configurator.NewConfigurator(configurator.WithSources(configSource))
+		o.configSource, o.configurator = source, config.NewConfigurator(config.WithSources(source))
 	}
 }

cluster/master/proxy.go

@@ -3,7 +3,7 @@ package master
 import (
 	"context"
 	"github.com/dobyte/due/v2/cluster"
-	"github.com/dobyte/due/v2/config/configurator"
+	"github.com/dobyte/due/v2/config"
 	"github.com/dobyte/due/v2/errors"
 	"github.com/dobyte/due/v2/internal/link"
 	"github.com/dobyte/due/v2/registry"
@@ -45,7 +45,7 @@ func (p *Proxy) GetMasterName() string {
 }
 
 // LoadConfig 加载配置
-func (p *Proxy) LoadConfig(ctx context.Context, file string) ([]*configurator.Configuration, error) {
+func (p *Proxy) LoadConfig(ctx context.Context, file string) ([]*config.Configuration, error) {
 	if p.master.opts.configurator != nil {
 		return p.master.opts.configurator.Load(ctx, p.master.opts.configSource.Name(), file)
 	}

container.go

@@ -66,6 +66,8 @@ func (c *Container) Serve() {
 		log.Errorf("eventbus close failed: %v", err)
 	}
 
+	eventbus.Close()
+
 	task.Release()
 
 	config.Close()

internal/link/link.go

@@ -177,8 +177,6 @@ func (l *Link) LocateGate(ctx context.Context, uid int64) (string, error) {
 	}
 
 	if gid == "" {
-		l.gateSource.Delete(uid)
-
 		return "", errors.ErrNotFoundUserLocation
 	}
 
@@ -606,7 +604,10 @@ func (l *Link) Deliver(ctx context.Context, args *DeliverArgs) error {
 			miss, err := client.Deliver(ctx, arguments)
 			return miss, nil, err
 		})
-		return err
+		if err != nil && err != errors.ErrNotFoundUserLocation {
+			return err
+		}
+		return nil
 	}
 }