repo provider interface refactor for repo static configuration

Signed-off-by: Lyndon-Li <lyonghui@vmware.com>
This commit is contained in:
Lyndon-Li
2025-11-03 15:09:37 +08:00
parent c907b316a5
commit 9556a39a89
8 changed files with 249 additions and 18 deletions

View File

@@ -1,4 +1,4 @@
// Code generated by mockery v2.39.1. DO NOT EDIT.
// Code generated by mockery v2.53.2. DO NOT EDIT.
package mocks
@@ -37,6 +37,34 @@ func (_m *Manager) BatchForget(_a0 context.Context, _a1 *v1.BackupRepository, _a
return r0
}
// ClientSideCacheLimit provides a mock function with given fields: _a0
func (_m *Manager) ClientSideCacheLimit(_a0 *v1.BackupRepository) (int64, error) {
ret := _m.Called(_a0)
if len(ret) == 0 {
panic("no return value specified for ClientSideCacheLimit")
}
var r0 int64
var r1 error
if rf, ok := ret.Get(0).(func(*v1.BackupRepository) (int64, error)); ok {
return rf(_a0)
}
if rf, ok := ret.Get(0).(func(*v1.BackupRepository) int64); ok {
r0 = rf(_a0)
} else {
r0 = ret.Get(0).(int64)
}
if rf, ok := ret.Get(1).(func(*v1.BackupRepository) error); ok {
r1 = rf(_a0)
} else {
r1 = ret.Error(1)
}
return r0, r1
}
// ConnectToRepo provides a mock function with given fields: repo
func (_m *Manager) ConnectToRepo(repo *v1.BackupRepository) error {
ret := _m.Called(repo)
@@ -55,9 +83,9 @@ func (_m *Manager) ConnectToRepo(repo *v1.BackupRepository) error {
return r0
}
// DefaultMaintenanceFrequency provides a mock function with given fields: repo
func (_m *Manager) DefaultMaintenanceFrequency(repo *v1.BackupRepository) (time.Duration, error) {
ret := _m.Called(repo)
// DefaultMaintenanceFrequency provides a mock function with given fields: _a0
func (_m *Manager) DefaultMaintenanceFrequency(_a0 *v1.BackupRepository) (time.Duration, error) {
ret := _m.Called(_a0)
if len(ret) == 0 {
panic("no return value specified for DefaultMaintenanceFrequency")
@@ -66,16 +94,16 @@ func (_m *Manager) DefaultMaintenanceFrequency(repo *v1.BackupRepository) (time.
var r0 time.Duration
var r1 error
if rf, ok := ret.Get(0).(func(*v1.BackupRepository) (time.Duration, error)); ok {
return rf(repo)
return rf(_a0)
}
if rf, ok := ret.Get(0).(func(*v1.BackupRepository) time.Duration); ok {
r0 = rf(repo)
r0 = rf(_a0)
} else {
r0 = ret.Get(0).(time.Duration)
}
if rf, ok := ret.Get(1).(func(*v1.BackupRepository) error); ok {
r1 = rf(repo)
r1 = rf(_a0)
} else {
r1 = ret.Error(1)
}