fixed resource manager panic (#214)

ortuman · Feb 25, 2022 · 414d2eb · 414d2eb
1 parent 2b28746
commit 414d2eb
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/pkg/jackal/jackal.go b/pkg/jackal/jackal.go
@@ -266,15 +266,14 @@ func (j *Jackal) Run() error {
 }
 
 func (j *Jackal) initCluster(cfg ClusterConfig) error {
-	if !cfg.IsEnabled() {
-		return nil
-	}
-
 	switch cfg.Type {
 	case kvClusterType:
 		if err := j.initKVStore(cfg.KV); err != nil {
 			return err
 		}
+		fallthrough
+
+	case noneClusterType:
 		j.memberList = memberlist.NewKVMemberList(cfg.Server.Port, j.kv, j.hk, j.logger)
 		j.resMng = resourcemanager.NewKVManager(j.kv, j.logger)