Function SchemaReaderFactory

internal/factories/storage.go:43–55

SchemaReaderFactory creates and returns a SchemaReader based on the database engine type.

(db database.Database)

// SchemaReaderFactory creates and returns a SchemaReader based on the database engine type.
func SchemaReaderFactory(db database.Database) (repo storage.SchemaReader) {
	switch db.GetEngineType() {
	case "postgres":
		// If the database engine is Postgres, create a new SchemaReader using the Postgres implementation
		return PQRepository.NewSchemaReader(db.(*PQDatabase.Postgres))
	case "memory":
		// If the database engine is in-memory, create a new SchemaReader using the in-memory implementation
		return MMRepository.NewSchemaReader(db.(*MMDatabase.Memory))
	default:
		// For any other type, use the in-memory implementation as a default
		return MMRepository.NewSchemaReader(db.(*MMDatabase.Memory))
	}
}

// WatcherFactory creates and returns a Watcher based on the database engine type.
func WatcherFactory(db database.Database) (repo storage.Watcher) {