spdb_mock.go

// Code generated by MockGen. DO NOT EDIT.
// Source: ./spdb.go
//
// Generated by this command:
//
//	mockgen -source=./spdb.go -destination=./spdb_mock.go -package=spdb
//

// Package spdb is a generated GoMock package.
package spdb

import (
	reflect "reflect"
	time "time"

	task "github.com/bnb-chain/greenfield-storage-provider/core/task"
	types "github.com/bnb-chain/greenfield-storage-provider/store/types"
	types0 "github.com/bnb-chain/greenfield/x/sp/types"
	gomock "go.uber.org/mock/gomock"
)

// MockSPDB is a mock of SPDB interface.
type MockSPDB struct {
	ctrl     *gomock.Controller
	recorder *MockSPDBMockRecorder
}

// MockSPDBMockRecorder is the mock recorder for MockSPDB.
type MockSPDBMockRecorder struct {
	mock *MockSPDB
}

// NewMockSPDB creates a new mock instance.
func NewMockSPDB(ctrl *gomock.Controller) *MockSPDB {
	mock := &MockSPDB{ctrl: ctrl}
	mock.recorder = &MockSPDBMockRecorder{mock}
	return mock
}

// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockSPDB) EXPECT() *MockSPDBMockRecorder {
	return m.recorder
}

// BatchGetRecoverGVGStats mocks base method.
func (m *MockSPDB) BatchGetRecoverGVGStats(gvgID []uint32) ([]*RecoverGVGStats, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "BatchGetRecoverGVGStats", gvgID)
	ret0, _ := ret[0].([]*RecoverGVGStats)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// BatchGetRecoverGVGStats indicates an expected call of BatchGetRecoverGVGStats.
func (mr *MockSPDBMockRecorder) BatchGetRecoverGVGStats(gvgID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "BatchGetRecoverGVGStats", reflect.TypeOf((*MockSPDB)(nil).BatchGetRecoverGVGStats), gvgID)
}

// CheckQuotaAndAddReadRecord mocks base method.
func (m *MockSPDB) CheckQuotaAndAddReadRecord(record *ReadRecord, quota *BucketQuota) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CheckQuotaAndAddReadRecord", record, quota)
	ret0, _ := ret[0].(error)
	return ret0
}

// CheckQuotaAndAddReadRecord indicates an expected call of CheckQuotaAndAddReadRecord.
func (mr *MockSPDBMockRecorder) CheckQuotaAndAddReadRecord(record, quota any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CheckQuotaAndAddReadRecord", reflect.TypeOf((*MockSPDB)(nil).CheckQuotaAndAddReadRecord), record, quota)
}

// ClearExpiredOffChainAuthKeys mocks base method.
func (m *MockSPDB) ClearExpiredOffChainAuthKeys() error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ClearExpiredOffChainAuthKeys")
	ret0, _ := ret[0].(error)
	return ret0
}

// ClearExpiredOffChainAuthKeys indicates an expected call of ClearExpiredOffChainAuthKeys.
func (mr *MockSPDBMockRecorder) ClearExpiredOffChainAuthKeys() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ClearExpiredOffChainAuthKeys", reflect.TypeOf((*MockSPDB)(nil).ClearExpiredOffChainAuthKeys))
}

// CountRecoverFailedObject mocks base method.
func (m *MockSPDB) CountRecoverFailedObject() (int64, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CountRecoverFailedObject")
	ret0, _ := ret[0].(int64)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// CountRecoverFailedObject indicates an expected call of CountRecoverFailedObject.
func (mr *MockSPDBMockRecorder) CountRecoverFailedObject() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CountRecoverFailedObject", reflect.TypeOf((*MockSPDB)(nil).CountRecoverFailedObject))
}

// DeleteAllReplicatePieceChecksum mocks base method.
func (m *MockSPDB) DeleteAllReplicatePieceChecksum(objectID uint64, redundancyIdx int32, pieceCount uint32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteAllReplicatePieceChecksum", objectID, redundancyIdx, pieceCount)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteAllReplicatePieceChecksum indicates an expected call of DeleteAllReplicatePieceChecksum.
func (mr *MockSPDBMockRecorder) DeleteAllReplicatePieceChecksum(objectID, redundancyIdx, pieceCount any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteAllReplicatePieceChecksum", reflect.TypeOf((*MockSPDB)(nil).DeleteAllReplicatePieceChecksum), objectID, redundancyIdx, pieceCount)
}

// DeleteAllReplicatePieceChecksumOptimized mocks base method.
func (m *MockSPDB) DeleteAllReplicatePieceChecksumOptimized(objectID uint64, redundancyIdx int32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteAllReplicatePieceChecksumOptimized", objectID, redundancyIdx)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteAllReplicatePieceChecksumOptimized indicates an expected call of DeleteAllReplicatePieceChecksumOptimized.
func (mr *MockSPDBMockRecorder) DeleteAllReplicatePieceChecksumOptimized(objectID, redundancyIdx any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteAllReplicatePieceChecksumOptimized", reflect.TypeOf((*MockSPDB)(nil).DeleteAllReplicatePieceChecksumOptimized), objectID, redundancyIdx)
}

// DeleteAuthKeysV2 mocks base method.
func (m *MockSPDB) DeleteAuthKeysV2(userAddress, domain string, publicKey []string) (bool, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteAuthKeysV2", userAddress, domain, publicKey)
	ret0, _ := ret[0].(bool)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// DeleteAuthKeysV2 indicates an expected call of DeleteAuthKeysV2.
func (mr *MockSPDBMockRecorder) DeleteAuthKeysV2(userAddress, domain, publicKey any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteAuthKeysV2", reflect.TypeOf((*MockSPDB)(nil).DeleteAuthKeysV2), userAddress, domain, publicKey)
}

// DeleteExpiredBucketTraffic mocks base method.
func (m *MockSPDB) DeleteExpiredBucketTraffic(yearMonth string) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteExpiredBucketTraffic", yearMonth)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteExpiredBucketTraffic indicates an expected call of DeleteExpiredBucketTraffic.
func (mr *MockSPDBMockRecorder) DeleteExpiredBucketTraffic(yearMonth any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteExpiredBucketTraffic", reflect.TypeOf((*MockSPDB)(nil).DeleteExpiredBucketTraffic), yearMonth)
}

// DeleteExpiredReadRecord mocks base method.
func (m *MockSPDB) DeleteExpiredReadRecord(ts, limit uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteExpiredReadRecord", ts, limit)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteExpiredReadRecord indicates an expected call of DeleteExpiredReadRecord.
func (mr *MockSPDBMockRecorder) DeleteExpiredReadRecord(ts, limit any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteExpiredReadRecord", reflect.TypeOf((*MockSPDB)(nil).DeleteExpiredReadRecord), ts, limit)
}

// DeleteGCObjectProgress mocks base method.
func (m *MockSPDB) DeleteGCObjectProgress(taskKey string) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteGCObjectProgress", taskKey)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteGCObjectProgress indicates an expected call of DeleteGCObjectProgress.
func (mr *MockSPDBMockRecorder) DeleteGCObjectProgress(taskKey any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteGCObjectProgress", reflect.TypeOf((*MockSPDB)(nil).DeleteGCObjectProgress), taskKey)
}

// DeleteMigrateBucket mocks base method.
func (m *MockSPDB) DeleteMigrateBucket(bucketID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteMigrateBucket", bucketID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteMigrateBucket indicates an expected call of DeleteMigrateBucket.
func (mr *MockSPDBMockRecorder) DeleteMigrateBucket(bucketID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteMigrateBucket", reflect.TypeOf((*MockSPDB)(nil).DeleteMigrateBucket), bucketID)
}

// DeleteMigrateGVGUnit mocks base method.
func (m *MockSPDB) DeleteMigrateGVGUnit(meta *MigrateGVGUnitMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteMigrateGVGUnit", meta)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteMigrateGVGUnit indicates an expected call of DeleteMigrateGVGUnit.
func (mr *MockSPDBMockRecorder) DeleteMigrateGVGUnit(meta any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteMigrateGVGUnit", reflect.TypeOf((*MockSPDB)(nil).DeleteMigrateGVGUnit), meta)
}

// DeleteMigrateGVGUnitsByBucketID mocks base method.
func (m *MockSPDB) DeleteMigrateGVGUnitsByBucketID(bucketID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteMigrateGVGUnitsByBucketID", bucketID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteMigrateGVGUnitsByBucketID indicates an expected call of DeleteMigrateGVGUnitsByBucketID.
func (mr *MockSPDBMockRecorder) DeleteMigrateGVGUnitsByBucketID(bucketID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteMigrateGVGUnitsByBucketID", reflect.TypeOf((*MockSPDB)(nil).DeleteMigrateGVGUnitsByBucketID), bucketID)
}

// DeleteObjectIntegrity mocks base method.
func (m *MockSPDB) DeleteObjectIntegrity(objectID uint64, redundancyIndex int32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteObjectIntegrity", objectID, redundancyIndex)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteObjectIntegrity indicates an expected call of DeleteObjectIntegrity.
func (mr *MockSPDBMockRecorder) DeleteObjectIntegrity(objectID, redundancyIndex any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteObjectIntegrity", reflect.TypeOf((*MockSPDB)(nil).DeleteObjectIntegrity), objectID, redundancyIndex)
}

// DeleteRecoverFailedObject mocks base method.
func (m *MockSPDB) DeleteRecoverFailedObject(objectID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteRecoverFailedObject", objectID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteRecoverFailedObject indicates an expected call of DeleteRecoverFailedObject.
func (mr *MockSPDBMockRecorder) DeleteRecoverFailedObject(objectID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteRecoverFailedObject", reflect.TypeOf((*MockSPDB)(nil).DeleteRecoverFailedObject), objectID)
}

// DeleteRecoverGVGStats mocks base method.
func (m *MockSPDB) DeleteRecoverGVGStats(gvgID uint32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteRecoverGVGStats", gvgID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteRecoverGVGStats indicates an expected call of DeleteRecoverGVGStats.
func (mr *MockSPDBMockRecorder) DeleteRecoverGVGStats(gvgID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteRecoverGVGStats", reflect.TypeOf((*MockSPDB)(nil).DeleteRecoverGVGStats), gvgID)
}

// DeleteReplicatePieceChecksum mocks base method.
func (m *MockSPDB) DeleteReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteReplicatePieceChecksum", objectID, segmentIdx, redundancyIdx)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteReplicatePieceChecksum indicates an expected call of DeleteReplicatePieceChecksum.
func (mr *MockSPDBMockRecorder) DeleteReplicatePieceChecksum(objectID, segmentIdx, redundancyIdx any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteReplicatePieceChecksum", reflect.TypeOf((*MockSPDB)(nil).DeleteReplicatePieceChecksum), objectID, segmentIdx, redundancyIdx)
}

// DeleteReplicatePieceChecksumsByObjectID mocks base method.
func (m *MockSPDB) DeleteReplicatePieceChecksumsByObjectID(objectID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteReplicatePieceChecksumsByObjectID", objectID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteReplicatePieceChecksumsByObjectID indicates an expected call of DeleteReplicatePieceChecksumsByObjectID.
func (mr *MockSPDBMockRecorder) DeleteReplicatePieceChecksumsByObjectID(objectID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteReplicatePieceChecksumsByObjectID", reflect.TypeOf((*MockSPDB)(nil).DeleteReplicatePieceChecksumsByObjectID), objectID)
}

// DeleteShadowObjectIntegrity mocks base method.
func (m *MockSPDB) DeleteShadowObjectIntegrity(objectID uint64, redundancyIndex int32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteShadowObjectIntegrity", objectID, redundancyIndex)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteShadowObjectIntegrity indicates an expected call of DeleteShadowObjectIntegrity.
func (mr *MockSPDBMockRecorder) DeleteShadowObjectIntegrity(objectID, redundancyIndex any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteShadowObjectIntegrity", reflect.TypeOf((*MockSPDB)(nil).DeleteShadowObjectIntegrity), objectID, redundancyIndex)
}

// DeleteUploadProgress mocks base method.
func (m *MockSPDB) DeleteUploadProgress(objectID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteUploadProgress", objectID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteUploadProgress indicates an expected call of DeleteUploadProgress.
func (mr *MockSPDBMockRecorder) DeleteUploadProgress(objectID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteUploadProgress", reflect.TypeOf((*MockSPDB)(nil).DeleteUploadProgress), objectID)
}

// FetchAllSp mocks base method.
func (m *MockSPDB) FetchAllSp(status ...types0.Status) ([]*types0.StorageProvider, error) {
	m.ctrl.T.Helper()
	varargs := []any{}
	for _, a := range status {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "FetchAllSp", varargs...)
	ret0, _ := ret[0].([]*types0.StorageProvider)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// FetchAllSp indicates an expected call of FetchAllSp.
func (mr *MockSPDBMockRecorder) FetchAllSp(status ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "FetchAllSp", reflect.TypeOf((*MockSPDB)(nil).FetchAllSp), status...)
}

// FetchAllSpWithoutOwnSp mocks base method.
func (m *MockSPDB) FetchAllSpWithoutOwnSp(status ...types0.Status) ([]*types0.StorageProvider, error) {
	m.ctrl.T.Helper()
	varargs := []any{}
	for _, a := range status {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "FetchAllSpWithoutOwnSp", varargs...)
	ret0, _ := ret[0].([]*types0.StorageProvider)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// FetchAllSpWithoutOwnSp indicates an expected call of FetchAllSpWithoutOwnSp.
func (mr *MockSPDBMockRecorder) FetchAllSpWithoutOwnSp(status ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "FetchAllSpWithoutOwnSp", reflect.TypeOf((*MockSPDB)(nil).FetchAllSpWithoutOwnSp), status...)
}

// GetAllReplicatePieceChecksum mocks base method.
func (m *MockSPDB) GetAllReplicatePieceChecksum(objectID uint64, redundancyIdx int32, pieceCount uint32) ([][]byte, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetAllReplicatePieceChecksum", objectID, redundancyIdx, pieceCount)
	ret0, _ := ret[0].([][]byte)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetAllReplicatePieceChecksum indicates an expected call of GetAllReplicatePieceChecksum.
func (mr *MockSPDBMockRecorder) GetAllReplicatePieceChecksum(objectID, redundancyIdx, pieceCount any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetAllReplicatePieceChecksum", reflect.TypeOf((*MockSPDB)(nil).GetAllReplicatePieceChecksum), objectID, redundancyIdx, pieceCount)
}

// GetAllReplicatePieceChecksumOptimized mocks base method.
func (m *MockSPDB) GetAllReplicatePieceChecksumOptimized(objectID uint64, redundancyIdx int32, pieceCount uint32) ([][]byte, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetAllReplicatePieceChecksumOptimized", objectID, redundancyIdx, pieceCount)
	ret0, _ := ret[0].([][]byte)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetAllReplicatePieceChecksumOptimized indicates an expected call of GetAllReplicatePieceChecksumOptimized.
func (mr *MockSPDBMockRecorder) GetAllReplicatePieceChecksumOptimized(objectID, redundancyIdx, pieceCount any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetAllReplicatePieceChecksumOptimized", reflect.TypeOf((*MockSPDB)(nil).GetAllReplicatePieceChecksumOptimized), objectID, redundancyIdx, pieceCount)
}

// GetAuthKey mocks base method.
func (m *MockSPDB) GetAuthKey(userAddress, domain string) (*OffChainAuthKey, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetAuthKey", userAddress, domain)
	ret0, _ := ret[0].(*OffChainAuthKey)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetAuthKey indicates an expected call of GetAuthKey.
func (mr *MockSPDBMockRecorder) GetAuthKey(userAddress, domain any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetAuthKey", reflect.TypeOf((*MockSPDB)(nil).GetAuthKey), userAddress, domain)
}

// GetAuthKeyV2 mocks base method.
func (m *MockSPDB) GetAuthKeyV2(userAddress, domain, publicKey string) (*OffChainAuthKeyV2, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetAuthKeyV2", userAddress, domain, publicKey)
	ret0, _ := ret[0].(*OffChainAuthKeyV2)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetAuthKeyV2 indicates an expected call of GetAuthKeyV2.
func (mr *MockSPDBMockRecorder) GetAuthKeyV2(userAddress, domain, publicKey any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetAuthKeyV2", reflect.TypeOf((*MockSPDB)(nil).GetAuthKeyV2), userAddress, domain, publicKey)
}

// GetBucketReadRecord mocks base method.
func (m *MockSPDB) GetBucketReadRecord(bucketID uint64, timeRange *TrafficTimeRange) ([]*ReadRecord, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetBucketReadRecord", bucketID, timeRange)
	ret0, _ := ret[0].([]*ReadRecord)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetBucketReadRecord indicates an expected call of GetBucketReadRecord.
func (mr *MockSPDBMockRecorder) GetBucketReadRecord(bucketID, timeRange any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetBucketReadRecord", reflect.TypeOf((*MockSPDB)(nil).GetBucketReadRecord), bucketID, timeRange)
}

// GetBucketTraffic mocks base method.
func (m *MockSPDB) GetBucketTraffic(bucketID uint64, yearMonth string) (*BucketTraffic, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetBucketTraffic", bucketID, yearMonth)
	ret0, _ := ret[0].(*BucketTraffic)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetBucketTraffic indicates an expected call of GetBucketTraffic.
func (mr *MockSPDBMockRecorder) GetBucketTraffic(bucketID, yearMonth any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetBucketTraffic", reflect.TypeOf((*MockSPDB)(nil).GetBucketTraffic), bucketID, yearMonth)
}

// GetBucketTrafficCount mocks base method.
func (m *MockSPDB) GetBucketTrafficCount(yearMonth string) (int64, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetBucketTrafficCount", yearMonth)
	ret0, _ := ret[0].(int64)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetBucketTrafficCount indicates an expected call of GetBucketTrafficCount.
func (mr *MockSPDBMockRecorder) GetBucketTrafficCount(yearMonth any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetBucketTrafficCount", reflect.TypeOf((*MockSPDB)(nil).GetBucketTrafficCount), yearMonth)
}

// GetGCMetasToGC mocks base method.
func (m *MockSPDB) GetGCMetasToGC(limit int) ([]*GCObjectMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetGCMetasToGC", limit)
	ret0, _ := ret[0].([]*GCObjectMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetGCMetasToGC indicates an expected call of GetGCMetasToGC.
func (mr *MockSPDBMockRecorder) GetGCMetasToGC(limit any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetGCMetasToGC", reflect.TypeOf((*MockSPDB)(nil).GetGCMetasToGC), limit)
}

// GetLatestBucketTraffic mocks base method.
func (m *MockSPDB) GetLatestBucketTraffic(bucketID uint64) (*BucketTraffic, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetLatestBucketTraffic", bucketID)
	ret0, _ := ret[0].(*BucketTraffic)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetLatestBucketTraffic indicates an expected call of GetLatestBucketTraffic.
func (mr *MockSPDBMockRecorder) GetLatestBucketTraffic(bucketID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetLatestBucketTraffic", reflect.TypeOf((*MockSPDB)(nil).GetLatestBucketTraffic), bucketID)
}

// GetObjectIntegrity mocks base method.
func (m *MockSPDB) GetObjectIntegrity(objectID uint64, redundancyIndex int32) (*IntegrityMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetObjectIntegrity", objectID, redundancyIndex)
	ret0, _ := ret[0].(*IntegrityMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetObjectIntegrity indicates an expected call of GetObjectIntegrity.
func (mr *MockSPDBMockRecorder) GetObjectIntegrity(objectID, redundancyIndex any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetObjectIntegrity", reflect.TypeOf((*MockSPDB)(nil).GetObjectIntegrity), objectID, redundancyIndex)
}

// GetObjectReadRecord mocks base method.
func (m *MockSPDB) GetObjectReadRecord(objectID uint64, timeRange *TrafficTimeRange) ([]*ReadRecord, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetObjectReadRecord", objectID, timeRange)
	ret0, _ := ret[0].([]*ReadRecord)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetObjectReadRecord indicates an expected call of GetObjectReadRecord.
func (mr *MockSPDBMockRecorder) GetObjectReadRecord(objectID, timeRange any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetObjectReadRecord", reflect.TypeOf((*MockSPDB)(nil).GetObjectReadRecord), objectID, timeRange)
}

// GetOwnSpInfo mocks base method.
func (m *MockSPDB) GetOwnSpInfo() (*types0.StorageProvider, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetOwnSpInfo")
	ret0, _ := ret[0].(*types0.StorageProvider)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetOwnSpInfo indicates an expected call of GetOwnSpInfo.
func (mr *MockSPDBMockRecorder) GetOwnSpInfo() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetOwnSpInfo", reflect.TypeOf((*MockSPDB)(nil).GetOwnSpInfo))
}

// GetReadRecord mocks base method.
func (m *MockSPDB) GetReadRecord(timeRange *TrafficTimeRange) ([]*ReadRecord, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetReadRecord", timeRange)
	ret0, _ := ret[0].([]*ReadRecord)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetReadRecord indicates an expected call of GetReadRecord.
func (mr *MockSPDBMockRecorder) GetReadRecord(timeRange any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetReadRecord", reflect.TypeOf((*MockSPDB)(nil).GetReadRecord), timeRange)
}

// GetRecoverFailedObject mocks base method.
func (m *MockSPDB) GetRecoverFailedObject(objectID uint64) (*RecoverFailedObject, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetRecoverFailedObject", objectID)
	ret0, _ := ret[0].(*RecoverFailedObject)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetRecoverFailedObject indicates an expected call of GetRecoverFailedObject.
func (mr *MockSPDBMockRecorder) GetRecoverFailedObject(objectID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetRecoverFailedObject", reflect.TypeOf((*MockSPDB)(nil).GetRecoverFailedObject), objectID)
}

// GetRecoverFailedObjects mocks base method.
func (m *MockSPDB) GetRecoverFailedObjects(retry, limit uint32) ([]*RecoverFailedObject, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetRecoverFailedObjects", retry, limit)
	ret0, _ := ret[0].([]*RecoverFailedObject)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetRecoverFailedObjects indicates an expected call of GetRecoverFailedObjects.
func (mr *MockSPDBMockRecorder) GetRecoverFailedObjects(retry, limit any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetRecoverFailedObjects", reflect.TypeOf((*MockSPDB)(nil).GetRecoverFailedObjects), retry, limit)
}

// GetRecoverFailedObjectsByRetryTime mocks base method.
func (m *MockSPDB) GetRecoverFailedObjectsByRetryTime(retry uint32) ([]*RecoverFailedObject, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetRecoverFailedObjectsByRetryTime", retry)
	ret0, _ := ret[0].([]*RecoverFailedObject)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetRecoverFailedObjectsByRetryTime indicates an expected call of GetRecoverFailedObjectsByRetryTime.
func (mr *MockSPDBMockRecorder) GetRecoverFailedObjectsByRetryTime(retry any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetRecoverFailedObjectsByRetryTime", reflect.TypeOf((*MockSPDB)(nil).GetRecoverFailedObjectsByRetryTime), retry)
}

// GetRecoverGVGStats mocks base method.
func (m *MockSPDB) GetRecoverGVGStats(gvgID uint32) (*RecoverGVGStats, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetRecoverGVGStats", gvgID)
	ret0, _ := ret[0].(*RecoverGVGStats)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetRecoverGVGStats indicates an expected call of GetRecoverGVGStats.
func (mr *MockSPDBMockRecorder) GetRecoverGVGStats(gvgID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetRecoverGVGStats", reflect.TypeOf((*MockSPDB)(nil).GetRecoverGVGStats), gvgID)
}

// GetReplicatePieceChecksum mocks base method.
func (m *MockSPDB) GetReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32) ([]byte, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetReplicatePieceChecksum", objectID, segmentIdx, redundancyIdx)
	ret0, _ := ret[0].([]byte)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetReplicatePieceChecksum indicates an expected call of GetReplicatePieceChecksum.
func (mr *MockSPDBMockRecorder) GetReplicatePieceChecksum(objectID, segmentIdx, redundancyIdx any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetReplicatePieceChecksum", reflect.TypeOf((*MockSPDB)(nil).GetReplicatePieceChecksum), objectID, segmentIdx, redundancyIdx)
}

// GetShadowObjectIntegrity mocks base method.
func (m *MockSPDB) GetShadowObjectIntegrity(objectID uint64, redundancyIndex int32) (*ShadowIntegrityMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetShadowObjectIntegrity", objectID, redundancyIndex)
	ret0, _ := ret[0].(*ShadowIntegrityMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetShadowObjectIntegrity indicates an expected call of GetShadowObjectIntegrity.
func (mr *MockSPDBMockRecorder) GetShadowObjectIntegrity(objectID, redundancyIndex any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetShadowObjectIntegrity", reflect.TypeOf((*MockSPDB)(nil).GetShadowObjectIntegrity), objectID, redundancyIndex)
}

// GetSpByAddress mocks base method.
func (m *MockSPDB) GetSpByAddress(address string, addressType SpAddressType) (*types0.StorageProvider, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetSpByAddress", address, addressType)
	ret0, _ := ret[0].(*types0.StorageProvider)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetSpByAddress indicates an expected call of GetSpByAddress.
func (mr *MockSPDBMockRecorder) GetSpByAddress(address, addressType any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetSpByAddress", reflect.TypeOf((*MockSPDB)(nil).GetSpByAddress), address, addressType)
}

// GetSpByEndpoint mocks base method.
func (m *MockSPDB) GetSpByEndpoint(endpoint string) (*types0.StorageProvider, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetSpByEndpoint", endpoint)
	ret0, _ := ret[0].(*types0.StorageProvider)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetSpByEndpoint indicates an expected call of GetSpByEndpoint.
func (mr *MockSPDBMockRecorder) GetSpByEndpoint(endpoint any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetSpByEndpoint", reflect.TypeOf((*MockSPDB)(nil).GetSpByEndpoint), endpoint)
}

// GetSpByID mocks base method.
func (m *MockSPDB) GetSpByID(id uint32) (*types0.StorageProvider, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetSpByID", id)
	ret0, _ := ret[0].(*types0.StorageProvider)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetSpByID indicates an expected call of GetSpByID.
func (mr *MockSPDBMockRecorder) GetSpByID(id any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetSpByID", reflect.TypeOf((*MockSPDB)(nil).GetSpByID), id)
}

// GetUploadMetasToRejectUnsealByRangeTS mocks base method.
func (m *MockSPDB) GetUploadMetasToRejectUnsealByRangeTS(limit int, startTimeStamp, endTimeStamp int64) ([]*UploadObjectMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetUploadMetasToRejectUnsealByRangeTS", limit, startTimeStamp, endTimeStamp)
	ret0, _ := ret[0].([]*UploadObjectMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetUploadMetasToRejectUnsealByRangeTS indicates an expected call of GetUploadMetasToRejectUnsealByRangeTS.
func (mr *MockSPDBMockRecorder) GetUploadMetasToRejectUnsealByRangeTS(limit, startTimeStamp, endTimeStamp any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUploadMetasToRejectUnsealByRangeTS", reflect.TypeOf((*MockSPDB)(nil).GetUploadMetasToRejectUnsealByRangeTS), limit, startTimeStamp, endTimeStamp)
}

// GetUploadMetasToReplicate mocks base method.
func (m *MockSPDB) GetUploadMetasToReplicate(limit int, timeout int64) ([]*UploadObjectMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetUploadMetasToReplicate", limit, timeout)
	ret0, _ := ret[0].([]*UploadObjectMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetUploadMetasToReplicate indicates an expected call of GetUploadMetasToReplicate.
func (mr *MockSPDBMockRecorder) GetUploadMetasToReplicate(limit, timeout any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUploadMetasToReplicate", reflect.TypeOf((*MockSPDB)(nil).GetUploadMetasToReplicate), limit, timeout)
}

// GetUploadMetasToReplicateByStartTS mocks base method.
func (m *MockSPDB) GetUploadMetasToReplicateByStartTS(limit int, startTimeStamp int64) ([]*UploadObjectMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetUploadMetasToReplicateByStartTS", limit, startTimeStamp)
	ret0, _ := ret[0].([]*UploadObjectMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetUploadMetasToReplicateByStartTS indicates an expected call of GetUploadMetasToReplicateByStartTS.
func (mr *MockSPDBMockRecorder) GetUploadMetasToReplicateByStartTS(limit, startTimeStamp any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUploadMetasToReplicateByStartTS", reflect.TypeOf((*MockSPDB)(nil).GetUploadMetasToReplicateByStartTS), limit, startTimeStamp)
}

// GetUploadMetasToSeal mocks base method.
func (m *MockSPDB) GetUploadMetasToSeal(limit int, timeout int64) ([]*UploadObjectMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetUploadMetasToSeal", limit, timeout)
	ret0, _ := ret[0].([]*UploadObjectMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetUploadMetasToSeal indicates an expected call of GetUploadMetasToSeal.
func (mr *MockSPDBMockRecorder) GetUploadMetasToSeal(limit, timeout any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUploadMetasToSeal", reflect.TypeOf((*MockSPDB)(nil).GetUploadMetasToSeal), limit, timeout)
}

// GetUploadMetasToSealByStartTS mocks base method.
func (m *MockSPDB) GetUploadMetasToSealByStartTS(limit int, startTimeStamp int64) ([]*UploadObjectMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetUploadMetasToSealByStartTS", limit, startTimeStamp)
	ret0, _ := ret[0].([]*UploadObjectMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetUploadMetasToSealByStartTS indicates an expected call of GetUploadMetasToSealByStartTS.
func (mr *MockSPDBMockRecorder) GetUploadMetasToSealByStartTS(limit, startTimeStamp any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUploadMetasToSealByStartTS", reflect.TypeOf((*MockSPDB)(nil).GetUploadMetasToSealByStartTS), limit, startTimeStamp)
}

// GetUploadState mocks base method.
func (m *MockSPDB) GetUploadState(objectID uint64) (types.TaskState, string, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetUploadState", objectID)
	ret0, _ := ret[0].(types.TaskState)
	ret1, _ := ret[1].(string)
	ret2, _ := ret[2].(error)
	return ret0, ret1, ret2
}

// GetUploadState indicates an expected call of GetUploadState.
func (mr *MockSPDBMockRecorder) GetUploadState(objectID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUploadState", reflect.TypeOf((*MockSPDB)(nil).GetUploadState), objectID)
}

// GetUserReadRecord mocks base method.
func (m *MockSPDB) GetUserReadRecord(userAddress string, timeRange *TrafficTimeRange) ([]*ReadRecord, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetUserReadRecord", userAddress, timeRange)
	ret0, _ := ret[0].([]*ReadRecord)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetUserReadRecord indicates an expected call of GetUserReadRecord.
func (mr *MockSPDBMockRecorder) GetUserReadRecord(userAddress, timeRange any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUserReadRecord", reflect.TypeOf((*MockSPDB)(nil).GetUserReadRecord), userAddress, timeRange)
}

// InitBucketTraffic mocks base method.
func (m *MockSPDB) InitBucketTraffic(record *ReadRecord, quota *BucketQuota) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InitBucketTraffic", record, quota)
	ret0, _ := ret[0].(error)
	return ret0
}

// InitBucketTraffic indicates an expected call of InitBucketTraffic.
func (mr *MockSPDBMockRecorder) InitBucketTraffic(record, quota any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InitBucketTraffic", reflect.TypeOf((*MockSPDB)(nil).InitBucketTraffic), record, quota)
}

// InsertAuthKey mocks base method.
func (m *MockSPDB) InsertAuthKey(newRecord *OffChainAuthKey) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertAuthKey", newRecord)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertAuthKey indicates an expected call of InsertAuthKey.
func (mr *MockSPDBMockRecorder) InsertAuthKey(newRecord any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertAuthKey", reflect.TypeOf((*MockSPDB)(nil).InsertAuthKey), newRecord)
}

// InsertAuthKeyV2 mocks base method.
func (m *MockSPDB) InsertAuthKeyV2(newRecord *OffChainAuthKeyV2) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertAuthKeyV2", newRecord)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertAuthKeyV2 indicates an expected call of InsertAuthKeyV2.
func (mr *MockSPDBMockRecorder) InsertAuthKeyV2(newRecord any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertAuthKeyV2", reflect.TypeOf((*MockSPDB)(nil).InsertAuthKeyV2), newRecord)
}

// InsertGCObjectProgress mocks base method.
func (m *MockSPDB) InsertGCObjectProgress(gcMeta *GCObjectMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertGCObjectProgress", gcMeta)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertGCObjectProgress indicates an expected call of InsertGCObjectProgress.
func (mr *MockSPDBMockRecorder) InsertGCObjectProgress(gcMeta any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertGCObjectProgress", reflect.TypeOf((*MockSPDB)(nil).InsertGCObjectProgress), gcMeta)
}

// InsertMigrateGVGUnit mocks base method.
func (m *MockSPDB) InsertMigrateGVGUnit(meta *MigrateGVGUnitMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertMigrateGVGUnit", meta)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertMigrateGVGUnit indicates an expected call of InsertMigrateGVGUnit.
func (mr *MockSPDBMockRecorder) InsertMigrateGVGUnit(meta any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertMigrateGVGUnit", reflect.TypeOf((*MockSPDB)(nil).InsertMigrateGVGUnit), meta)
}

// InsertPutEvent mocks base method.
func (m *MockSPDB) InsertPutEvent(task task.Task) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertPutEvent", task)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertPutEvent indicates an expected call of InsertPutEvent.
func (mr *MockSPDBMockRecorder) InsertPutEvent(task any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertPutEvent", reflect.TypeOf((*MockSPDB)(nil).InsertPutEvent), task)
}

// InsertRecoverFailedObject mocks base method.
func (m *MockSPDB) InsertRecoverFailedObject(object *RecoverFailedObject) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertRecoverFailedObject", object)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertRecoverFailedObject indicates an expected call of InsertRecoverFailedObject.
func (mr *MockSPDBMockRecorder) InsertRecoverFailedObject(object any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertRecoverFailedObject", reflect.TypeOf((*MockSPDB)(nil).InsertRecoverFailedObject), object)
}

// InsertSwapOutUnit mocks base method.
func (m *MockSPDB) InsertSwapOutUnit(meta *SwapOutMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertSwapOutUnit", meta)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertSwapOutUnit indicates an expected call of InsertSwapOutUnit.
func (mr *MockSPDBMockRecorder) InsertSwapOutUnit(meta any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertSwapOutUnit", reflect.TypeOf((*MockSPDB)(nil).InsertSwapOutUnit), meta)
}

// InsertUploadProgress mocks base method.
func (m *MockSPDB) InsertUploadProgress(objectID uint64, isAgentUpload bool) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertUploadProgress", objectID, isAgentUpload)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertUploadProgress indicates an expected call of InsertUploadProgress.
func (mr *MockSPDBMockRecorder) InsertUploadProgress(objectID, isAgentUpload any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertUploadProgress", reflect.TypeOf((*MockSPDB)(nil).InsertUploadProgress), objectID, isAgentUpload)
}

// ListAuthKeysV2 mocks base method.
func (m *MockSPDB) ListAuthKeysV2(userAddress, domain string) ([]string, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListAuthKeysV2", userAddress, domain)
	ret0, _ := ret[0].([]string)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListAuthKeysV2 indicates an expected call of ListAuthKeysV2.
func (mr *MockSPDBMockRecorder) ListAuthKeysV2(userAddress, domain any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListAuthKeysV2", reflect.TypeOf((*MockSPDB)(nil).ListAuthKeysV2), userAddress, domain)
}

// ListBucketMigrationToConfirm mocks base method.
func (m *MockSPDB) ListBucketMigrationToConfirm(migrationStates []int) ([]*MigrateBucketProgressMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListBucketMigrationToConfirm", migrationStates)
	ret0, _ := ret[0].([]*MigrateBucketProgressMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListBucketMigrationToConfirm indicates an expected call of ListBucketMigrationToConfirm.
func (mr *MockSPDBMockRecorder) ListBucketMigrationToConfirm(migrationStates any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListBucketMigrationToConfirm", reflect.TypeOf((*MockSPDB)(nil).ListBucketMigrationToConfirm), migrationStates)
}

// ListBucketTraffic mocks base method.
func (m *MockSPDB) ListBucketTraffic(yearMonth string, offset, limit int) ([]*BucketTraffic, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListBucketTraffic", yearMonth, offset, limit)
	ret0, _ := ret[0].([]*BucketTraffic)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListBucketTraffic indicates an expected call of ListBucketTraffic.
func (mr *MockSPDBMockRecorder) ListBucketTraffic(yearMonth, offset, limit any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListBucketTraffic", reflect.TypeOf((*MockSPDB)(nil).ListBucketTraffic), yearMonth, offset, limit)
}

// ListDestSPSwapOutUnits mocks base method.
func (m *MockSPDB) ListDestSPSwapOutUnits() ([]*SwapOutMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListDestSPSwapOutUnits")
	ret0, _ := ret[0].([]*SwapOutMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListDestSPSwapOutUnits indicates an expected call of ListDestSPSwapOutUnits.
func (mr *MockSPDBMockRecorder) ListDestSPSwapOutUnits() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListDestSPSwapOutUnits", reflect.TypeOf((*MockSPDB)(nil).ListDestSPSwapOutUnits))
}

// ListIntegrityMetaByObjectIDRange mocks base method.
func (m *MockSPDB) ListIntegrityMetaByObjectIDRange(startObjectID, endObjectID int64, includePrivate bool) ([]*IntegrityMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListIntegrityMetaByObjectIDRange", startObjectID, endObjectID, includePrivate)
	ret0, _ := ret[0].([]*IntegrityMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListIntegrityMetaByObjectIDRange indicates an expected call of ListIntegrityMetaByObjectIDRange.
func (mr *MockSPDBMockRecorder) ListIntegrityMetaByObjectIDRange(startObjectID, endObjectID, includePrivate any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListIntegrityMetaByObjectIDRange", reflect.TypeOf((*MockSPDB)(nil).ListIntegrityMetaByObjectIDRange), startObjectID, endObjectID, includePrivate)
}

// ListMigrateGVGUnitsByBucketID mocks base method.
func (m *MockSPDB) ListMigrateGVGUnitsByBucketID(bucketID uint64) ([]*MigrateGVGUnitMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListMigrateGVGUnitsByBucketID", bucketID)
	ret0, _ := ret[0].([]*MigrateGVGUnitMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListMigrateGVGUnitsByBucketID indicates an expected call of ListMigrateGVGUnitsByBucketID.
func (mr *MockSPDBMockRecorder) ListMigrateGVGUnitsByBucketID(bucketID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListMigrateGVGUnitsByBucketID", reflect.TypeOf((*MockSPDB)(nil).ListMigrateGVGUnitsByBucketID), bucketID)
}

// ListReplicatePieceChecksumByObjectIDRange mocks base method.
func (m *MockSPDB) ListReplicatePieceChecksumByObjectIDRange(startObjectID, endObjectID int64) ([]*GCPieceMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListReplicatePieceChecksumByObjectIDRange", startObjectID, endObjectID)
	ret0, _ := ret[0].([]*GCPieceMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListReplicatePieceChecksumByObjectIDRange indicates an expected call of ListReplicatePieceChecksumByObjectIDRange.
func (mr *MockSPDBMockRecorder) ListReplicatePieceChecksumByObjectIDRange(startObjectID, endObjectID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListReplicatePieceChecksumByObjectIDRange", reflect.TypeOf((*MockSPDB)(nil).ListReplicatePieceChecksumByObjectIDRange), startObjectID, endObjectID)
}

// ListShadowIntegrityMeta mocks base method.
func (m *MockSPDB) ListShadowIntegrityMeta() ([]*ShadowIntegrityMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListShadowIntegrityMeta")
	ret0, _ := ret[0].([]*ShadowIntegrityMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListShadowIntegrityMeta indicates an expected call of ListShadowIntegrityMeta.
func (mr *MockSPDBMockRecorder) ListShadowIntegrityMeta() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListShadowIntegrityMeta", reflect.TypeOf((*MockSPDB)(nil).ListShadowIntegrityMeta))
}

// QueryBucketMigrateSubscribeProgress mocks base method.
func (m *MockSPDB) QueryBucketMigrateSubscribeProgress() (uint64, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "QueryBucketMigrateSubscribeProgress")
	ret0, _ := ret[0].(uint64)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// QueryBucketMigrateSubscribeProgress indicates an expected call of QueryBucketMigrateSubscribeProgress.
func (mr *MockSPDBMockRecorder) QueryBucketMigrateSubscribeProgress() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QueryBucketMigrateSubscribeProgress", reflect.TypeOf((*MockSPDB)(nil).QueryBucketMigrateSubscribeProgress))
}

// QueryMigrateBucketProgress mocks base method.
func (m *MockSPDB) QueryMigrateBucketProgress(bucketID uint64) (*MigrateBucketProgressMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "QueryMigrateBucketProgress", bucketID)
	ret0, _ := ret[0].(*MigrateBucketProgressMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// QueryMigrateBucketProgress indicates an expected call of QueryMigrateBucketProgress.
func (mr *MockSPDBMockRecorder) QueryMigrateBucketProgress(bucketID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QueryMigrateBucketProgress", reflect.TypeOf((*MockSPDB)(nil).QueryMigrateBucketProgress), bucketID)
}

// QueryMigrateBucketState mocks base method.
func (m *MockSPDB) QueryMigrateBucketState(bucketID uint64) (int, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "QueryMigrateBucketState", bucketID)
	ret0, _ := ret[0].(int)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// QueryMigrateBucketState indicates an expected call of QueryMigrateBucketState.
func (mr *MockSPDBMockRecorder) QueryMigrateBucketState(bucketID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QueryMigrateBucketState", reflect.TypeOf((*MockSPDB)(nil).QueryMigrateBucketState), bucketID)
}

// QueryMigrateGVGUnit mocks base method.
func (m *MockSPDB) QueryMigrateGVGUnit(migrateKey string) (*MigrateGVGUnitMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "QueryMigrateGVGUnit", migrateKey)
	ret0, _ := ret[0].(*MigrateGVGUnitMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// QueryMigrateGVGUnit indicates an expected call of QueryMigrateGVGUnit.
func (mr *MockSPDBMockRecorder) QueryMigrateGVGUnit(migrateKey any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QueryMigrateGVGUnit", reflect.TypeOf((*MockSPDB)(nil).QueryMigrateGVGUnit), migrateKey)
}

// QuerySPExitSubscribeProgress mocks base method.
func (m *MockSPDB) QuerySPExitSubscribeProgress() (uint64, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "QuerySPExitSubscribeProgress")
	ret0, _ := ret[0].(uint64)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// QuerySPExitSubscribeProgress indicates an expected call of QuerySPExitSubscribeProgress.
func (mr *MockSPDBMockRecorder) QuerySPExitSubscribeProgress() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QuerySPExitSubscribeProgress", reflect.TypeOf((*MockSPDB)(nil).QuerySPExitSubscribeProgress))
}

// QuerySwapOutSubscribeProgress mocks base method.
func (m *MockSPDB) QuerySwapOutSubscribeProgress() (uint64, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "QuerySwapOutSubscribeProgress")
	ret0, _ := ret[0].(uint64)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// QuerySwapOutSubscribeProgress indicates an expected call of QuerySwapOutSubscribeProgress.
func (mr *MockSPDBMockRecorder) QuerySwapOutSubscribeProgress() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QuerySwapOutSubscribeProgress", reflect.TypeOf((*MockSPDB)(nil).QuerySwapOutSubscribeProgress))
}

// QuerySwapOutUnitInSrcSP mocks base method.
func (m *MockSPDB) QuerySwapOutUnitInSrcSP(swapOutKey string) (*SwapOutMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "QuerySwapOutUnitInSrcSP", swapOutKey)
	ret0, _ := ret[0].(*SwapOutMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// QuerySwapOutUnitInSrcSP indicates an expected call of QuerySwapOutUnitInSrcSP.
func (mr *MockSPDBMockRecorder) QuerySwapOutUnitInSrcSP(swapOutKey any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QuerySwapOutUnitInSrcSP", reflect.TypeOf((*MockSPDB)(nil).QuerySwapOutUnitInSrcSP), swapOutKey)
}

// SetObjectIntegrity mocks base method.
func (m *MockSPDB) SetObjectIntegrity(integrity *IntegrityMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "SetObjectIntegrity", integrity)
	ret0, _ := ret[0].(error)
	return ret0
}

// SetObjectIntegrity indicates an expected call of SetObjectIntegrity.
func (mr *MockSPDBMockRecorder) SetObjectIntegrity(integrity any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetObjectIntegrity", reflect.TypeOf((*MockSPDB)(nil).SetObjectIntegrity), integrity)
}

// SetOwnSpInfo mocks base method.
func (m *MockSPDB) SetOwnSpInfo(sp *types0.StorageProvider) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "SetOwnSpInfo", sp)
	ret0, _ := ret[0].(error)
	return ret0
}

// SetOwnSpInfo indicates an expected call of SetOwnSpInfo.
func (mr *MockSPDBMockRecorder) SetOwnSpInfo(sp any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetOwnSpInfo", reflect.TypeOf((*MockSPDB)(nil).SetOwnSpInfo), sp)
}

// SetRecoverGVGStats mocks base method.
func (m *MockSPDB) SetRecoverGVGStats(stats []*RecoverGVGStats) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "SetRecoverGVGStats", stats)
	ret0, _ := ret[0].(error)
	return ret0
}

// SetRecoverGVGStats indicates an expected call of SetRecoverGVGStats.
func (mr *MockSPDBMockRecorder) SetRecoverGVGStats(stats any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetRecoverGVGStats", reflect.TypeOf((*MockSPDB)(nil).SetRecoverGVGStats), stats)
}

// SetReplicatePieceChecksum mocks base method.
func (m *MockSPDB) SetReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32, checksum []byte, version int64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "SetReplicatePieceChecksum", objectID, segmentIdx, redundancyIdx, checksum, version)
	ret0, _ := ret[0].(error)
	return ret0
}

// SetReplicatePieceChecksum indicates an expected call of SetReplicatePieceChecksum.
func (mr *MockSPDBMockRecorder) SetReplicatePieceChecksum(objectID, segmentIdx, redundancyIdx, checksum, version any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetReplicatePieceChecksum", reflect.TypeOf((*MockSPDB)(nil).SetReplicatePieceChecksum), objectID, segmentIdx, redundancyIdx, checksum, version)
}

// SetShadowObjectIntegrity mocks base method.
func (m *MockSPDB) SetShadowObjectIntegrity(integrity *ShadowIntegrityMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "SetShadowObjectIntegrity", integrity)
	ret0, _ := ret[0].(error)
	return ret0
}

// SetShadowObjectIntegrity indicates an expected call of SetShadowObjectIntegrity.
func (mr *MockSPDBMockRecorder) SetShadowObjectIntegrity(integrity any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetShadowObjectIntegrity", reflect.TypeOf((*MockSPDB)(nil).SetShadowObjectIntegrity), integrity)
}

// UpdateAllSp mocks base method.
func (m *MockSPDB) UpdateAllSp(spList []*types0.StorageProvider) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateAllSp", spList)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateAllSp indicates an expected call of UpdateAllSp.
func (mr *MockSPDBMockRecorder) UpdateAllSp(spList any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateAllSp", reflect.TypeOf((*MockSPDB)(nil).UpdateAllSp), spList)
}

// UpdateAuthKey mocks base method.
func (m *MockSPDB) UpdateAuthKey(userAddress, domain string, oldNonce, newNonce int32, newPublicKey string, newExpiryDate time.Time) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateAuthKey", userAddress, domain, oldNonce, newNonce, newPublicKey, newExpiryDate)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateAuthKey indicates an expected call of UpdateAuthKey.
func (mr *MockSPDBMockRecorder) UpdateAuthKey(userAddress, domain, oldNonce, newNonce, newPublicKey, newExpiryDate any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateAuthKey", reflect.TypeOf((*MockSPDB)(nil).UpdateAuthKey), userAddress, domain, oldNonce, newNonce, newPublicKey, newExpiryDate)
}

// UpdateBucketMigrateGCSubscribeProgress mocks base method.
func (m *MockSPDB) UpdateBucketMigrateGCSubscribeProgress(blockHeight uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketMigrateGCSubscribeProgress", blockHeight)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketMigrateGCSubscribeProgress indicates an expected call of UpdateBucketMigrateGCSubscribeProgress.
func (mr *MockSPDBMockRecorder) UpdateBucketMigrateGCSubscribeProgress(blockHeight any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketMigrateGCSubscribeProgress", reflect.TypeOf((*MockSPDB)(nil).UpdateBucketMigrateGCSubscribeProgress), blockHeight)
}

// UpdateBucketMigrateSubscribeProgress mocks base method.
func (m *MockSPDB) UpdateBucketMigrateSubscribeProgress(blockHeight uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketMigrateSubscribeProgress", blockHeight)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketMigrateSubscribeProgress indicates an expected call of UpdateBucketMigrateSubscribeProgress.
func (mr *MockSPDBMockRecorder) UpdateBucketMigrateSubscribeProgress(blockHeight any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketMigrateSubscribeProgress", reflect.TypeOf((*MockSPDB)(nil).UpdateBucketMigrateSubscribeProgress), blockHeight)
}

// UpdateBucketMigrationGCProgress mocks base method.
func (m *MockSPDB) UpdateBucketMigrationGCProgress(progressMeta MigrateBucketProgressMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketMigrationGCProgress", progressMeta)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketMigrationGCProgress indicates an expected call of UpdateBucketMigrationGCProgress.
func (mr *MockSPDBMockRecorder) UpdateBucketMigrationGCProgress(progressMeta any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketMigrationGCProgress", reflect.TypeOf((*MockSPDB)(nil).UpdateBucketMigrationGCProgress), progressMeta)
}

// UpdateBucketMigrationMigratingProgress mocks base method.
func (m *MockSPDB) UpdateBucketMigrationMigratingProgress(bucketID uint64, gvgUnits, gvgUnitsFinished uint32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketMigrationMigratingProgress", bucketID, gvgUnits, gvgUnitsFinished)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketMigrationMigratingProgress indicates an expected call of UpdateBucketMigrationMigratingProgress.
func (mr *MockSPDBMockRecorder) UpdateBucketMigrationMigratingProgress(bucketID, gvgUnits, gvgUnitsFinished any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketMigrationMigratingProgress", reflect.TypeOf((*MockSPDB)(nil).UpdateBucketMigrationMigratingProgress), bucketID, gvgUnits, gvgUnitsFinished)
}

// UpdateBucketMigrationPreDeductedQuota mocks base method.
func (m *MockSPDB) UpdateBucketMigrationPreDeductedQuota(bucketID, deductedQuota uint64, state int) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketMigrationPreDeductedQuota", bucketID, deductedQuota, state)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketMigrationPreDeductedQuota indicates an expected call of UpdateBucketMigrationPreDeductedQuota.
func (mr *MockSPDBMockRecorder) UpdateBucketMigrationPreDeductedQuota(bucketID, deductedQuota, state any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketMigrationPreDeductedQuota", reflect.TypeOf((*MockSPDB)(nil).UpdateBucketMigrationPreDeductedQuota), bucketID, deductedQuota, state)
}

// UpdateBucketMigrationProgress mocks base method.
func (m *MockSPDB) UpdateBucketMigrationProgress(bucketID uint64, migrateState int) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketMigrationProgress", bucketID, migrateState)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketMigrationProgress indicates an expected call of UpdateBucketMigrationProgress.
func (mr *MockSPDBMockRecorder) UpdateBucketMigrationProgress(bucketID, migrateState any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketMigrationProgress", reflect.TypeOf((*MockSPDB)(nil).UpdateBucketMigrationProgress), bucketID, migrateState)
}

// UpdateBucketMigrationRecoupQuota mocks base method.
func (m *MockSPDB) UpdateBucketMigrationRecoupQuota(bucketID, recoupQuota uint64, state int) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketMigrationRecoupQuota", bucketID, recoupQuota, state)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketMigrationRecoupQuota indicates an expected call of UpdateBucketMigrationRecoupQuota.
func (mr *MockSPDBMockRecorder) UpdateBucketMigrationRecoupQuota(bucketID, recoupQuota, state any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketMigrationRecoupQuota", reflect.TypeOf((*MockSPDB)(nil).UpdateBucketMigrationRecoupQuota), bucketID, recoupQuota, state)
}

// UpdateBucketTraffic mocks base method.
func (m *MockSPDB) UpdateBucketTraffic(bucketID uint64, update *BucketTraffic) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketTraffic", bucketID, update)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketTraffic indicates an expected call of UpdateBucketTraffic.
func (mr *MockSPDBMockRecorder) UpdateBucketTraffic(bucketID, update any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketTraffic", reflect.TypeOf((*MockSPDB)(nil).UpdateBucketTraffic), bucketID, update)
}

// UpdateExtraQuota mocks base method.
func (m *MockSPDB) UpdateExtraQuota(bucketID, extraQuota uint64, yearMonth string) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateExtraQuota", bucketID, extraQuota, yearMonth)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateExtraQuota indicates an expected call of UpdateExtraQuota.
func (mr *MockSPDBMockRecorder) UpdateExtraQuota(bucketID, extraQuota, yearMonth any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateExtraQuota", reflect.TypeOf((*MockSPDB)(nil).UpdateExtraQuota), bucketID, extraQuota, yearMonth)
}

// UpdateGCObjectProgress mocks base method.
func (m *MockSPDB) UpdateGCObjectProgress(gcMeta *GCObjectMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateGCObjectProgress", gcMeta)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateGCObjectProgress indicates an expected call of UpdateGCObjectProgress.
func (mr *MockSPDBMockRecorder) UpdateGCObjectProgress(gcMeta any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateGCObjectProgress", reflect.TypeOf((*MockSPDB)(nil).UpdateGCObjectProgress), gcMeta)
}

// UpdateIntegrityChecksum mocks base method.
func (m *MockSPDB) UpdateIntegrityChecksum(integrity *IntegrityMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateIntegrityChecksum", integrity)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateIntegrityChecksum indicates an expected call of UpdateIntegrityChecksum.
func (mr *MockSPDBMockRecorder) UpdateIntegrityChecksum(integrity any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateIntegrityChecksum", reflect.TypeOf((*MockSPDB)(nil).UpdateIntegrityChecksum), integrity)
}

// UpdateIntegrityMeta mocks base method.
func (m *MockSPDB) UpdateIntegrityMeta(integrity *IntegrityMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateIntegrityMeta", integrity)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateIntegrityMeta indicates an expected call of UpdateIntegrityMeta.
func (mr *MockSPDBMockRecorder) UpdateIntegrityMeta(integrity any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateIntegrityMeta", reflect.TypeOf((*MockSPDB)(nil).UpdateIntegrityMeta), integrity)
}

// UpdateMigrateGVGMigratedBytesSize mocks base method.
func (m *MockSPDB) UpdateMigrateGVGMigratedBytesSize(migrateKey string, migratedBytes uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateMigrateGVGMigratedBytesSize", migrateKey, migratedBytes)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateMigrateGVGMigratedBytesSize indicates an expected call of UpdateMigrateGVGMigratedBytesSize.
func (mr *MockSPDBMockRecorder) UpdateMigrateGVGMigratedBytesSize(migrateKey, migratedBytes any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateMigrateGVGMigratedBytesSize", reflect.TypeOf((*MockSPDB)(nil).UpdateMigrateGVGMigratedBytesSize), migrateKey, migratedBytes)
}

// UpdateMigrateGVGRetryCount mocks base method.
func (m *MockSPDB) UpdateMigrateGVGRetryCount(migrateKey string, retryTime int) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateMigrateGVGRetryCount", migrateKey, retryTime)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateMigrateGVGRetryCount indicates an expected call of UpdateMigrateGVGRetryCount.
func (mr *MockSPDBMockRecorder) UpdateMigrateGVGRetryCount(migrateKey, retryTime any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateMigrateGVGRetryCount", reflect.TypeOf((*MockSPDB)(nil).UpdateMigrateGVGRetryCount), migrateKey, retryTime)
}

// UpdateMigrateGVGUnitLastMigrateObjectID mocks base method.
func (m *MockSPDB) UpdateMigrateGVGUnitLastMigrateObjectID(migrateKey string, lastMigrateObjectID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateMigrateGVGUnitLastMigrateObjectID", migrateKey, lastMigrateObjectID)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateMigrateGVGUnitLastMigrateObjectID indicates an expected call of UpdateMigrateGVGUnitLastMigrateObjectID.
func (mr *MockSPDBMockRecorder) UpdateMigrateGVGUnitLastMigrateObjectID(migrateKey, lastMigrateObjectID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateMigrateGVGUnitLastMigrateObjectID", reflect.TypeOf((*MockSPDB)(nil).UpdateMigrateGVGUnitLastMigrateObjectID), migrateKey, lastMigrateObjectID)
}

// UpdateMigrateGVGUnitStatus mocks base method.
func (m *MockSPDB) UpdateMigrateGVGUnitStatus(migrateKey string, migrateStatus int) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateMigrateGVGUnitStatus", migrateKey, migrateStatus)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateMigrateGVGUnitStatus indicates an expected call of UpdateMigrateGVGUnitStatus.
func (mr *MockSPDBMockRecorder) UpdateMigrateGVGUnitStatus(migrateKey, migrateStatus any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateMigrateGVGUnitStatus", reflect.TypeOf((*MockSPDB)(nil).UpdateMigrateGVGUnitStatus), migrateKey, migrateStatus)
}

// UpdatePieceChecksum mocks base method.
func (m *MockSPDB) UpdatePieceChecksum(objectID uint64, redundancyIndex int32, checksum []byte, dataLength uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdatePieceChecksum", objectID, redundancyIndex, checksum, dataLength)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdatePieceChecksum indicates an expected call of UpdatePieceChecksum.
func (mr *MockSPDBMockRecorder) UpdatePieceChecksum(objectID, redundancyIndex, checksum, dataLength any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdatePieceChecksum", reflect.TypeOf((*MockSPDB)(nil).UpdatePieceChecksum), objectID, redundancyIndex, checksum, dataLength)
}

// UpdateRecoverFailedObject mocks base method.
func (m *MockSPDB) UpdateRecoverFailedObject(object *RecoverFailedObject) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateRecoverFailedObject", object)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateRecoverFailedObject indicates an expected call of UpdateRecoverFailedObject.
func (mr *MockSPDBMockRecorder) UpdateRecoverFailedObject(object any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateRecoverFailedObject", reflect.TypeOf((*MockSPDB)(nil).UpdateRecoverFailedObject), object)
}

// UpdateRecoverGVGStats mocks base method.
func (m *MockSPDB) UpdateRecoverGVGStats(stats *RecoverGVGStats) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateRecoverGVGStats", stats)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateRecoverGVGStats indicates an expected call of UpdateRecoverGVGStats.
func (mr *MockSPDBMockRecorder) UpdateRecoverGVGStats(stats any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateRecoverGVGStats", reflect.TypeOf((*MockSPDB)(nil).UpdateRecoverGVGStats), stats)
}

// UpdateSPExitSubscribeProgress mocks base method.
func (m *MockSPDB) UpdateSPExitSubscribeProgress(blockHeight uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateSPExitSubscribeProgress", blockHeight)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateSPExitSubscribeProgress indicates an expected call of UpdateSPExitSubscribeProgress.
func (mr *MockSPDBMockRecorder) UpdateSPExitSubscribeProgress(blockHeight any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateSPExitSubscribeProgress", reflect.TypeOf((*MockSPDB)(nil).UpdateSPExitSubscribeProgress), blockHeight)
}

// UpdateShadowIntegrityChecksum mocks base method.
func (m *MockSPDB) UpdateShadowIntegrityChecksum(integrity *ShadowIntegrityMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateShadowIntegrityChecksum", integrity)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateShadowIntegrityChecksum indicates an expected call of UpdateShadowIntegrityChecksum.
func (mr *MockSPDBMockRecorder) UpdateShadowIntegrityChecksum(integrity any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateShadowIntegrityChecksum", reflect.TypeOf((*MockSPDB)(nil).UpdateShadowIntegrityChecksum), integrity)
}

// UpdateShadowPieceChecksum mocks base method.
func (m *MockSPDB) UpdateShadowPieceChecksum(objectID uint64, redundancyIndex int32, checksum []byte, version int64, dataLength uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateShadowPieceChecksum", objectID, redundancyIndex, checksum, version, dataLength)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateShadowPieceChecksum indicates an expected call of UpdateShadowPieceChecksum.
func (mr *MockSPDBMockRecorder) UpdateShadowPieceChecksum(objectID, redundancyIndex, checksum, version, dataLength any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateShadowPieceChecksum", reflect.TypeOf((*MockSPDB)(nil).UpdateShadowPieceChecksum), objectID, redundancyIndex, checksum, version, dataLength)
}

// UpdateSwapOutSubscribeProgress mocks base method.
func (m *MockSPDB) UpdateSwapOutSubscribeProgress(blockHeight uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateSwapOutSubscribeProgress", blockHeight)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateSwapOutSubscribeProgress indicates an expected call of UpdateSwapOutSubscribeProgress.
func (mr *MockSPDBMockRecorder) UpdateSwapOutSubscribeProgress(blockHeight any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateSwapOutSubscribeProgress", reflect.TypeOf((*MockSPDB)(nil).UpdateSwapOutSubscribeProgress), blockHeight)
}

// UpdateSwapOutUnitCompletedGVGList mocks base method.
func (m *MockSPDB) UpdateSwapOutUnitCompletedGVGList(swapOutKey string, completedGVGList []uint32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateSwapOutUnitCompletedGVGList", swapOutKey, completedGVGList)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateSwapOutUnitCompletedGVGList indicates an expected call of UpdateSwapOutUnitCompletedGVGList.
func (mr *MockSPDBMockRecorder) UpdateSwapOutUnitCompletedGVGList(swapOutKey, completedGVGList any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateSwapOutUnitCompletedGVGList", reflect.TypeOf((*MockSPDB)(nil).UpdateSwapOutUnitCompletedGVGList), swapOutKey, completedGVGList)
}

// UpdateUploadProgress mocks base method.
func (m *MockSPDB) UpdateUploadProgress(uploadMeta *UploadObjectMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateUploadProgress", uploadMeta)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateUploadProgress indicates an expected call of UpdateUploadProgress.
func (mr *MockSPDBMockRecorder) UpdateUploadProgress(uploadMeta any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateUploadProgress", reflect.TypeOf((*MockSPDB)(nil).UpdateUploadProgress), uploadMeta)
}

// MockUploadObjectProgressDB is a mock of UploadObjectProgressDB interface.
type MockUploadObjectProgressDB struct {
	ctrl     *gomock.Controller
	recorder *MockUploadObjectProgressDBMockRecorder
}

// MockUploadObjectProgressDBMockRecorder is the mock recorder for MockUploadObjectProgressDB.
type MockUploadObjectProgressDBMockRecorder struct {
	mock *MockUploadObjectProgressDB
}

// NewMockUploadObjectProgressDB creates a new mock instance.
func NewMockUploadObjectProgressDB(ctrl *gomock.Controller) *MockUploadObjectProgressDB {
	mock := &MockUploadObjectProgressDB{ctrl: ctrl}
	mock.recorder = &MockUploadObjectProgressDBMockRecorder{mock}
	return mock
}

// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockUploadObjectProgressDB) EXPECT() *MockUploadObjectProgressDBMockRecorder {
	return m.recorder
}

// DeleteUploadProgress mocks base method.
func (m *MockUploadObjectProgressDB) DeleteUploadProgress(objectID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteUploadProgress", objectID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteUploadProgress indicates an expected call of DeleteUploadProgress.
func (mr *MockUploadObjectProgressDBMockRecorder) DeleteUploadProgress(objectID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteUploadProgress", reflect.TypeOf((*MockUploadObjectProgressDB)(nil).DeleteUploadProgress), objectID)
}

// GetUploadMetasToRejectUnsealByRangeTS mocks base method.
func (m *MockUploadObjectProgressDB) GetUploadMetasToRejectUnsealByRangeTS(limit int, startTimeStamp, endTimeStamp int64) ([]*UploadObjectMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetUploadMetasToRejectUnsealByRangeTS", limit, startTimeStamp, endTimeStamp)
	ret0, _ := ret[0].([]*UploadObjectMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetUploadMetasToRejectUnsealByRangeTS indicates an expected call of GetUploadMetasToRejectUnsealByRangeTS.
func (mr *MockUploadObjectProgressDBMockRecorder) GetUploadMetasToRejectUnsealByRangeTS(limit, startTimeStamp, endTimeStamp any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUploadMetasToRejectUnsealByRangeTS", reflect.TypeOf((*MockUploadObjectProgressDB)(nil).GetUploadMetasToRejectUnsealByRangeTS), limit, startTimeStamp, endTimeStamp)
}

// GetUploadMetasToReplicate mocks base method.
func (m *MockUploadObjectProgressDB) GetUploadMetasToReplicate(limit int, timeout int64) ([]*UploadObjectMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetUploadMetasToReplicate", limit, timeout)
	ret0, _ := ret[0].([]*UploadObjectMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetUploadMetasToReplicate indicates an expected call of GetUploadMetasToReplicate.
func (mr *MockUploadObjectProgressDBMockRecorder) GetUploadMetasToReplicate(limit, timeout any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUploadMetasToReplicate", reflect.TypeOf((*MockUploadObjectProgressDB)(nil).GetUploadMetasToReplicate), limit, timeout)
}

// GetUploadMetasToReplicateByStartTS mocks base method.
func (m *MockUploadObjectProgressDB) GetUploadMetasToReplicateByStartTS(limit int, startTimeStamp int64) ([]*UploadObjectMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetUploadMetasToReplicateByStartTS", limit, startTimeStamp)
	ret0, _ := ret[0].([]*UploadObjectMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetUploadMetasToReplicateByStartTS indicates an expected call of GetUploadMetasToReplicateByStartTS.
func (mr *MockUploadObjectProgressDBMockRecorder) GetUploadMetasToReplicateByStartTS(limit, startTimeStamp any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUploadMetasToReplicateByStartTS", reflect.TypeOf((*MockUploadObjectProgressDB)(nil).GetUploadMetasToReplicateByStartTS), limit, startTimeStamp)
}

// GetUploadMetasToSeal mocks base method.
func (m *MockUploadObjectProgressDB) GetUploadMetasToSeal(limit int, timeout int64) ([]*UploadObjectMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetUploadMetasToSeal", limit, timeout)
	ret0, _ := ret[0].([]*UploadObjectMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetUploadMetasToSeal indicates an expected call of GetUploadMetasToSeal.
func (mr *MockUploadObjectProgressDBMockRecorder) GetUploadMetasToSeal(limit, timeout any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUploadMetasToSeal", reflect.TypeOf((*MockUploadObjectProgressDB)(nil).GetUploadMetasToSeal), limit, timeout)
}

// GetUploadMetasToSealByStartTS mocks base method.
func (m *MockUploadObjectProgressDB) GetUploadMetasToSealByStartTS(limit int, startTimeStamp int64) ([]*UploadObjectMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetUploadMetasToSealByStartTS", limit, startTimeStamp)
	ret0, _ := ret[0].([]*UploadObjectMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetUploadMetasToSealByStartTS indicates an expected call of GetUploadMetasToSealByStartTS.
func (mr *MockUploadObjectProgressDBMockRecorder) GetUploadMetasToSealByStartTS(limit, startTimeStamp any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUploadMetasToSealByStartTS", reflect.TypeOf((*MockUploadObjectProgressDB)(nil).GetUploadMetasToSealByStartTS), limit, startTimeStamp)
}

// GetUploadState mocks base method.
func (m *MockUploadObjectProgressDB) GetUploadState(objectID uint64) (types.TaskState, string, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetUploadState", objectID)
	ret0, _ := ret[0].(types.TaskState)
	ret1, _ := ret[1].(string)
	ret2, _ := ret[2].(error)
	return ret0, ret1, ret2
}

// GetUploadState indicates an expected call of GetUploadState.
func (mr *MockUploadObjectProgressDBMockRecorder) GetUploadState(objectID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUploadState", reflect.TypeOf((*MockUploadObjectProgressDB)(nil).GetUploadState), objectID)
}

// InsertPutEvent mocks base method.
func (m *MockUploadObjectProgressDB) InsertPutEvent(task task.Task) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertPutEvent", task)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertPutEvent indicates an expected call of InsertPutEvent.
func (mr *MockUploadObjectProgressDBMockRecorder) InsertPutEvent(task any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertPutEvent", reflect.TypeOf((*MockUploadObjectProgressDB)(nil).InsertPutEvent), task)
}

// InsertUploadProgress mocks base method.
func (m *MockUploadObjectProgressDB) InsertUploadProgress(objectID uint64, isAgentUpload bool) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertUploadProgress", objectID, isAgentUpload)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertUploadProgress indicates an expected call of InsertUploadProgress.
func (mr *MockUploadObjectProgressDBMockRecorder) InsertUploadProgress(objectID, isAgentUpload any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertUploadProgress", reflect.TypeOf((*MockUploadObjectProgressDB)(nil).InsertUploadProgress), objectID, isAgentUpload)
}

// UpdateUploadProgress mocks base method.
func (m *MockUploadObjectProgressDB) UpdateUploadProgress(uploadMeta *UploadObjectMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateUploadProgress", uploadMeta)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateUploadProgress indicates an expected call of UpdateUploadProgress.
func (mr *MockUploadObjectProgressDBMockRecorder) UpdateUploadProgress(uploadMeta any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateUploadProgress", reflect.TypeOf((*MockUploadObjectProgressDB)(nil).UpdateUploadProgress), uploadMeta)
}

// MockGCObjectProgressDB is a mock of GCObjectProgressDB interface.
type MockGCObjectProgressDB struct {
	ctrl     *gomock.Controller
	recorder *MockGCObjectProgressDBMockRecorder
}

// MockGCObjectProgressDBMockRecorder is the mock recorder for MockGCObjectProgressDB.
type MockGCObjectProgressDBMockRecorder struct {
	mock *MockGCObjectProgressDB
}

// NewMockGCObjectProgressDB creates a new mock instance.
func NewMockGCObjectProgressDB(ctrl *gomock.Controller) *MockGCObjectProgressDB {
	mock := &MockGCObjectProgressDB{ctrl: ctrl}
	mock.recorder = &MockGCObjectProgressDBMockRecorder{mock}
	return mock
}

// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockGCObjectProgressDB) EXPECT() *MockGCObjectProgressDBMockRecorder {
	return m.recorder
}

// DeleteGCObjectProgress mocks base method.
func (m *MockGCObjectProgressDB) DeleteGCObjectProgress(taskKey string) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteGCObjectProgress", taskKey)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteGCObjectProgress indicates an expected call of DeleteGCObjectProgress.
func (mr *MockGCObjectProgressDBMockRecorder) DeleteGCObjectProgress(taskKey any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteGCObjectProgress", reflect.TypeOf((*MockGCObjectProgressDB)(nil).DeleteGCObjectProgress), taskKey)
}

// GetGCMetasToGC mocks base method.
func (m *MockGCObjectProgressDB) GetGCMetasToGC(limit int) ([]*GCObjectMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetGCMetasToGC", limit)
	ret0, _ := ret[0].([]*GCObjectMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetGCMetasToGC indicates an expected call of GetGCMetasToGC.
func (mr *MockGCObjectProgressDBMockRecorder) GetGCMetasToGC(limit any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetGCMetasToGC", reflect.TypeOf((*MockGCObjectProgressDB)(nil).GetGCMetasToGC), limit)
}

// InsertGCObjectProgress mocks base method.
func (m *MockGCObjectProgressDB) InsertGCObjectProgress(gcMeta *GCObjectMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertGCObjectProgress", gcMeta)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertGCObjectProgress indicates an expected call of InsertGCObjectProgress.
func (mr *MockGCObjectProgressDBMockRecorder) InsertGCObjectProgress(gcMeta any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertGCObjectProgress", reflect.TypeOf((*MockGCObjectProgressDB)(nil).InsertGCObjectProgress), gcMeta)
}

// UpdateGCObjectProgress mocks base method.
func (m *MockGCObjectProgressDB) UpdateGCObjectProgress(gcMeta *GCObjectMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateGCObjectProgress", gcMeta)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateGCObjectProgress indicates an expected call of UpdateGCObjectProgress.
func (mr *MockGCObjectProgressDBMockRecorder) UpdateGCObjectProgress(gcMeta any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateGCObjectProgress", reflect.TypeOf((*MockGCObjectProgressDB)(nil).UpdateGCObjectProgress), gcMeta)
}

// MockSignatureDB is a mock of SignatureDB interface.
type MockSignatureDB struct {
	ctrl     *gomock.Controller
	recorder *MockSignatureDBMockRecorder
}

// MockSignatureDBMockRecorder is the mock recorder for MockSignatureDB.
type MockSignatureDBMockRecorder struct {
	mock *MockSignatureDB
}

// NewMockSignatureDB creates a new mock instance.
func NewMockSignatureDB(ctrl *gomock.Controller) *MockSignatureDB {
	mock := &MockSignatureDB{ctrl: ctrl}
	mock.recorder = &MockSignatureDBMockRecorder{mock}
	return mock
}

// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockSignatureDB) EXPECT() *MockSignatureDBMockRecorder {
	return m.recorder
}

// DeleteAllReplicatePieceChecksum mocks base method.
func (m *MockSignatureDB) DeleteAllReplicatePieceChecksum(objectID uint64, redundancyIdx int32, pieceCount uint32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteAllReplicatePieceChecksum", objectID, redundancyIdx, pieceCount)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteAllReplicatePieceChecksum indicates an expected call of DeleteAllReplicatePieceChecksum.
func (mr *MockSignatureDBMockRecorder) DeleteAllReplicatePieceChecksum(objectID, redundancyIdx, pieceCount any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteAllReplicatePieceChecksum", reflect.TypeOf((*MockSignatureDB)(nil).DeleteAllReplicatePieceChecksum), objectID, redundancyIdx, pieceCount)
}

// DeleteAllReplicatePieceChecksumOptimized mocks base method.
func (m *MockSignatureDB) DeleteAllReplicatePieceChecksumOptimized(objectID uint64, redundancyIdx int32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteAllReplicatePieceChecksumOptimized", objectID, redundancyIdx)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteAllReplicatePieceChecksumOptimized indicates an expected call of DeleteAllReplicatePieceChecksumOptimized.
func (mr *MockSignatureDBMockRecorder) DeleteAllReplicatePieceChecksumOptimized(objectID, redundancyIdx any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteAllReplicatePieceChecksumOptimized", reflect.TypeOf((*MockSignatureDB)(nil).DeleteAllReplicatePieceChecksumOptimized), objectID, redundancyIdx)
}

// DeleteObjectIntegrity mocks base method.
func (m *MockSignatureDB) DeleteObjectIntegrity(objectID uint64, redundancyIndex int32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteObjectIntegrity", objectID, redundancyIndex)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteObjectIntegrity indicates an expected call of DeleteObjectIntegrity.
func (mr *MockSignatureDBMockRecorder) DeleteObjectIntegrity(objectID, redundancyIndex any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteObjectIntegrity", reflect.TypeOf((*MockSignatureDB)(nil).DeleteObjectIntegrity), objectID, redundancyIndex)
}

// DeleteReplicatePieceChecksum mocks base method.
func (m *MockSignatureDB) DeleteReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteReplicatePieceChecksum", objectID, segmentIdx, redundancyIdx)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteReplicatePieceChecksum indicates an expected call of DeleteReplicatePieceChecksum.
func (mr *MockSignatureDBMockRecorder) DeleteReplicatePieceChecksum(objectID, segmentIdx, redundancyIdx any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteReplicatePieceChecksum", reflect.TypeOf((*MockSignatureDB)(nil).DeleteReplicatePieceChecksum), objectID, segmentIdx, redundancyIdx)
}

// DeleteReplicatePieceChecksumsByObjectID mocks base method.
func (m *MockSignatureDB) DeleteReplicatePieceChecksumsByObjectID(objectID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteReplicatePieceChecksumsByObjectID", objectID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteReplicatePieceChecksumsByObjectID indicates an expected call of DeleteReplicatePieceChecksumsByObjectID.
func (mr *MockSignatureDBMockRecorder) DeleteReplicatePieceChecksumsByObjectID(objectID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteReplicatePieceChecksumsByObjectID", reflect.TypeOf((*MockSignatureDB)(nil).DeleteReplicatePieceChecksumsByObjectID), objectID)
}

// DeleteShadowObjectIntegrity mocks base method.
func (m *MockSignatureDB) DeleteShadowObjectIntegrity(objectID uint64, redundancyIndex int32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteShadowObjectIntegrity", objectID, redundancyIndex)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteShadowObjectIntegrity indicates an expected call of DeleteShadowObjectIntegrity.
func (mr *MockSignatureDBMockRecorder) DeleteShadowObjectIntegrity(objectID, redundancyIndex any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteShadowObjectIntegrity", reflect.TypeOf((*MockSignatureDB)(nil).DeleteShadowObjectIntegrity), objectID, redundancyIndex)
}

// GetAllReplicatePieceChecksum mocks base method.
func (m *MockSignatureDB) GetAllReplicatePieceChecksum(objectID uint64, redundancyIdx int32, pieceCount uint32) ([][]byte, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetAllReplicatePieceChecksum", objectID, redundancyIdx, pieceCount)
	ret0, _ := ret[0].([][]byte)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetAllReplicatePieceChecksum indicates an expected call of GetAllReplicatePieceChecksum.
func (mr *MockSignatureDBMockRecorder) GetAllReplicatePieceChecksum(objectID, redundancyIdx, pieceCount any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetAllReplicatePieceChecksum", reflect.TypeOf((*MockSignatureDB)(nil).GetAllReplicatePieceChecksum), objectID, redundancyIdx, pieceCount)
}

// GetAllReplicatePieceChecksumOptimized mocks base method.
func (m *MockSignatureDB) GetAllReplicatePieceChecksumOptimized(objectID uint64, redundancyIdx int32, pieceCount uint32) ([][]byte, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetAllReplicatePieceChecksumOptimized", objectID, redundancyIdx, pieceCount)
	ret0, _ := ret[0].([][]byte)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetAllReplicatePieceChecksumOptimized indicates an expected call of GetAllReplicatePieceChecksumOptimized.
func (mr *MockSignatureDBMockRecorder) GetAllReplicatePieceChecksumOptimized(objectID, redundancyIdx, pieceCount any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetAllReplicatePieceChecksumOptimized", reflect.TypeOf((*MockSignatureDB)(nil).GetAllReplicatePieceChecksumOptimized), objectID, redundancyIdx, pieceCount)
}

// GetObjectIntegrity mocks base method.
func (m *MockSignatureDB) GetObjectIntegrity(objectID uint64, redundancyIndex int32) (*IntegrityMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetObjectIntegrity", objectID, redundancyIndex)
	ret0, _ := ret[0].(*IntegrityMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetObjectIntegrity indicates an expected call of GetObjectIntegrity.
func (mr *MockSignatureDBMockRecorder) GetObjectIntegrity(objectID, redundancyIndex any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetObjectIntegrity", reflect.TypeOf((*MockSignatureDB)(nil).GetObjectIntegrity), objectID, redundancyIndex)
}

// GetReplicatePieceChecksum mocks base method.
func (m *MockSignatureDB) GetReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32) ([]byte, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetReplicatePieceChecksum", objectID, segmentIdx, redundancyIdx)
	ret0, _ := ret[0].([]byte)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetReplicatePieceChecksum indicates an expected call of GetReplicatePieceChecksum.
func (mr *MockSignatureDBMockRecorder) GetReplicatePieceChecksum(objectID, segmentIdx, redundancyIdx any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetReplicatePieceChecksum", reflect.TypeOf((*MockSignatureDB)(nil).GetReplicatePieceChecksum), objectID, segmentIdx, redundancyIdx)
}

// GetShadowObjectIntegrity mocks base method.
func (m *MockSignatureDB) GetShadowObjectIntegrity(objectID uint64, redundancyIndex int32) (*ShadowIntegrityMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetShadowObjectIntegrity", objectID, redundancyIndex)
	ret0, _ := ret[0].(*ShadowIntegrityMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetShadowObjectIntegrity indicates an expected call of GetShadowObjectIntegrity.
func (mr *MockSignatureDBMockRecorder) GetShadowObjectIntegrity(objectID, redundancyIndex any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetShadowObjectIntegrity", reflect.TypeOf((*MockSignatureDB)(nil).GetShadowObjectIntegrity), objectID, redundancyIndex)
}

// ListIntegrityMetaByObjectIDRange mocks base method.
func (m *MockSignatureDB) ListIntegrityMetaByObjectIDRange(startObjectID, endObjectID int64, includePrivate bool) ([]*IntegrityMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListIntegrityMetaByObjectIDRange", startObjectID, endObjectID, includePrivate)
	ret0, _ := ret[0].([]*IntegrityMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListIntegrityMetaByObjectIDRange indicates an expected call of ListIntegrityMetaByObjectIDRange.
func (mr *MockSignatureDBMockRecorder) ListIntegrityMetaByObjectIDRange(startObjectID, endObjectID, includePrivate any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListIntegrityMetaByObjectIDRange", reflect.TypeOf((*MockSignatureDB)(nil).ListIntegrityMetaByObjectIDRange), startObjectID, endObjectID, includePrivate)
}

// ListReplicatePieceChecksumByObjectIDRange mocks base method.
func (m *MockSignatureDB) ListReplicatePieceChecksumByObjectIDRange(startObjectID, endObjectID int64) ([]*GCPieceMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListReplicatePieceChecksumByObjectIDRange", startObjectID, endObjectID)
	ret0, _ := ret[0].([]*GCPieceMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListReplicatePieceChecksumByObjectIDRange indicates an expected call of ListReplicatePieceChecksumByObjectIDRange.
func (mr *MockSignatureDBMockRecorder) ListReplicatePieceChecksumByObjectIDRange(startObjectID, endObjectID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListReplicatePieceChecksumByObjectIDRange", reflect.TypeOf((*MockSignatureDB)(nil).ListReplicatePieceChecksumByObjectIDRange), startObjectID, endObjectID)
}

// ListShadowIntegrityMeta mocks base method.
func (m *MockSignatureDB) ListShadowIntegrityMeta() ([]*ShadowIntegrityMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListShadowIntegrityMeta")
	ret0, _ := ret[0].([]*ShadowIntegrityMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListShadowIntegrityMeta indicates an expected call of ListShadowIntegrityMeta.
func (mr *MockSignatureDBMockRecorder) ListShadowIntegrityMeta() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListShadowIntegrityMeta", reflect.TypeOf((*MockSignatureDB)(nil).ListShadowIntegrityMeta))
}

// SetObjectIntegrity mocks base method.
func (m *MockSignatureDB) SetObjectIntegrity(integrity *IntegrityMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "SetObjectIntegrity", integrity)
	ret0, _ := ret[0].(error)
	return ret0
}

// SetObjectIntegrity indicates an expected call of SetObjectIntegrity.
func (mr *MockSignatureDBMockRecorder) SetObjectIntegrity(integrity any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetObjectIntegrity", reflect.TypeOf((*MockSignatureDB)(nil).SetObjectIntegrity), integrity)
}

// SetReplicatePieceChecksum mocks base method.
func (m *MockSignatureDB) SetReplicatePieceChecksum(objectID uint64, segmentIdx uint32, redundancyIdx int32, checksum []byte, version int64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "SetReplicatePieceChecksum", objectID, segmentIdx, redundancyIdx, checksum, version)
	ret0, _ := ret[0].(error)
	return ret0
}

// SetReplicatePieceChecksum indicates an expected call of SetReplicatePieceChecksum.
func (mr *MockSignatureDBMockRecorder) SetReplicatePieceChecksum(objectID, segmentIdx, redundancyIdx, checksum, version any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetReplicatePieceChecksum", reflect.TypeOf((*MockSignatureDB)(nil).SetReplicatePieceChecksum), objectID, segmentIdx, redundancyIdx, checksum, version)
}

// SetShadowObjectIntegrity mocks base method.
func (m *MockSignatureDB) SetShadowObjectIntegrity(integrity *ShadowIntegrityMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "SetShadowObjectIntegrity", integrity)
	ret0, _ := ret[0].(error)
	return ret0
}

// SetShadowObjectIntegrity indicates an expected call of SetShadowObjectIntegrity.
func (mr *MockSignatureDBMockRecorder) SetShadowObjectIntegrity(integrity any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetShadowObjectIntegrity", reflect.TypeOf((*MockSignatureDB)(nil).SetShadowObjectIntegrity), integrity)
}

// UpdateIntegrityChecksum mocks base method.
func (m *MockSignatureDB) UpdateIntegrityChecksum(integrity *IntegrityMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateIntegrityChecksum", integrity)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateIntegrityChecksum indicates an expected call of UpdateIntegrityChecksum.
func (mr *MockSignatureDBMockRecorder) UpdateIntegrityChecksum(integrity any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateIntegrityChecksum", reflect.TypeOf((*MockSignatureDB)(nil).UpdateIntegrityChecksum), integrity)
}

// UpdateIntegrityMeta mocks base method.
func (m *MockSignatureDB) UpdateIntegrityMeta(integrity *IntegrityMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateIntegrityMeta", integrity)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateIntegrityMeta indicates an expected call of UpdateIntegrityMeta.
func (mr *MockSignatureDBMockRecorder) UpdateIntegrityMeta(integrity any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateIntegrityMeta", reflect.TypeOf((*MockSignatureDB)(nil).UpdateIntegrityMeta), integrity)
}

// UpdatePieceChecksum mocks base method.
func (m *MockSignatureDB) UpdatePieceChecksum(objectID uint64, redundancyIndex int32, checksum []byte, dataLength uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdatePieceChecksum", objectID, redundancyIndex, checksum, dataLength)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdatePieceChecksum indicates an expected call of UpdatePieceChecksum.
func (mr *MockSignatureDBMockRecorder) UpdatePieceChecksum(objectID, redundancyIndex, checksum, dataLength any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdatePieceChecksum", reflect.TypeOf((*MockSignatureDB)(nil).UpdatePieceChecksum), objectID, redundancyIndex, checksum, dataLength)
}

// UpdateShadowIntegrityChecksum mocks base method.
func (m *MockSignatureDB) UpdateShadowIntegrityChecksum(integrity *ShadowIntegrityMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateShadowIntegrityChecksum", integrity)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateShadowIntegrityChecksum indicates an expected call of UpdateShadowIntegrityChecksum.
func (mr *MockSignatureDBMockRecorder) UpdateShadowIntegrityChecksum(integrity any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateShadowIntegrityChecksum", reflect.TypeOf((*MockSignatureDB)(nil).UpdateShadowIntegrityChecksum), integrity)
}

// UpdateShadowPieceChecksum mocks base method.
func (m *MockSignatureDB) UpdateShadowPieceChecksum(objectID uint64, redundancyIndex int32, checksum []byte, version int64, dataLength uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateShadowPieceChecksum", objectID, redundancyIndex, checksum, version, dataLength)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateShadowPieceChecksum indicates an expected call of UpdateShadowPieceChecksum.
func (mr *MockSignatureDBMockRecorder) UpdateShadowPieceChecksum(objectID, redundancyIndex, checksum, version, dataLength any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateShadowPieceChecksum", reflect.TypeOf((*MockSignatureDB)(nil).UpdateShadowPieceChecksum), objectID, redundancyIndex, checksum, version, dataLength)
}

// MockTrafficDB is a mock of TrafficDB interface.
type MockTrafficDB struct {
	ctrl     *gomock.Controller
	recorder *MockTrafficDBMockRecorder
}

// MockTrafficDBMockRecorder is the mock recorder for MockTrafficDB.
type MockTrafficDBMockRecorder struct {
	mock *MockTrafficDB
}

// NewMockTrafficDB creates a new mock instance.
func NewMockTrafficDB(ctrl *gomock.Controller) *MockTrafficDB {
	mock := &MockTrafficDB{ctrl: ctrl}
	mock.recorder = &MockTrafficDBMockRecorder{mock}
	return mock
}

// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockTrafficDB) EXPECT() *MockTrafficDBMockRecorder {
	return m.recorder
}

// CheckQuotaAndAddReadRecord mocks base method.
func (m *MockTrafficDB) CheckQuotaAndAddReadRecord(record *ReadRecord, quota *BucketQuota) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CheckQuotaAndAddReadRecord", record, quota)
	ret0, _ := ret[0].(error)
	return ret0
}

// CheckQuotaAndAddReadRecord indicates an expected call of CheckQuotaAndAddReadRecord.
func (mr *MockTrafficDBMockRecorder) CheckQuotaAndAddReadRecord(record, quota any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CheckQuotaAndAddReadRecord", reflect.TypeOf((*MockTrafficDB)(nil).CheckQuotaAndAddReadRecord), record, quota)
}

// DeleteExpiredBucketTraffic mocks base method.
func (m *MockTrafficDB) DeleteExpiredBucketTraffic(yearMonth string) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteExpiredBucketTraffic", yearMonth)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteExpiredBucketTraffic indicates an expected call of DeleteExpiredBucketTraffic.
func (mr *MockTrafficDBMockRecorder) DeleteExpiredBucketTraffic(yearMonth any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteExpiredBucketTraffic", reflect.TypeOf((*MockTrafficDB)(nil).DeleteExpiredBucketTraffic), yearMonth)
}

// DeleteExpiredReadRecord mocks base method.
func (m *MockTrafficDB) DeleteExpiredReadRecord(ts, limit uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteExpiredReadRecord", ts, limit)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteExpiredReadRecord indicates an expected call of DeleteExpiredReadRecord.
func (mr *MockTrafficDBMockRecorder) DeleteExpiredReadRecord(ts, limit any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteExpiredReadRecord", reflect.TypeOf((*MockTrafficDB)(nil).DeleteExpiredReadRecord), ts, limit)
}

// GetBucketReadRecord mocks base method.
func (m *MockTrafficDB) GetBucketReadRecord(bucketID uint64, timeRange *TrafficTimeRange) ([]*ReadRecord, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetBucketReadRecord", bucketID, timeRange)
	ret0, _ := ret[0].([]*ReadRecord)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetBucketReadRecord indicates an expected call of GetBucketReadRecord.
func (mr *MockTrafficDBMockRecorder) GetBucketReadRecord(bucketID, timeRange any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetBucketReadRecord", reflect.TypeOf((*MockTrafficDB)(nil).GetBucketReadRecord), bucketID, timeRange)
}

// GetBucketTraffic mocks base method.
func (m *MockTrafficDB) GetBucketTraffic(bucketID uint64, yearMonth string) (*BucketTraffic, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetBucketTraffic", bucketID, yearMonth)
	ret0, _ := ret[0].(*BucketTraffic)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetBucketTraffic indicates an expected call of GetBucketTraffic.
func (mr *MockTrafficDBMockRecorder) GetBucketTraffic(bucketID, yearMonth any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetBucketTraffic", reflect.TypeOf((*MockTrafficDB)(nil).GetBucketTraffic), bucketID, yearMonth)
}

// GetBucketTrafficCount mocks base method.
func (m *MockTrafficDB) GetBucketTrafficCount(yearMonth string) (int64, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetBucketTrafficCount", yearMonth)
	ret0, _ := ret[0].(int64)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetBucketTrafficCount indicates an expected call of GetBucketTrafficCount.
func (mr *MockTrafficDBMockRecorder) GetBucketTrafficCount(yearMonth any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetBucketTrafficCount", reflect.TypeOf((*MockTrafficDB)(nil).GetBucketTrafficCount), yearMonth)
}

// GetLatestBucketTraffic mocks base method.
func (m *MockTrafficDB) GetLatestBucketTraffic(bucketID uint64) (*BucketTraffic, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetLatestBucketTraffic", bucketID)
	ret0, _ := ret[0].(*BucketTraffic)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetLatestBucketTraffic indicates an expected call of GetLatestBucketTraffic.
func (mr *MockTrafficDBMockRecorder) GetLatestBucketTraffic(bucketID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetLatestBucketTraffic", reflect.TypeOf((*MockTrafficDB)(nil).GetLatestBucketTraffic), bucketID)
}

// GetObjectReadRecord mocks base method.
func (m *MockTrafficDB) GetObjectReadRecord(objectID uint64, timeRange *TrafficTimeRange) ([]*ReadRecord, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetObjectReadRecord", objectID, timeRange)
	ret0, _ := ret[0].([]*ReadRecord)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetObjectReadRecord indicates an expected call of GetObjectReadRecord.
func (mr *MockTrafficDBMockRecorder) GetObjectReadRecord(objectID, timeRange any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetObjectReadRecord", reflect.TypeOf((*MockTrafficDB)(nil).GetObjectReadRecord), objectID, timeRange)
}

// GetReadRecord mocks base method.
func (m *MockTrafficDB) GetReadRecord(timeRange *TrafficTimeRange) ([]*ReadRecord, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetReadRecord", timeRange)
	ret0, _ := ret[0].([]*ReadRecord)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetReadRecord indicates an expected call of GetReadRecord.
func (mr *MockTrafficDBMockRecorder) GetReadRecord(timeRange any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetReadRecord", reflect.TypeOf((*MockTrafficDB)(nil).GetReadRecord), timeRange)
}

// GetUserReadRecord mocks base method.
func (m *MockTrafficDB) GetUserReadRecord(userAddress string, timeRange *TrafficTimeRange) ([]*ReadRecord, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetUserReadRecord", userAddress, timeRange)
	ret0, _ := ret[0].([]*ReadRecord)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetUserReadRecord indicates an expected call of GetUserReadRecord.
func (mr *MockTrafficDBMockRecorder) GetUserReadRecord(userAddress, timeRange any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUserReadRecord", reflect.TypeOf((*MockTrafficDB)(nil).GetUserReadRecord), userAddress, timeRange)
}

// InitBucketTraffic mocks base method.
func (m *MockTrafficDB) InitBucketTraffic(record *ReadRecord, quota *BucketQuota) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InitBucketTraffic", record, quota)
	ret0, _ := ret[0].(error)
	return ret0
}

// InitBucketTraffic indicates an expected call of InitBucketTraffic.
func (mr *MockTrafficDBMockRecorder) InitBucketTraffic(record, quota any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InitBucketTraffic", reflect.TypeOf((*MockTrafficDB)(nil).InitBucketTraffic), record, quota)
}

// ListBucketTraffic mocks base method.
func (m *MockTrafficDB) ListBucketTraffic(yearMonth string, offset, limit int) ([]*BucketTraffic, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListBucketTraffic", yearMonth, offset, limit)
	ret0, _ := ret[0].([]*BucketTraffic)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListBucketTraffic indicates an expected call of ListBucketTraffic.
func (mr *MockTrafficDBMockRecorder) ListBucketTraffic(yearMonth, offset, limit any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListBucketTraffic", reflect.TypeOf((*MockTrafficDB)(nil).ListBucketTraffic), yearMonth, offset, limit)
}

// UpdateBucketTraffic mocks base method.
func (m *MockTrafficDB) UpdateBucketTraffic(bucketID uint64, update *BucketTraffic) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketTraffic", bucketID, update)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketTraffic indicates an expected call of UpdateBucketTraffic.
func (mr *MockTrafficDBMockRecorder) UpdateBucketTraffic(bucketID, update any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketTraffic", reflect.TypeOf((*MockTrafficDB)(nil).UpdateBucketTraffic), bucketID, update)
}

// UpdateExtraQuota mocks base method.
func (m *MockTrafficDB) UpdateExtraQuota(bucketID, extraQuota uint64, yearMonth string) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateExtraQuota", bucketID, extraQuota, yearMonth)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateExtraQuota indicates an expected call of UpdateExtraQuota.
func (mr *MockTrafficDBMockRecorder) UpdateExtraQuota(bucketID, extraQuota, yearMonth any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateExtraQuota", reflect.TypeOf((*MockTrafficDB)(nil).UpdateExtraQuota), bucketID, extraQuota, yearMonth)
}

// MockSPInfoDB is a mock of SPInfoDB interface.
type MockSPInfoDB struct {
	ctrl     *gomock.Controller
	recorder *MockSPInfoDBMockRecorder
}

// MockSPInfoDBMockRecorder is the mock recorder for MockSPInfoDB.
type MockSPInfoDBMockRecorder struct {
	mock *MockSPInfoDB
}

// NewMockSPInfoDB creates a new mock instance.
func NewMockSPInfoDB(ctrl *gomock.Controller) *MockSPInfoDB {
	mock := &MockSPInfoDB{ctrl: ctrl}
	mock.recorder = &MockSPInfoDBMockRecorder{mock}
	return mock
}

// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockSPInfoDB) EXPECT() *MockSPInfoDBMockRecorder {
	return m.recorder
}

// FetchAllSp mocks base method.
func (m *MockSPInfoDB) FetchAllSp(status ...types0.Status) ([]*types0.StorageProvider, error) {
	m.ctrl.T.Helper()
	varargs := []any{}
	for _, a := range status {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "FetchAllSp", varargs...)
	ret0, _ := ret[0].([]*types0.StorageProvider)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// FetchAllSp indicates an expected call of FetchAllSp.
func (mr *MockSPInfoDBMockRecorder) FetchAllSp(status ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "FetchAllSp", reflect.TypeOf((*MockSPInfoDB)(nil).FetchAllSp), status...)
}

// FetchAllSpWithoutOwnSp mocks base method.
func (m *MockSPInfoDB) FetchAllSpWithoutOwnSp(status ...types0.Status) ([]*types0.StorageProvider, error) {
	m.ctrl.T.Helper()
	varargs := []any{}
	for _, a := range status {
		varargs = append(varargs, a)
	}
	ret := m.ctrl.Call(m, "FetchAllSpWithoutOwnSp", varargs...)
	ret0, _ := ret[0].([]*types0.StorageProvider)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// FetchAllSpWithoutOwnSp indicates an expected call of FetchAllSpWithoutOwnSp.
func (mr *MockSPInfoDBMockRecorder) FetchAllSpWithoutOwnSp(status ...any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "FetchAllSpWithoutOwnSp", reflect.TypeOf((*MockSPInfoDB)(nil).FetchAllSpWithoutOwnSp), status...)
}

// GetOwnSpInfo mocks base method.
func (m *MockSPInfoDB) GetOwnSpInfo() (*types0.StorageProvider, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetOwnSpInfo")
	ret0, _ := ret[0].(*types0.StorageProvider)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetOwnSpInfo indicates an expected call of GetOwnSpInfo.
func (mr *MockSPInfoDBMockRecorder) GetOwnSpInfo() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetOwnSpInfo", reflect.TypeOf((*MockSPInfoDB)(nil).GetOwnSpInfo))
}

// GetSpByAddress mocks base method.
func (m *MockSPInfoDB) GetSpByAddress(address string, addressType SpAddressType) (*types0.StorageProvider, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetSpByAddress", address, addressType)
	ret0, _ := ret[0].(*types0.StorageProvider)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetSpByAddress indicates an expected call of GetSpByAddress.
func (mr *MockSPInfoDBMockRecorder) GetSpByAddress(address, addressType any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetSpByAddress", reflect.TypeOf((*MockSPInfoDB)(nil).GetSpByAddress), address, addressType)
}

// GetSpByEndpoint mocks base method.
func (m *MockSPInfoDB) GetSpByEndpoint(endpoint string) (*types0.StorageProvider, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetSpByEndpoint", endpoint)
	ret0, _ := ret[0].(*types0.StorageProvider)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetSpByEndpoint indicates an expected call of GetSpByEndpoint.
func (mr *MockSPInfoDBMockRecorder) GetSpByEndpoint(endpoint any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetSpByEndpoint", reflect.TypeOf((*MockSPInfoDB)(nil).GetSpByEndpoint), endpoint)
}

// GetSpByID mocks base method.
func (m *MockSPInfoDB) GetSpByID(id uint32) (*types0.StorageProvider, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetSpByID", id)
	ret0, _ := ret[0].(*types0.StorageProvider)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetSpByID indicates an expected call of GetSpByID.
func (mr *MockSPInfoDBMockRecorder) GetSpByID(id any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetSpByID", reflect.TypeOf((*MockSPInfoDB)(nil).GetSpByID), id)
}

// SetOwnSpInfo mocks base method.
func (m *MockSPInfoDB) SetOwnSpInfo(sp *types0.StorageProvider) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "SetOwnSpInfo", sp)
	ret0, _ := ret[0].(error)
	return ret0
}

// SetOwnSpInfo indicates an expected call of SetOwnSpInfo.
func (mr *MockSPInfoDBMockRecorder) SetOwnSpInfo(sp any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetOwnSpInfo", reflect.TypeOf((*MockSPInfoDB)(nil).SetOwnSpInfo), sp)
}

// UpdateAllSp mocks base method.
func (m *MockSPInfoDB) UpdateAllSp(spList []*types0.StorageProvider) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateAllSp", spList)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateAllSp indicates an expected call of UpdateAllSp.
func (mr *MockSPInfoDBMockRecorder) UpdateAllSp(spList any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateAllSp", reflect.TypeOf((*MockSPInfoDB)(nil).UpdateAllSp), spList)
}

// MockOffChainAuthKeyDB is a mock of OffChainAuthKeyDB interface.
type MockOffChainAuthKeyDB struct {
	ctrl     *gomock.Controller
	recorder *MockOffChainAuthKeyDBMockRecorder
}

// MockOffChainAuthKeyDBMockRecorder is the mock recorder for MockOffChainAuthKeyDB.
type MockOffChainAuthKeyDBMockRecorder struct {
	mock *MockOffChainAuthKeyDB
}

// NewMockOffChainAuthKeyDB creates a new mock instance.
func NewMockOffChainAuthKeyDB(ctrl *gomock.Controller) *MockOffChainAuthKeyDB {
	mock := &MockOffChainAuthKeyDB{ctrl: ctrl}
	mock.recorder = &MockOffChainAuthKeyDBMockRecorder{mock}
	return mock
}

// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockOffChainAuthKeyDB) EXPECT() *MockOffChainAuthKeyDBMockRecorder {
	return m.recorder
}

// GetAuthKey mocks base method.
func (m *MockOffChainAuthKeyDB) GetAuthKey(userAddress, domain string) (*OffChainAuthKey, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetAuthKey", userAddress, domain)
	ret0, _ := ret[0].(*OffChainAuthKey)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetAuthKey indicates an expected call of GetAuthKey.
func (mr *MockOffChainAuthKeyDBMockRecorder) GetAuthKey(userAddress, domain any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetAuthKey", reflect.TypeOf((*MockOffChainAuthKeyDB)(nil).GetAuthKey), userAddress, domain)
}

// InsertAuthKey mocks base method.
func (m *MockOffChainAuthKeyDB) InsertAuthKey(newRecord *OffChainAuthKey) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertAuthKey", newRecord)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertAuthKey indicates an expected call of InsertAuthKey.
func (mr *MockOffChainAuthKeyDBMockRecorder) InsertAuthKey(newRecord any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertAuthKey", reflect.TypeOf((*MockOffChainAuthKeyDB)(nil).InsertAuthKey), newRecord)
}

// UpdateAuthKey mocks base method.
func (m *MockOffChainAuthKeyDB) UpdateAuthKey(userAddress, domain string, oldNonce, newNonce int32, newPublicKey string, newExpiryDate time.Time) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateAuthKey", userAddress, domain, oldNonce, newNonce, newPublicKey, newExpiryDate)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateAuthKey indicates an expected call of UpdateAuthKey.
func (mr *MockOffChainAuthKeyDBMockRecorder) UpdateAuthKey(userAddress, domain, oldNonce, newNonce, newPublicKey, newExpiryDate any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateAuthKey", reflect.TypeOf((*MockOffChainAuthKeyDB)(nil).UpdateAuthKey), userAddress, domain, oldNonce, newNonce, newPublicKey, newExpiryDate)
}

// MockOffChainAuthKeyV2DB is a mock of OffChainAuthKeyV2DB interface.
type MockOffChainAuthKeyV2DB struct {
	ctrl     *gomock.Controller
	recorder *MockOffChainAuthKeyV2DBMockRecorder
}

// MockOffChainAuthKeyV2DBMockRecorder is the mock recorder for MockOffChainAuthKeyV2DB.
type MockOffChainAuthKeyV2DBMockRecorder struct {
	mock *MockOffChainAuthKeyV2DB
}

// NewMockOffChainAuthKeyV2DB creates a new mock instance.
func NewMockOffChainAuthKeyV2DB(ctrl *gomock.Controller) *MockOffChainAuthKeyV2DB {
	mock := &MockOffChainAuthKeyV2DB{ctrl: ctrl}
	mock.recorder = &MockOffChainAuthKeyV2DBMockRecorder{mock}
	return mock
}

// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockOffChainAuthKeyV2DB) EXPECT() *MockOffChainAuthKeyV2DBMockRecorder {
	return m.recorder
}

// ClearExpiredOffChainAuthKeys mocks base method.
func (m *MockOffChainAuthKeyV2DB) ClearExpiredOffChainAuthKeys() error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ClearExpiredOffChainAuthKeys")
	ret0, _ := ret[0].(error)
	return ret0
}

// ClearExpiredOffChainAuthKeys indicates an expected call of ClearExpiredOffChainAuthKeys.
func (mr *MockOffChainAuthKeyV2DBMockRecorder) ClearExpiredOffChainAuthKeys() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ClearExpiredOffChainAuthKeys", reflect.TypeOf((*MockOffChainAuthKeyV2DB)(nil).ClearExpiredOffChainAuthKeys))
}

// DeleteAuthKeysV2 mocks base method.
func (m *MockOffChainAuthKeyV2DB) DeleteAuthKeysV2(userAddress, domain string, publicKey []string) (bool, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteAuthKeysV2", userAddress, domain, publicKey)
	ret0, _ := ret[0].(bool)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// DeleteAuthKeysV2 indicates an expected call of DeleteAuthKeysV2.
func (mr *MockOffChainAuthKeyV2DBMockRecorder) DeleteAuthKeysV2(userAddress, domain, publicKey any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteAuthKeysV2", reflect.TypeOf((*MockOffChainAuthKeyV2DB)(nil).DeleteAuthKeysV2), userAddress, domain, publicKey)
}

// GetAuthKeyV2 mocks base method.
func (m *MockOffChainAuthKeyV2DB) GetAuthKeyV2(userAddress, domain, publicKey string) (*OffChainAuthKeyV2, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetAuthKeyV2", userAddress, domain, publicKey)
	ret0, _ := ret[0].(*OffChainAuthKeyV2)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetAuthKeyV2 indicates an expected call of GetAuthKeyV2.
func (mr *MockOffChainAuthKeyV2DBMockRecorder) GetAuthKeyV2(userAddress, domain, publicKey any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetAuthKeyV2", reflect.TypeOf((*MockOffChainAuthKeyV2DB)(nil).GetAuthKeyV2), userAddress, domain, publicKey)
}

// InsertAuthKeyV2 mocks base method.
func (m *MockOffChainAuthKeyV2DB) InsertAuthKeyV2(newRecord *OffChainAuthKeyV2) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertAuthKeyV2", newRecord)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertAuthKeyV2 indicates an expected call of InsertAuthKeyV2.
func (mr *MockOffChainAuthKeyV2DBMockRecorder) InsertAuthKeyV2(newRecord any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertAuthKeyV2", reflect.TypeOf((*MockOffChainAuthKeyV2DB)(nil).InsertAuthKeyV2), newRecord)
}

// ListAuthKeysV2 mocks base method.
func (m *MockOffChainAuthKeyV2DB) ListAuthKeysV2(userAddress, domain string) ([]string, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListAuthKeysV2", userAddress, domain)
	ret0, _ := ret[0].([]string)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListAuthKeysV2 indicates an expected call of ListAuthKeysV2.
func (mr *MockOffChainAuthKeyV2DBMockRecorder) ListAuthKeysV2(userAddress, domain any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListAuthKeysV2", reflect.TypeOf((*MockOffChainAuthKeyV2DB)(nil).ListAuthKeysV2), userAddress, domain)
}

// MockMigrateDB is a mock of MigrateDB interface.
type MockMigrateDB struct {
	ctrl     *gomock.Controller
	recorder *MockMigrateDBMockRecorder
}

// MockMigrateDBMockRecorder is the mock recorder for MockMigrateDB.
type MockMigrateDBMockRecorder struct {
	mock *MockMigrateDB
}

// NewMockMigrateDB creates a new mock instance.
func NewMockMigrateDB(ctrl *gomock.Controller) *MockMigrateDB {
	mock := &MockMigrateDB{ctrl: ctrl}
	mock.recorder = &MockMigrateDBMockRecorder{mock}
	return mock
}

// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockMigrateDB) EXPECT() *MockMigrateDBMockRecorder {
	return m.recorder
}

// DeleteMigrateBucket mocks base method.
func (m *MockMigrateDB) DeleteMigrateBucket(bucketID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteMigrateBucket", bucketID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteMigrateBucket indicates an expected call of DeleteMigrateBucket.
func (mr *MockMigrateDBMockRecorder) DeleteMigrateBucket(bucketID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteMigrateBucket", reflect.TypeOf((*MockMigrateDB)(nil).DeleteMigrateBucket), bucketID)
}

// DeleteMigrateGVGUnit mocks base method.
func (m *MockMigrateDB) DeleteMigrateGVGUnit(meta *MigrateGVGUnitMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteMigrateGVGUnit", meta)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteMigrateGVGUnit indicates an expected call of DeleteMigrateGVGUnit.
func (mr *MockMigrateDBMockRecorder) DeleteMigrateGVGUnit(meta any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteMigrateGVGUnit", reflect.TypeOf((*MockMigrateDB)(nil).DeleteMigrateGVGUnit), meta)
}

// DeleteMigrateGVGUnitsByBucketID mocks base method.
func (m *MockMigrateDB) DeleteMigrateGVGUnitsByBucketID(bucketID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteMigrateGVGUnitsByBucketID", bucketID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteMigrateGVGUnitsByBucketID indicates an expected call of DeleteMigrateGVGUnitsByBucketID.
func (mr *MockMigrateDBMockRecorder) DeleteMigrateGVGUnitsByBucketID(bucketID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteMigrateGVGUnitsByBucketID", reflect.TypeOf((*MockMigrateDB)(nil).DeleteMigrateGVGUnitsByBucketID), bucketID)
}

// InsertMigrateGVGUnit mocks base method.
func (m *MockMigrateDB) InsertMigrateGVGUnit(meta *MigrateGVGUnitMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertMigrateGVGUnit", meta)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertMigrateGVGUnit indicates an expected call of InsertMigrateGVGUnit.
func (mr *MockMigrateDBMockRecorder) InsertMigrateGVGUnit(meta any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertMigrateGVGUnit", reflect.TypeOf((*MockMigrateDB)(nil).InsertMigrateGVGUnit), meta)
}

// InsertSwapOutUnit mocks base method.
func (m *MockMigrateDB) InsertSwapOutUnit(meta *SwapOutMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertSwapOutUnit", meta)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertSwapOutUnit indicates an expected call of InsertSwapOutUnit.
func (mr *MockMigrateDBMockRecorder) InsertSwapOutUnit(meta any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertSwapOutUnit", reflect.TypeOf((*MockMigrateDB)(nil).InsertSwapOutUnit), meta)
}

// ListBucketMigrationToConfirm mocks base method.
func (m *MockMigrateDB) ListBucketMigrationToConfirm(migrationStates []int) ([]*MigrateBucketProgressMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListBucketMigrationToConfirm", migrationStates)
	ret0, _ := ret[0].([]*MigrateBucketProgressMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListBucketMigrationToConfirm indicates an expected call of ListBucketMigrationToConfirm.
func (mr *MockMigrateDBMockRecorder) ListBucketMigrationToConfirm(migrationStates any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListBucketMigrationToConfirm", reflect.TypeOf((*MockMigrateDB)(nil).ListBucketMigrationToConfirm), migrationStates)
}

// ListDestSPSwapOutUnits mocks base method.
func (m *MockMigrateDB) ListDestSPSwapOutUnits() ([]*SwapOutMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListDestSPSwapOutUnits")
	ret0, _ := ret[0].([]*SwapOutMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListDestSPSwapOutUnits indicates an expected call of ListDestSPSwapOutUnits.
func (mr *MockMigrateDBMockRecorder) ListDestSPSwapOutUnits() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListDestSPSwapOutUnits", reflect.TypeOf((*MockMigrateDB)(nil).ListDestSPSwapOutUnits))
}

// ListMigrateGVGUnitsByBucketID mocks base method.
func (m *MockMigrateDB) ListMigrateGVGUnitsByBucketID(bucketID uint64) ([]*MigrateGVGUnitMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "ListMigrateGVGUnitsByBucketID", bucketID)
	ret0, _ := ret[0].([]*MigrateGVGUnitMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// ListMigrateGVGUnitsByBucketID indicates an expected call of ListMigrateGVGUnitsByBucketID.
func (mr *MockMigrateDBMockRecorder) ListMigrateGVGUnitsByBucketID(bucketID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListMigrateGVGUnitsByBucketID", reflect.TypeOf((*MockMigrateDB)(nil).ListMigrateGVGUnitsByBucketID), bucketID)
}

// QueryBucketMigrateSubscribeProgress mocks base method.
func (m *MockMigrateDB) QueryBucketMigrateSubscribeProgress() (uint64, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "QueryBucketMigrateSubscribeProgress")
	ret0, _ := ret[0].(uint64)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// QueryBucketMigrateSubscribeProgress indicates an expected call of QueryBucketMigrateSubscribeProgress.
func (mr *MockMigrateDBMockRecorder) QueryBucketMigrateSubscribeProgress() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QueryBucketMigrateSubscribeProgress", reflect.TypeOf((*MockMigrateDB)(nil).QueryBucketMigrateSubscribeProgress))
}

// QueryMigrateBucketProgress mocks base method.
func (m *MockMigrateDB) QueryMigrateBucketProgress(bucketID uint64) (*MigrateBucketProgressMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "QueryMigrateBucketProgress", bucketID)
	ret0, _ := ret[0].(*MigrateBucketProgressMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// QueryMigrateBucketProgress indicates an expected call of QueryMigrateBucketProgress.
func (mr *MockMigrateDBMockRecorder) QueryMigrateBucketProgress(bucketID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QueryMigrateBucketProgress", reflect.TypeOf((*MockMigrateDB)(nil).QueryMigrateBucketProgress), bucketID)
}

// QueryMigrateBucketState mocks base method.
func (m *MockMigrateDB) QueryMigrateBucketState(bucketID uint64) (int, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "QueryMigrateBucketState", bucketID)
	ret0, _ := ret[0].(int)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// QueryMigrateBucketState indicates an expected call of QueryMigrateBucketState.
func (mr *MockMigrateDBMockRecorder) QueryMigrateBucketState(bucketID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QueryMigrateBucketState", reflect.TypeOf((*MockMigrateDB)(nil).QueryMigrateBucketState), bucketID)
}

// QueryMigrateGVGUnit mocks base method.
func (m *MockMigrateDB) QueryMigrateGVGUnit(migrateKey string) (*MigrateGVGUnitMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "QueryMigrateGVGUnit", migrateKey)
	ret0, _ := ret[0].(*MigrateGVGUnitMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// QueryMigrateGVGUnit indicates an expected call of QueryMigrateGVGUnit.
func (mr *MockMigrateDBMockRecorder) QueryMigrateGVGUnit(migrateKey any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QueryMigrateGVGUnit", reflect.TypeOf((*MockMigrateDB)(nil).QueryMigrateGVGUnit), migrateKey)
}

// QuerySPExitSubscribeProgress mocks base method.
func (m *MockMigrateDB) QuerySPExitSubscribeProgress() (uint64, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "QuerySPExitSubscribeProgress")
	ret0, _ := ret[0].(uint64)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// QuerySPExitSubscribeProgress indicates an expected call of QuerySPExitSubscribeProgress.
func (mr *MockMigrateDBMockRecorder) QuerySPExitSubscribeProgress() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QuerySPExitSubscribeProgress", reflect.TypeOf((*MockMigrateDB)(nil).QuerySPExitSubscribeProgress))
}

// QuerySwapOutSubscribeProgress mocks base method.
func (m *MockMigrateDB) QuerySwapOutSubscribeProgress() (uint64, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "QuerySwapOutSubscribeProgress")
	ret0, _ := ret[0].(uint64)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// QuerySwapOutSubscribeProgress indicates an expected call of QuerySwapOutSubscribeProgress.
func (mr *MockMigrateDBMockRecorder) QuerySwapOutSubscribeProgress() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QuerySwapOutSubscribeProgress", reflect.TypeOf((*MockMigrateDB)(nil).QuerySwapOutSubscribeProgress))
}

// QuerySwapOutUnitInSrcSP mocks base method.
func (m *MockMigrateDB) QuerySwapOutUnitInSrcSP(swapOutKey string) (*SwapOutMeta, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "QuerySwapOutUnitInSrcSP", swapOutKey)
	ret0, _ := ret[0].(*SwapOutMeta)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// QuerySwapOutUnitInSrcSP indicates an expected call of QuerySwapOutUnitInSrcSP.
func (mr *MockMigrateDBMockRecorder) QuerySwapOutUnitInSrcSP(swapOutKey any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "QuerySwapOutUnitInSrcSP", reflect.TypeOf((*MockMigrateDB)(nil).QuerySwapOutUnitInSrcSP), swapOutKey)
}

// UpdateBucketMigrateGCSubscribeProgress mocks base method.
func (m *MockMigrateDB) UpdateBucketMigrateGCSubscribeProgress(blockHeight uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketMigrateGCSubscribeProgress", blockHeight)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketMigrateGCSubscribeProgress indicates an expected call of UpdateBucketMigrateGCSubscribeProgress.
func (mr *MockMigrateDBMockRecorder) UpdateBucketMigrateGCSubscribeProgress(blockHeight any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketMigrateGCSubscribeProgress", reflect.TypeOf((*MockMigrateDB)(nil).UpdateBucketMigrateGCSubscribeProgress), blockHeight)
}

// UpdateBucketMigrateSubscribeProgress mocks base method.
func (m *MockMigrateDB) UpdateBucketMigrateSubscribeProgress(blockHeight uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketMigrateSubscribeProgress", blockHeight)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketMigrateSubscribeProgress indicates an expected call of UpdateBucketMigrateSubscribeProgress.
func (mr *MockMigrateDBMockRecorder) UpdateBucketMigrateSubscribeProgress(blockHeight any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketMigrateSubscribeProgress", reflect.TypeOf((*MockMigrateDB)(nil).UpdateBucketMigrateSubscribeProgress), blockHeight)
}

// UpdateBucketMigrationGCProgress mocks base method.
func (m *MockMigrateDB) UpdateBucketMigrationGCProgress(progressMeta MigrateBucketProgressMeta) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketMigrationGCProgress", progressMeta)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketMigrationGCProgress indicates an expected call of UpdateBucketMigrationGCProgress.
func (mr *MockMigrateDBMockRecorder) UpdateBucketMigrationGCProgress(progressMeta any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketMigrationGCProgress", reflect.TypeOf((*MockMigrateDB)(nil).UpdateBucketMigrationGCProgress), progressMeta)
}

// UpdateBucketMigrationMigratingProgress mocks base method.
func (m *MockMigrateDB) UpdateBucketMigrationMigratingProgress(bucketID uint64, gvgUnits, gvgUnitsFinished uint32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketMigrationMigratingProgress", bucketID, gvgUnits, gvgUnitsFinished)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketMigrationMigratingProgress indicates an expected call of UpdateBucketMigrationMigratingProgress.
func (mr *MockMigrateDBMockRecorder) UpdateBucketMigrationMigratingProgress(bucketID, gvgUnits, gvgUnitsFinished any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketMigrationMigratingProgress", reflect.TypeOf((*MockMigrateDB)(nil).UpdateBucketMigrationMigratingProgress), bucketID, gvgUnits, gvgUnitsFinished)
}

// UpdateBucketMigrationPreDeductedQuota mocks base method.
func (m *MockMigrateDB) UpdateBucketMigrationPreDeductedQuota(bucketID, deductedQuota uint64, state int) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketMigrationPreDeductedQuota", bucketID, deductedQuota, state)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketMigrationPreDeductedQuota indicates an expected call of UpdateBucketMigrationPreDeductedQuota.
func (mr *MockMigrateDBMockRecorder) UpdateBucketMigrationPreDeductedQuota(bucketID, deductedQuota, state any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketMigrationPreDeductedQuota", reflect.TypeOf((*MockMigrateDB)(nil).UpdateBucketMigrationPreDeductedQuota), bucketID, deductedQuota, state)
}

// UpdateBucketMigrationProgress mocks base method.
func (m *MockMigrateDB) UpdateBucketMigrationProgress(bucketID uint64, migrateState int) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketMigrationProgress", bucketID, migrateState)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketMigrationProgress indicates an expected call of UpdateBucketMigrationProgress.
func (mr *MockMigrateDBMockRecorder) UpdateBucketMigrationProgress(bucketID, migrateState any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketMigrationProgress", reflect.TypeOf((*MockMigrateDB)(nil).UpdateBucketMigrationProgress), bucketID, migrateState)
}

// UpdateBucketMigrationRecoupQuota mocks base method.
func (m *MockMigrateDB) UpdateBucketMigrationRecoupQuota(bucketID, recoupQuota uint64, state int) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateBucketMigrationRecoupQuota", bucketID, recoupQuota, state)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateBucketMigrationRecoupQuota indicates an expected call of UpdateBucketMigrationRecoupQuota.
func (mr *MockMigrateDBMockRecorder) UpdateBucketMigrationRecoupQuota(bucketID, recoupQuota, state any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBucketMigrationRecoupQuota", reflect.TypeOf((*MockMigrateDB)(nil).UpdateBucketMigrationRecoupQuota), bucketID, recoupQuota, state)
}

// UpdateMigrateGVGMigratedBytesSize mocks base method.
func (m *MockMigrateDB) UpdateMigrateGVGMigratedBytesSize(migrateKey string, migratedBytes uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateMigrateGVGMigratedBytesSize", migrateKey, migratedBytes)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateMigrateGVGMigratedBytesSize indicates an expected call of UpdateMigrateGVGMigratedBytesSize.
func (mr *MockMigrateDBMockRecorder) UpdateMigrateGVGMigratedBytesSize(migrateKey, migratedBytes any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateMigrateGVGMigratedBytesSize", reflect.TypeOf((*MockMigrateDB)(nil).UpdateMigrateGVGMigratedBytesSize), migrateKey, migratedBytes)
}

// UpdateMigrateGVGRetryCount mocks base method.
func (m *MockMigrateDB) UpdateMigrateGVGRetryCount(migrateKey string, retryTime int) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateMigrateGVGRetryCount", migrateKey, retryTime)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateMigrateGVGRetryCount indicates an expected call of UpdateMigrateGVGRetryCount.
func (mr *MockMigrateDBMockRecorder) UpdateMigrateGVGRetryCount(migrateKey, retryTime any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateMigrateGVGRetryCount", reflect.TypeOf((*MockMigrateDB)(nil).UpdateMigrateGVGRetryCount), migrateKey, retryTime)
}

// UpdateMigrateGVGUnitLastMigrateObjectID mocks base method.
func (m *MockMigrateDB) UpdateMigrateGVGUnitLastMigrateObjectID(migrateKey string, lastMigrateObjectID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateMigrateGVGUnitLastMigrateObjectID", migrateKey, lastMigrateObjectID)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateMigrateGVGUnitLastMigrateObjectID indicates an expected call of UpdateMigrateGVGUnitLastMigrateObjectID.
func (mr *MockMigrateDBMockRecorder) UpdateMigrateGVGUnitLastMigrateObjectID(migrateKey, lastMigrateObjectID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateMigrateGVGUnitLastMigrateObjectID", reflect.TypeOf((*MockMigrateDB)(nil).UpdateMigrateGVGUnitLastMigrateObjectID), migrateKey, lastMigrateObjectID)
}

// UpdateMigrateGVGUnitStatus mocks base method.
func (m *MockMigrateDB) UpdateMigrateGVGUnitStatus(migrateKey string, migrateStatus int) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateMigrateGVGUnitStatus", migrateKey, migrateStatus)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateMigrateGVGUnitStatus indicates an expected call of UpdateMigrateGVGUnitStatus.
func (mr *MockMigrateDBMockRecorder) UpdateMigrateGVGUnitStatus(migrateKey, migrateStatus any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateMigrateGVGUnitStatus", reflect.TypeOf((*MockMigrateDB)(nil).UpdateMigrateGVGUnitStatus), migrateKey, migrateStatus)
}

// UpdateSPExitSubscribeProgress mocks base method.
func (m *MockMigrateDB) UpdateSPExitSubscribeProgress(blockHeight uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateSPExitSubscribeProgress", blockHeight)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateSPExitSubscribeProgress indicates an expected call of UpdateSPExitSubscribeProgress.
func (mr *MockMigrateDBMockRecorder) UpdateSPExitSubscribeProgress(blockHeight any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateSPExitSubscribeProgress", reflect.TypeOf((*MockMigrateDB)(nil).UpdateSPExitSubscribeProgress), blockHeight)
}

// UpdateSwapOutSubscribeProgress mocks base method.
func (m *MockMigrateDB) UpdateSwapOutSubscribeProgress(blockHeight uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateSwapOutSubscribeProgress", blockHeight)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateSwapOutSubscribeProgress indicates an expected call of UpdateSwapOutSubscribeProgress.
func (mr *MockMigrateDBMockRecorder) UpdateSwapOutSubscribeProgress(blockHeight any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateSwapOutSubscribeProgress", reflect.TypeOf((*MockMigrateDB)(nil).UpdateSwapOutSubscribeProgress), blockHeight)
}

// UpdateSwapOutUnitCompletedGVGList mocks base method.
func (m *MockMigrateDB) UpdateSwapOutUnitCompletedGVGList(swapOutKey string, completedGVGList []uint32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateSwapOutUnitCompletedGVGList", swapOutKey, completedGVGList)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateSwapOutUnitCompletedGVGList indicates an expected call of UpdateSwapOutUnitCompletedGVGList.
func (mr *MockMigrateDBMockRecorder) UpdateSwapOutUnitCompletedGVGList(swapOutKey, completedGVGList any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateSwapOutUnitCompletedGVGList", reflect.TypeOf((*MockMigrateDB)(nil).UpdateSwapOutUnitCompletedGVGList), swapOutKey, completedGVGList)
}

// MockExitRecoverDB is a mock of ExitRecoverDB interface.
type MockExitRecoverDB struct {
	ctrl     *gomock.Controller
	recorder *MockExitRecoverDBMockRecorder
}

// MockExitRecoverDBMockRecorder is the mock recorder for MockExitRecoverDB.
type MockExitRecoverDBMockRecorder struct {
	mock *MockExitRecoverDB
}

// NewMockExitRecoverDB creates a new mock instance.
func NewMockExitRecoverDB(ctrl *gomock.Controller) *MockExitRecoverDB {
	mock := &MockExitRecoverDB{ctrl: ctrl}
	mock.recorder = &MockExitRecoverDBMockRecorder{mock}
	return mock
}

// EXPECT returns an object that allows the caller to indicate expected use.
func (m *MockExitRecoverDB) EXPECT() *MockExitRecoverDBMockRecorder {
	return m.recorder
}

// BatchGetRecoverGVGStats mocks base method.
func (m *MockExitRecoverDB) BatchGetRecoverGVGStats(gvgID []uint32) ([]*RecoverGVGStats, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "BatchGetRecoverGVGStats", gvgID)
	ret0, _ := ret[0].([]*RecoverGVGStats)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// BatchGetRecoverGVGStats indicates an expected call of BatchGetRecoverGVGStats.
func (mr *MockExitRecoverDBMockRecorder) BatchGetRecoverGVGStats(gvgID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "BatchGetRecoverGVGStats", reflect.TypeOf((*MockExitRecoverDB)(nil).BatchGetRecoverGVGStats), gvgID)
}

// CountRecoverFailedObject mocks base method.
func (m *MockExitRecoverDB) CountRecoverFailedObject() (int64, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "CountRecoverFailedObject")
	ret0, _ := ret[0].(int64)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// CountRecoverFailedObject indicates an expected call of CountRecoverFailedObject.
func (mr *MockExitRecoverDBMockRecorder) CountRecoverFailedObject() *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CountRecoverFailedObject", reflect.TypeOf((*MockExitRecoverDB)(nil).CountRecoverFailedObject))
}

// DeleteRecoverFailedObject mocks base method.
func (m *MockExitRecoverDB) DeleteRecoverFailedObject(objectID uint64) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteRecoverFailedObject", objectID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteRecoverFailedObject indicates an expected call of DeleteRecoverFailedObject.
func (mr *MockExitRecoverDBMockRecorder) DeleteRecoverFailedObject(objectID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteRecoverFailedObject", reflect.TypeOf((*MockExitRecoverDB)(nil).DeleteRecoverFailedObject), objectID)
}

// DeleteRecoverGVGStats mocks base method.
func (m *MockExitRecoverDB) DeleteRecoverGVGStats(gvgID uint32) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "DeleteRecoverGVGStats", gvgID)
	ret0, _ := ret[0].(error)
	return ret0
}

// DeleteRecoverGVGStats indicates an expected call of DeleteRecoverGVGStats.
func (mr *MockExitRecoverDBMockRecorder) DeleteRecoverGVGStats(gvgID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteRecoverGVGStats", reflect.TypeOf((*MockExitRecoverDB)(nil).DeleteRecoverGVGStats), gvgID)
}

// GetRecoverFailedObject mocks base method.
func (m *MockExitRecoverDB) GetRecoverFailedObject(objectID uint64) (*RecoverFailedObject, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetRecoverFailedObject", objectID)
	ret0, _ := ret[0].(*RecoverFailedObject)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetRecoverFailedObject indicates an expected call of GetRecoverFailedObject.
func (mr *MockExitRecoverDBMockRecorder) GetRecoverFailedObject(objectID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetRecoverFailedObject", reflect.TypeOf((*MockExitRecoverDB)(nil).GetRecoverFailedObject), objectID)
}

// GetRecoverFailedObjects mocks base method.
func (m *MockExitRecoverDB) GetRecoverFailedObjects(retry, limit uint32) ([]*RecoverFailedObject, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetRecoverFailedObjects", retry, limit)
	ret0, _ := ret[0].([]*RecoverFailedObject)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetRecoverFailedObjects indicates an expected call of GetRecoverFailedObjects.
func (mr *MockExitRecoverDBMockRecorder) GetRecoverFailedObjects(retry, limit any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetRecoverFailedObjects", reflect.TypeOf((*MockExitRecoverDB)(nil).GetRecoverFailedObjects), retry, limit)
}

// GetRecoverFailedObjectsByRetryTime mocks base method.
func (m *MockExitRecoverDB) GetRecoverFailedObjectsByRetryTime(retry uint32) ([]*RecoverFailedObject, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetRecoverFailedObjectsByRetryTime", retry)
	ret0, _ := ret[0].([]*RecoverFailedObject)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetRecoverFailedObjectsByRetryTime indicates an expected call of GetRecoverFailedObjectsByRetryTime.
func (mr *MockExitRecoverDBMockRecorder) GetRecoverFailedObjectsByRetryTime(retry any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetRecoverFailedObjectsByRetryTime", reflect.TypeOf((*MockExitRecoverDB)(nil).GetRecoverFailedObjectsByRetryTime), retry)
}

// GetRecoverGVGStats mocks base method.
func (m *MockExitRecoverDB) GetRecoverGVGStats(gvgID uint32) (*RecoverGVGStats, error) {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "GetRecoverGVGStats", gvgID)
	ret0, _ := ret[0].(*RecoverGVGStats)
	ret1, _ := ret[1].(error)
	return ret0, ret1
}

// GetRecoverGVGStats indicates an expected call of GetRecoverGVGStats.
func (mr *MockExitRecoverDBMockRecorder) GetRecoverGVGStats(gvgID any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetRecoverGVGStats", reflect.TypeOf((*MockExitRecoverDB)(nil).GetRecoverGVGStats), gvgID)
}

// InsertRecoverFailedObject mocks base method.
func (m *MockExitRecoverDB) InsertRecoverFailedObject(object *RecoverFailedObject) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "InsertRecoverFailedObject", object)
	ret0, _ := ret[0].(error)
	return ret0
}

// InsertRecoverFailedObject indicates an expected call of InsertRecoverFailedObject.
func (mr *MockExitRecoverDBMockRecorder) InsertRecoverFailedObject(object any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "InsertRecoverFailedObject", reflect.TypeOf((*MockExitRecoverDB)(nil).InsertRecoverFailedObject), object)
}

// SetRecoverGVGStats mocks base method.
func (m *MockExitRecoverDB) SetRecoverGVGStats(stats []*RecoverGVGStats) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "SetRecoverGVGStats", stats)
	ret0, _ := ret[0].(error)
	return ret0
}

// SetRecoverGVGStats indicates an expected call of SetRecoverGVGStats.
func (mr *MockExitRecoverDBMockRecorder) SetRecoverGVGStats(stats any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SetRecoverGVGStats", reflect.TypeOf((*MockExitRecoverDB)(nil).SetRecoverGVGStats), stats)
}

// UpdateRecoverFailedObject mocks base method.
func (m *MockExitRecoverDB) UpdateRecoverFailedObject(object *RecoverFailedObject) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateRecoverFailedObject", object)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateRecoverFailedObject indicates an expected call of UpdateRecoverFailedObject.
func (mr *MockExitRecoverDBMockRecorder) UpdateRecoverFailedObject(object any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateRecoverFailedObject", reflect.TypeOf((*MockExitRecoverDB)(nil).UpdateRecoverFailedObject), object)
}

// UpdateRecoverGVGStats mocks base method.
func (m *MockExitRecoverDB) UpdateRecoverGVGStats(stats *RecoverGVGStats) error {
	m.ctrl.T.Helper()
	ret := m.ctrl.Call(m, "UpdateRecoverGVGStats", stats)
	ret0, _ := ret[0].(error)
	return ret0
}

// UpdateRecoverGVGStats indicates an expected call of UpdateRecoverGVGStats.
func (mr *MockExitRecoverDBMockRecorder) UpdateRecoverGVGStats(stats any) *gomock.Call {
	mr.mock.ctrl.T.Helper()
	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateRecoverGVGStats", reflect.TypeOf((*MockExitRecoverDB)(nil).UpdateRecoverGVGStats), stats)
}