rename funcs

Author: arzonus

common/persistence/sql/sqlplugin/sqlite/db.go

@@ -93,5 +93,5 @@ func (mdb *DB) Close() error {
 		return mdb.DB.Close()
 	}
 
-	return closePolledDBConn(mdb.databaseName, mdb.DB.Close)
+	return closeSharedDBConn(mdb.databaseName, mdb.DB.Close)
 }

common/persistence/sql/sqlplugin/sqlite/db_pool.go

@@ -20,8 +20,8 @@ var (
 	dbPoolMx      sync.Mutex
 )
 
-// createPolledDBConn creates a new database connection in the dbPool if it doesn't exist.
-func createPolledDBConn(databaseName string, createDBConnFn func() (*sqlx.DB, error)) (*sqlx.DB, error) {
+// createSharedDBConn creates a new database connection in the dbPool if it doesn't exist.
+func createSharedDBConn(databaseName string, createDBConnFn func() (*sqlx.DB, error)) (*sqlx.DB, error) {
 	dbPoolMx.Lock()
 	defer dbPoolMx.Unlock()
 
@@ -41,8 +41,8 @@ func createPolledDBConn(databaseName string, createDBConnFn func() (*sqlx.DB, er
 	return db, nil
 }
 
-// createPolledDBConn closes the database connection in the dbPool if it exists.
-func closePolledDBConn(databaseName string, closeFn func() error) error {
+// closeSharedDBConn closes the database connection in the dbPool if it exists.
+func closeSharedDBConn(databaseName string, closeDBConnFn func() error) error {
 	dbPoolMx.Lock()
 	defer dbPoolMx.Unlock()
 
@@ -53,5 +53,5 @@ func closePolledDBConn(databaseName string, closeFn func() error) error {
 
 	delete(dbPool, databaseName)
 	delete(dbPoolCounter, databaseName)
-	return closeFn()
+	return closeDBConnFn()
 }

common/persistence/sql/sqlplugin/sqlite/plugin.go

@@ -81,7 +81,7 @@ func (p *plugin) createSingleDBConn(cfg *config.SQL) (*sqlx.DB, error) {
 		return p.createDBConn(cfg)
 	}
 
-	return createPolledDBConn(cfg.DatabaseName, func() (*sqlx.DB, error) {
+	return createSharedDBConn(cfg.DatabaseName, func() (*sqlx.DB, error) {
 		return p.createDBConn(cfg)
 	})
 }