From 67e8053b17f867aa4a0c069446c658988a9202f4 Mon Sep 17 00:00:00 2001 From: Riccardo Montagnin Date: Mon, 12 Jun 2023 14:25:17 -0500 Subject: [PATCH] feat: expose Database#CreatePartitionIfNotExists method --- database/postgresql/postgresql.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/database/postgresql/postgresql.go b/database/postgresql/postgresql.go index 6c33db18..9c10e586 100644 --- a/database/postgresql/postgresql.go +++ b/database/postgresql/postgresql.go @@ -63,8 +63,8 @@ type Database struct { Logger logging.Logger } -// createPartitionIfNotExists creates a new partition having the given partition id if not existing -func (db *Database) createPartitionIfNotExists(table string, partitionID int64) error { +// CreatePartitionIfNotExists creates a new partition having the given partition id if not existing +func (db *Database) CreatePartitionIfNotExists(table string, partitionID int64) error { partitionTable := fmt.Sprintf("%s_%d", table, partitionID) stmt := fmt.Sprintf( @@ -155,7 +155,7 @@ func (db *Database) SaveTx(tx *types.Tx) error { partitionSize := config.Cfg.Database.PartitionSize if partitionSize > 0 { partitionID = tx.Height / partitionSize - err := db.createPartitionIfNotExists("transaction", partitionID) + err := db.CreatePartitionIfNotExists("transaction", partitionID) if err != nil { return err } @@ -286,7 +286,7 @@ func (db *Database) SaveMessage(msg *types.Message) error { partitionSize := config.Cfg.Database.PartitionSize if partitionSize > 0 { partitionID = msg.Height / partitionSize - err := db.createPartitionIfNotExists("message", partitionID) + err := db.CreatePartitionIfNotExists("message", partitionID) if err != nil { return err }