database driver init logs added

Author: sh0umik

database/cache/factory.go

@@ -1,6 +1,8 @@
 package cache
 
 import (
+	"log"
+
 	"github.com/apito-io/engine/database/cache/badger"
 	"github.com/apito-io/engine/database/cache/bbolt"
 	"github.com/apito-io/engine/database/cache/memory"
@@ -11,6 +13,7 @@ import (
 
 // CreateCacheDriver creates a cache driver instance based on the engine type
 func CreateCacheDriver(engineType string, cfg *models.Config) (interfaces.CacheDBInterface, error) {
+	log.Printf("Creating cache driver: %s", engineType)
 	switch engineType {
 	case "redis":
 		return redis.GetRedisCacheDriver(cfg)

database/kv/factory.go

@@ -2,6 +2,7 @@ package kv
 
 import (
 	"fmt"
+	"log"
 
 	"github.com/apito-io/engine/database/kv/bbolt"
 	"github.com/apito-io/engine/database/kv/memory"
@@ -12,6 +13,7 @@ import (
 
 // CreateKVDriver creates a queue engine instance based on the engine type
 func CreateKVDriver(engineType string, cfg *models.Config) (interfaces.KeyValueServiceInterface, error) {
+	log.Printf("Creating KV driver: %s", engineType)
 	switch engineType {
 	case "redis":
 		return redis.GetKVRedisDriver(cfg)

database/project/driver.go

@@ -2,6 +2,7 @@ package project
 
 import (
 	"errors"
+	"log"
 
 	_const "github.com/apito-io/engine/const"
 	//"github.com/apito-io/engine/database/project/driver/mongo"
@@ -24,6 +25,8 @@ func GetProjectDriverWithConfig(conf *models.Config, engineConfig *models.Driver
 		}
 	}
 
+	log.Printf("Getting project driver: %s", engineConfig.Engine)
+
 	// Fall back to default core drivers
 	var db interfaces.ProjectDBInterface
 	var err error

database/queue/factory.go

@@ -2,6 +2,7 @@ package queue
 
 import (
 	"fmt"
+	"log"
 
 	"github.com/apito-io/engine/database/queue/bbolt"
 	"github.com/apito-io/engine/database/queue/memory"
@@ -12,6 +13,7 @@ import (
 
 // CreateQueueEngine creates a queue engine instance based on the engine type
 func CreateQueueEngine(engineType string, cfg *models.Config) (interfaces.QueueEngineInterface, error) {
+	log.Printf("Creating queue engine: %s", engineType)
 	switch engineType {
 	case "redis":
 		return redis.GetRedisQueueDriver(cfg)

database/shared/driver.go

@@ -2,6 +2,7 @@ package shared
 
 import (
 	"errors"
+	"log"
 
 	_const "github.com/apito-io/engine/const"
 	sharedRedis "github.com/apito-io/engine/database/shared/redis"
@@ -15,6 +16,7 @@ func GetSharedDriver(engineConfig *models.DriverCredentials) (interfaces.SharedD
 	if engineConfig == nil { // default db
 		return sharedRedis.GetSharedRedisDriver(engineConfig)
 	}
+	log.Printf("Getting shared driver: %s", engineConfig.Engine)
 	switch engineConfig.Engine {
 	case _const.RedisDriver:
 		db, err = sharedRedis.GetSharedRedisDriver(engineConfig)

database/system/driver.go

@@ -2,6 +2,8 @@ package system
 
 import (
 	"errors"
+	"log"
+
 	_const "github.com/apito-io/engine/const"
 	"github.com/apito-io/engine/database/system/driver/bbolt"
 	"github.com/apito-io/engine/interfaces"
@@ -26,6 +28,8 @@ func GetSystemDriver(engineConfig *models.DriverCredentials, conf *models.Config
 	var db interfaces.ApitoSystemDB
 	var err error
 
+	log.Printf("Getting system driver: %s", engineConfig.Engine)
+
 	switch engineConfig.Engine {
 	case _const.CoreDB:
 		db, err = bbolt.GetSystemBBoltDriver(engineConfig, nil)