diff --git a/db/db.go b/db/db.go deleted file mode 100644 index 0e9dfed..0000000 --- a/db/db.go +++ /dev/null @@ -1,48 +0,0 @@ -package db - -import ( - "git.hlsq.asia/mmorpg/service-common/config" - "git.hlsq.asia/mmorpg/service-common/db/etcd" - "git.hlsq.asia/mmorpg/service-common/db/mysql" - "git.hlsq.asia/mmorpg/service-common/db/redis" - "git.hlsq.asia/mmorpg/service-common/log" -) - -// ModuleDB 数据库模块 -type ModuleDB struct { -} - -func (p *ModuleDB) Init(cfg *config.DBConfig) error { - // ETCD - if cfg.Etcd != nil { - if err := etcd.Init(cfg.Etcd); err != nil { - return err - } - } - // MYSQL - if cfg.MySQL != nil { - if err := mysql.Init(cfg.MySQL); err != nil { - return err - } - } - // REDIS - if cfg.Redis != nil { - if err := redis.Init(cfg.Redis); err != nil { - return err - } - } - return nil -} - -func (p *ModuleDB) Stop() error { - if err := etcd.Close(); err != nil { - log.Errorf("close etcd failed: %v", err) - } - if err := mysql.Close(); err != nil { - log.Errorf("close mysql failed: %v", err) - } - if err := redis.Close(); err != nil { - log.Errorf("close redis failed: %v", err) - } - return nil -} diff --git a/module/discover.go b/module/discover.go new file mode 100644 index 0000000..ba476a5 --- /dev/null +++ b/module/discover.go @@ -0,0 +1,25 @@ +package module + +import "git.hlsq.asia/mmorpg/service-common/discover" + +// Discover 服务发现模块 +type Discover struct { +} + +func (m *Discover) Init() error { + return nil +} + +func (m *Discover) Start() error { + discover.Listen() + return nil +} + +func (m *Discover) Stop() error { + discover.Close() + return nil +} + +func (m *Discover) Bind(_ ...any) Module { + return m +}