diff --git a/dtmsvr/storage/registry/registry.go b/dtmsvr/storage/registry/registry.go index e699bd3..7a2105b 100644 --- a/dtmsvr/storage/registry/registry.go +++ b/dtmsvr/storage/registry/registry.go @@ -3,6 +3,8 @@ package registry import ( "time" + "github.com/dtm-labs/dtm/dtmcli/logger" + "github.com/dtm-labs/dtm/dtmsvr/config" "github.com/dtm-labs/dtm/dtmsvr/storage" "github.com/dtm-labs/dtm/dtmsvr/storage/boltdb" @@ -48,5 +50,6 @@ func GetStore() storage.Store { func WaitStoreUp() { for err := GetStore().Ping(); err != nil; err = GetStore().Ping() { time.Sleep(3 * time.Second) + logger.Infof("wait store up") } }