Browse Source

add panic

Yeuoly 11 months ago
parent
commit
b5cc7b7080
1 changed files with 7 additions and 3 deletions
  1. 7 3
      internal/core/persistence/init.go

+ 7 - 3
internal/core/persistence/init.go

@@ -20,9 +20,13 @@ func InitPersistence(config *app.Config) *Persistence {
 		return &Persistence{
 			storage: s3,
 		}
+	} else if config.PersistenceStorageType == "local" {
+		return &Persistence{
+			storage: NewLocalWrapper(),
+		}
+	} else {
+		log.Panic("Invalid persistence storage type: %s", config.PersistenceStorageType)
 	}
 
-	return &Persistence{
-		storage: NewLocalWrapper(),
-	}
+	return nil
 }