Skip to content

Commit edd8e87

Browse files
committed
refactor: unify rds kvbackend impl
1 parent fa09e18 commit edd8e87

File tree

6 files changed

+557
-482
lines changed

6 files changed

+557
-482
lines changed

src/cli/src/bench.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ use common_meta::key::{TableMetadataManager, TableMetadataManagerRef};
2424
use common_meta::kv_backend::etcd::EtcdStore;
2525
use common_meta::kv_backend::memory::MemoryKvBackend;
2626
#[cfg(feature = "pg_kvbackend")]
27-
use common_meta::kv_backend::postgres::PgStore;
27+
use common_meta::kv_backend::rds::PgStore;
2828
use common_meta::peer::Peer;
2929
use common_meta::rpc::router::{Region, RegionRoute};
3030
use common_telemetry::info;

src/common/meta/src/error.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -686,8 +686,8 @@ pub enum Error {
686686
},
687687

688688
#[cfg(feature = "pg_kvbackend")]
689-
#[snafu(display("Postgres transaction retry failed"))]
690-
PostgresTransactionRetryFailed {
689+
#[snafu(display("Rds transaction retry failed"))]
690+
RdsTransactionRetryFailed {
691691
#[snafu(implicit)]
692692
location: Location,
693693
},
@@ -814,7 +814,7 @@ impl ErrorExt for Error {
814814
| CreatePostgresPool { .. }
815815
| GetPostgresConnection { .. }
816816
| PostgresTransaction { .. }
817-
| PostgresTransactionRetryFailed { .. } => StatusCode::Internal,
817+
| RdsTransactionRetryFailed { .. } => StatusCode::Internal,
818818
Error::DatanodeTableInfoNotFound { .. } => StatusCode::Internal,
819819
}
820820
}

src/common/meta/src/kv_backend.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ pub mod chroot;
3232
pub mod etcd;
3333
pub mod memory;
3434
#[cfg(feature = "pg_kvbackend")]
35-
pub mod postgres;
35+
pub mod rds;
3636
pub mod test;
3737
pub mod txn;
3838

0 commit comments

Comments
 (0)