Skip to content

Commit bdc1bb4

Browse files
committed
🚧 Snapshot/Restore 提前校验 s3 是否启用
1 parent 07823d7 commit bdc1bb4

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

db/ha_sqlite_db_manager.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -254,6 +254,9 @@ func (d *HaSqliteDBManager) FinishTx(c context.Context, req *proto.FinishTxReque
254254

255255
// Snapshot 快照
256256
func (d *HaSqliteDBManager) Snapshot(c context.Context, req *proto.SnapshotRequest) (*proto.SnapshotResponse, error) {
257+
if d.s3Store == nil {
258+
return nil, fmt.Errorf("s3 is disabled")
259+
}
257260
_, ok, err := d.GetDB(req.Request)
258261
if !ok || err != nil {
259262
return nil, fmt.Errorf("get db error : %d,err:%v", req.Request.DbId, err)
@@ -264,6 +267,9 @@ func (d *HaSqliteDBManager) Snapshot(c context.Context, req *proto.SnapshotReque
264267

265268
// Restore 恢复
266269
func (d *HaSqliteDBManager) Restore(c context.Context, req *proto.RestoreRequest) (*proto.RestoreResponse, error) {
270+
if d.s3Store == nil {
271+
return nil, fmt.Errorf("s3 is disabled")
272+
}
267273
_, ok, err := d.GetDB(req.Request)
268274
if !ok || err != nil {
269275
return nil, fmt.Errorf("get db error : %d,err:%v", req.Request.DbId, err)

0 commit comments

Comments
 (0)