Documentation ¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockAccessAPI
- func (m *MockAccessAPI) Delete(arg0 context.Context, arg1 *access.DeleteArgs) ([]access.Location, error)
- func (m *MockAccessAPI) EXPECT() *MockAccessAPIMockRecorder
- func (m *MockAccessAPI) Get(arg0 context.Context, arg1 *access.GetArgs) (io.ReadCloser, error)
- func (m *MockAccessAPI) Put(arg0 context.Context, arg1 *access.PutArgs) (access.Location, access.HashSumMap, error)
- type MockAccessAPIMockRecorder
- type MockClientAPI
- func (m *MockClientAPI) AllocBid(arg0 context.Context, arg1 *clustermgr.BidScopeArgs) (*clustermgr.BidScopeRet, error)
- func (m *MockClientAPI) AllocVolume(arg0 context.Context, arg1 *clustermgr.AllocVolumeArgs) (clustermgr.AllocatedVolumeInfos, error)
- func (m *MockClientAPI) DiskInfo(arg0 context.Context, arg1 proto.DiskID) (*blobnode.DiskInfo, error)
- func (m *MockClientAPI) EXPECT() *MockClientAPIMockRecorder
- func (m *MockClientAPI) GetConfig(arg0 context.Context, arg1 string) (string, error)
- func (m *MockClientAPI) GetService(arg0 context.Context, arg1 clustermgr.GetServiceArgs) (clustermgr.ServiceInfo, error)
- func (m *MockClientAPI) GetVolumeInfo(arg0 context.Context, arg1 *clustermgr.GetVolumeArgs) (*clustermgr.VolumeInfo, error)
- func (m *MockClientAPI) ListDisk(arg0 context.Context, arg1 *clustermgr.ListOptionArgs) (clustermgr.ListDiskRet, error)
- func (m *MockClientAPI) RegisterService(arg0 context.Context, arg1 clustermgr.ServiceNode, arg2, arg3, arg4 uint32) error
- func (m *MockClientAPI) RetainVolume(arg0 context.Context, arg1 *clustermgr.RetainVolumeArgs) (clustermgr.RetainVolumes, error)
- type MockClientAPIMockRecorder
- func (mr *MockClientAPIMockRecorder) AllocBid(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientAPIMockRecorder) AllocVolume(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientAPIMockRecorder) DiskInfo(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientAPIMockRecorder) GetConfig(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientAPIMockRecorder) GetService(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientAPIMockRecorder) GetVolumeInfo(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientAPIMockRecorder) ListDisk(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientAPIMockRecorder) RegisterService(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
- func (mr *MockClientAPIMockRecorder) RetainVolume(arg0, arg1 interface{}) *gomock.Call
- type MockIScheduler
- func (m *MockIScheduler) AcquireInspectTask(arg0 context.Context) (*proto.VolumeInspectTask, error)
- func (m *MockIScheduler) AcquireTask(arg0 context.Context, arg1 *scheduler.AcquireArgs) (*proto.MigrateTask, error)
- func (m *MockIScheduler) AddManualMigrateTask(arg0 context.Context, arg1 *scheduler.AddManualMigrateArgs) error
- func (m *MockIScheduler) CancelTask(arg0 context.Context, arg1 *scheduler.OperateTaskArgs) error
- func (m *MockIScheduler) CompleteInspectTask(arg0 context.Context, arg1 *proto.VolumeInspectRet) error
- func (m *MockIScheduler) CompleteTask(arg0 context.Context, arg1 *scheduler.OperateTaskArgs) error
- func (m *MockIScheduler) DetailMigrateTask(arg0 context.Context, arg1 *scheduler.MigrateTaskDetailArgs) (scheduler.MigrateTaskDetail, error)
- func (m *MockIScheduler) DiskMigratingStats(arg0 context.Context, arg1 *scheduler.DiskMigratingStatsArgs) (*scheduler.DiskMigratingStats, error)
- func (m *MockIScheduler) EXPECT() *MockISchedulerMockRecorder
- func (m *MockIScheduler) LeaderStats(arg0 context.Context) (scheduler.TasksStat, error)
- func (m *MockIScheduler) ReclaimTask(arg0 context.Context, arg1 *scheduler.OperateTaskArgs) error
- func (m *MockIScheduler) RenewalTask(arg0 context.Context, arg1 *scheduler.TaskRenewalArgs) (*scheduler.TaskRenewalRet, error)
- func (m *MockIScheduler) ReportTask(arg0 context.Context, arg1 *scheduler.TaskReportArgs) error
- func (m *MockIScheduler) Stats(arg0 context.Context, arg1 string) (scheduler.TasksStat, error)
- func (m *MockIScheduler) UpdateVolume(arg0 context.Context, arg1 string, arg2 proto.Vid) error
- type MockISchedulerMockRecorder
- func (mr *MockISchedulerMockRecorder) AcquireInspectTask(arg0 interface{}) *gomock.Call
- func (mr *MockISchedulerMockRecorder) AcquireTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockISchedulerMockRecorder) AddManualMigrateTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockISchedulerMockRecorder) CancelTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockISchedulerMockRecorder) CompleteInspectTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockISchedulerMockRecorder) CompleteTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockISchedulerMockRecorder) DetailMigrateTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockISchedulerMockRecorder) DiskMigratingStats(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockISchedulerMockRecorder) LeaderStats(arg0 interface{}) *gomock.Call
- func (mr *MockISchedulerMockRecorder) ReclaimTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockISchedulerMockRecorder) RenewalTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockISchedulerMockRecorder) ReportTask(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockISchedulerMockRecorder) Stats(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockISchedulerMockRecorder) UpdateVolume(arg0, arg1, arg2 interface{}) *gomock.Call
- type MockProxyClient
- func (m *MockProxyClient) EXPECT() *MockProxyClientMockRecorder
- func (m *MockProxyClient) Erase(arg0 context.Context, arg1, arg2 string) error
- func (m *MockProxyClient) GetCacheDisk(arg0 context.Context, arg1 string, arg2 *proxy.CacheDiskArgs) (*blobnode.DiskInfo, error)
- func (m *MockProxyClient) GetCacheVolume(arg0 context.Context, arg1 string, arg2 *proxy.CacheVolumeArgs) (*proxy.VersionVolume, error)
- func (m *MockProxyClient) ListVolumes(arg0 context.Context, arg1 string, arg2 *proxy.ListVolsArgs) (proxy.VolumeList, error)
- func (m *MockProxyClient) SendDeleteMsg(arg0 context.Context, arg1 string, arg2 *proxy.DeleteArgs) error
- func (m *MockProxyClient) SendShardRepairMsg(arg0 context.Context, arg1 string, arg2 *proxy.ShardRepairArgs) error
- func (m *MockProxyClient) VolumeAlloc(arg0 context.Context, arg1 string, arg2 *proxy.AllocVolsArgs) ([]proxy.AllocRet, error)
- type MockProxyClientMockRecorder
- func (mr *MockProxyClientMockRecorder) Erase(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockProxyClientMockRecorder) GetCacheDisk(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockProxyClientMockRecorder) GetCacheVolume(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockProxyClientMockRecorder) ListVolumes(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockProxyClientMockRecorder) SendDeleteMsg(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockProxyClientMockRecorder) SendShardRepairMsg(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockProxyClientMockRecorder) VolumeAlloc(arg0, arg1, arg2 interface{}) *gomock.Call
- type MockProxyLbRpcClient
- type MockProxyLbRpcClientMockRecorder
- type MockRPCClient
- func (m *MockRPCClient) Close()
- func (m *MockRPCClient) Delete(arg0 context.Context, arg1 string) (*http.Response, error)
- func (m *MockRPCClient) Do(arg0 context.Context, arg1 *http.Request) (*http.Response, error)
- func (m *MockRPCClient) DoWith(arg0 context.Context, arg1 *http.Request, arg2 interface{}, arg3 ...rpc.Option) error
- func (m *MockRPCClient) EXPECT() *MockRPCClientMockRecorder
- func (m *MockRPCClient) Form(arg0 context.Context, arg1, arg2 string, arg3 map[string][]string) (*http.Response, error)
- func (m *MockRPCClient) Get(arg0 context.Context, arg1 string) (*http.Response, error)
- func (m *MockRPCClient) GetWith(arg0 context.Context, arg1 string, arg2 interface{}) error
- func (m *MockRPCClient) Head(arg0 context.Context, arg1 string) (*http.Response, error)
- func (m *MockRPCClient) Post(arg0 context.Context, arg1 string, arg2 interface{}) (*http.Response, error)
- func (m *MockRPCClient) PostWith(arg0 context.Context, arg1 string, arg2, arg3 interface{}, arg4 ...rpc.Option) error
- func (m *MockRPCClient) Put(arg0 context.Context, arg1 string, arg2 interface{}) (*http.Response, error)
- func (m *MockRPCClient) PutWith(arg0 context.Context, arg1 string, arg2, arg3 interface{}, arg4 ...rpc.Option) error
- type MockRPCClientMockRecorder
- func (mr *MockRPCClientMockRecorder) Close() *gomock.Call
- func (mr *MockRPCClientMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRPCClientMockRecorder) Do(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRPCClientMockRecorder) DoWith(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- func (mr *MockRPCClientMockRecorder) Form(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
- func (mr *MockRPCClientMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRPCClientMockRecorder) GetWith(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockRPCClientMockRecorder) Head(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRPCClientMockRecorder) Post(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockRPCClientMockRecorder) PostWith(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
- func (mr *MockRPCClientMockRecorder) Put(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockRPCClientMockRecorder) PutWith(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
- type MockRaftServer
- func (m *MockRaftServer) AddMember(arg0 context.Context, arg1 raftserver.Member) error
- func (m *MockRaftServer) EXPECT() *MockRaftServerMockRecorder
- func (m *MockRaftServer) IsLeader() bool
- func (m *MockRaftServer) Propose(arg0 context.Context, arg1 []byte) error
- func (m *MockRaftServer) ReadIndex(arg0 context.Context) error
- func (m *MockRaftServer) RemoveMember(arg0 context.Context, arg1 uint64) error
- func (m *MockRaftServer) Status() raftserver.Status
- func (m *MockRaftServer) Stop()
- func (m *MockRaftServer) TransferLeadership(arg0 context.Context, arg1, arg2 uint64)
- func (m *MockRaftServer) Truncate(arg0 uint64) error
- type MockRaftServerMockRecorder
- func (mr *MockRaftServerMockRecorder) AddMember(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRaftServerMockRecorder) IsLeader() *gomock.Call
- func (mr *MockRaftServerMockRecorder) Propose(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRaftServerMockRecorder) ReadIndex(arg0 interface{}) *gomock.Call
- func (mr *MockRaftServerMockRecorder) RemoveMember(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockRaftServerMockRecorder) Status() *gomock.Call
- func (mr *MockRaftServerMockRecorder) Stop() *gomock.Call
- func (mr *MockRaftServerMockRecorder) TransferLeadership(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockRaftServerMockRecorder) Truncate(arg0 interface{}) *gomock.Call
- type MockRecordLogEncoder
- type MockRecordLogEncoderMockRecorder
- type MockSelector
- type MockSelectorMockRecorder
- type MockStorageAPI
- func (m *MockStorageAPI) Close(arg0 context.Context, arg1 string) error
- func (m *MockStorageAPI) CreateChunk(arg0 context.Context, arg1 string, arg2 *blobnode.CreateChunkArgs) error
- func (m *MockStorageAPI) DeleteShard(arg0 context.Context, arg1 string, arg2 *blobnode.DeleteShardArgs) error
- func (m *MockStorageAPI) DiskInfo(arg0 context.Context, arg1 string, arg2 *blobnode.DiskStatArgs) (*blobnode.DiskInfo, error)
- func (m *MockStorageAPI) EXPECT() *MockStorageAPIMockRecorder
- func (m *MockStorageAPI) GetShard(arg0 context.Context, arg1 string, arg2 *blobnode.GetShardArgs) (io.ReadCloser, uint32, error)
- func (m *MockStorageAPI) IsOnline(arg0 context.Context, arg1 string) bool
- func (m *MockStorageAPI) ListChunks(arg0 context.Context, arg1 string, arg2 *blobnode.ListChunkArgs) ([]*blobnode.ChunkInfo, error)
- func (m *MockStorageAPI) ListShards(arg0 context.Context, arg1 string, arg2 *blobnode.ListShardsArgs) ([]*blobnode.ShardInfo, proto.BlobID, error)
- func (m *MockStorageAPI) MarkDeleteShard(arg0 context.Context, arg1 string, arg2 *blobnode.DeleteShardArgs) error
- func (m *MockStorageAPI) PutShard(arg0 context.Context, arg1 string, arg2 *blobnode.PutShardArgs) (uint32, error)
- func (m *MockStorageAPI) RangeGetShard(arg0 context.Context, arg1 string, arg2 *blobnode.RangeGetShardArgs) (io.ReadCloser, uint32, error)
- func (m *MockStorageAPI) ReleaseChunk(arg0 context.Context, arg1 string, arg2 *blobnode.ChangeChunkStatusArgs) error
- func (m *MockStorageAPI) RepairShard(arg0 context.Context, arg1 string, arg2 *proto.ShardRepairTask) error
- func (m *MockStorageAPI) SetChunkReadonly(arg0 context.Context, arg1 string, arg2 *blobnode.ChangeChunkStatusArgs) error
- func (m *MockStorageAPI) SetChunkReadwrite(arg0 context.Context, arg1 string, arg2 *blobnode.ChangeChunkStatusArgs) error
- func (m *MockStorageAPI) Stat(arg0 context.Context, arg1 string) ([]*blobnode.DiskInfo, error)
- func (m *MockStorageAPI) StatChunk(arg0 context.Context, arg1 string, arg2 *blobnode.StatChunkArgs) (*blobnode.ChunkInfo, error)
- func (m *MockStorageAPI) StatShard(arg0 context.Context, arg1 string, arg2 *blobnode.StatShardArgs) (*blobnode.ShardInfo, error)
- func (m *MockStorageAPI) String(arg0 context.Context, arg1 string) string
- func (m *MockStorageAPI) WorkerStats(arg0 context.Context, arg1 string) (blobnode.WorkerStats, error)
- type MockStorageAPIMockRecorder
- func (mr *MockStorageAPIMockRecorder) Close(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) CreateChunk(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) DeleteShard(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) DiskInfo(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) GetShard(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) IsOnline(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) ListChunks(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) ListShards(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) MarkDeleteShard(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) PutShard(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) RangeGetShard(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) ReleaseChunk(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) RepairShard(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) SetChunkReadonly(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) SetChunkReadwrite(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) Stat(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) StatChunk(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) StatShard(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) String(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockStorageAPIMockRecorder) WorkerStats(arg0, arg1 interface{}) *gomock.Call
- type MockSwitcher
- type MockSwitcherMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockAccessAPI ¶
type MockAccessAPI struct {
// contains filtered or unexported fields
}
MockAccessAPI is a mock of API interface.
func NewMockAccessAPI ¶
func NewMockAccessAPI(ctrl *gomock.Controller) *MockAccessAPI
NewMockAccessAPI creates a new mock instance.
func (*MockAccessAPI) Delete ¶
func (m *MockAccessAPI) Delete(arg0 context.Context, arg1 *access.DeleteArgs) ([]access.Location, error)
Delete mocks base method.
func (*MockAccessAPI) EXPECT ¶
func (m *MockAccessAPI) EXPECT() *MockAccessAPIMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockAccessAPI) Get ¶
func (m *MockAccessAPI) Get(arg0 context.Context, arg1 *access.GetArgs) (io.ReadCloser, error)
Get mocks base method.
type MockAccessAPIMockRecorder ¶
type MockAccessAPIMockRecorder struct {
// contains filtered or unexported fields
}
MockAccessAPIMockRecorder is the mock recorder for MockAccessAPI.
func (*MockAccessAPIMockRecorder) Delete ¶
func (mr *MockAccessAPIMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockAccessAPIMockRecorder) Get ¶
func (mr *MockAccessAPIMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockAccessAPIMockRecorder) Put ¶
func (mr *MockAccessAPIMockRecorder) Put(arg0, arg1 interface{}) *gomock.Call
Put indicates an expected call of Put.
type MockClientAPI ¶
type MockClientAPI struct {
// contains filtered or unexported fields
}
MockClientAPI is a mock of ClientAPI interface.
func NewMockClientAPI ¶
func NewMockClientAPI(ctrl *gomock.Controller) *MockClientAPI
NewMockClientAPI creates a new mock instance.
func (*MockClientAPI) AllocBid ¶
func (m *MockClientAPI) AllocBid(arg0 context.Context, arg1 *clustermgr.BidScopeArgs) (*clustermgr.BidScopeRet, error)
AllocBid mocks base method.
func (*MockClientAPI) AllocVolume ¶
func (m *MockClientAPI) AllocVolume(arg0 context.Context, arg1 *clustermgr.AllocVolumeArgs) (clustermgr.AllocatedVolumeInfos, error)
AllocVolume mocks base method.
func (*MockClientAPI) DiskInfo ¶
func (m *MockClientAPI) DiskInfo(arg0 context.Context, arg1 proto.DiskID) (*blobnode.DiskInfo, error)
DiskInfo mocks base method.
func (*MockClientAPI) EXPECT ¶
func (m *MockClientAPI) EXPECT() *MockClientAPIMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClientAPI) GetService ¶
func (m *MockClientAPI) GetService(arg0 context.Context, arg1 clustermgr.GetServiceArgs) (clustermgr.ServiceInfo, error)
GetService mocks base method.
func (*MockClientAPI) GetVolumeInfo ¶
func (m *MockClientAPI) GetVolumeInfo(arg0 context.Context, arg1 *clustermgr.GetVolumeArgs) (*clustermgr.VolumeInfo, error)
GetVolumeInfo mocks base method.
func (*MockClientAPI) ListDisk ¶
func (m *MockClientAPI) ListDisk(arg0 context.Context, arg1 *clustermgr.ListOptionArgs) (clustermgr.ListDiskRet, error)
ListDisk mocks base method.
func (*MockClientAPI) RegisterService ¶
func (m *MockClientAPI) RegisterService(arg0 context.Context, arg1 clustermgr.ServiceNode, arg2, arg3, arg4 uint32) error
RegisterService mocks base method.
func (*MockClientAPI) RetainVolume ¶
func (m *MockClientAPI) RetainVolume(arg0 context.Context, arg1 *clustermgr.RetainVolumeArgs) (clustermgr.RetainVolumes, error)
RetainVolume mocks base method.
type MockClientAPIMockRecorder ¶
type MockClientAPIMockRecorder struct {
// contains filtered or unexported fields
}
MockClientAPIMockRecorder is the mock recorder for MockClientAPI.
func (*MockClientAPIMockRecorder) AllocBid ¶
func (mr *MockClientAPIMockRecorder) AllocBid(arg0, arg1 interface{}) *gomock.Call
AllocBid indicates an expected call of AllocBid.
func (*MockClientAPIMockRecorder) AllocVolume ¶
func (mr *MockClientAPIMockRecorder) AllocVolume(arg0, arg1 interface{}) *gomock.Call
AllocVolume indicates an expected call of AllocVolume.
func (*MockClientAPIMockRecorder) DiskInfo ¶
func (mr *MockClientAPIMockRecorder) DiskInfo(arg0, arg1 interface{}) *gomock.Call
DiskInfo indicates an expected call of DiskInfo.
func (*MockClientAPIMockRecorder) GetConfig ¶
func (mr *MockClientAPIMockRecorder) GetConfig(arg0, arg1 interface{}) *gomock.Call
GetConfig indicates an expected call of GetConfig.
func (*MockClientAPIMockRecorder) GetService ¶
func (mr *MockClientAPIMockRecorder) GetService(arg0, arg1 interface{}) *gomock.Call
GetService indicates an expected call of GetService.
func (*MockClientAPIMockRecorder) GetVolumeInfo ¶
func (mr *MockClientAPIMockRecorder) GetVolumeInfo(arg0, arg1 interface{}) *gomock.Call
GetVolumeInfo indicates an expected call of GetVolumeInfo.
func (*MockClientAPIMockRecorder) ListDisk ¶
func (mr *MockClientAPIMockRecorder) ListDisk(arg0, arg1 interface{}) *gomock.Call
ListDisk indicates an expected call of ListDisk.
func (*MockClientAPIMockRecorder) RegisterService ¶
func (mr *MockClientAPIMockRecorder) RegisterService(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call
RegisterService indicates an expected call of RegisterService.
func (*MockClientAPIMockRecorder) RetainVolume ¶
func (mr *MockClientAPIMockRecorder) RetainVolume(arg0, arg1 interface{}) *gomock.Call
RetainVolume indicates an expected call of RetainVolume.
type MockIScheduler ¶
type MockIScheduler struct {
// contains filtered or unexported fields
}
MockIScheduler is a mock of IScheduler interface.
func NewMockIScheduler ¶
func NewMockIScheduler(ctrl *gomock.Controller) *MockIScheduler
NewMockIScheduler creates a new mock instance.
func (*MockIScheduler) AcquireInspectTask ¶
func (m *MockIScheduler) AcquireInspectTask(arg0 context.Context) (*proto.VolumeInspectTask, error)
AcquireInspectTask mocks base method.
func (*MockIScheduler) AcquireTask ¶
func (m *MockIScheduler) AcquireTask(arg0 context.Context, arg1 *scheduler.AcquireArgs) (*proto.MigrateTask, error)
AcquireTask mocks base method.
func (*MockIScheduler) AddManualMigrateTask ¶
func (m *MockIScheduler) AddManualMigrateTask(arg0 context.Context, arg1 *scheduler.AddManualMigrateArgs) error
AddManualMigrateTask mocks base method.
func (*MockIScheduler) CancelTask ¶
func (m *MockIScheduler) CancelTask(arg0 context.Context, arg1 *scheduler.OperateTaskArgs) error
CancelTask mocks base method.
func (*MockIScheduler) CompleteInspectTask ¶
func (m *MockIScheduler) CompleteInspectTask(arg0 context.Context, arg1 *proto.VolumeInspectRet) error
CompleteInspectTask mocks base method.
func (*MockIScheduler) CompleteTask ¶
func (m *MockIScheduler) CompleteTask(arg0 context.Context, arg1 *scheduler.OperateTaskArgs) error
CompleteTask mocks base method.
func (*MockIScheduler) DetailMigrateTask ¶
func (m *MockIScheduler) DetailMigrateTask(arg0 context.Context, arg1 *scheduler.MigrateTaskDetailArgs) (scheduler.MigrateTaskDetail, error)
DetailMigrateTask mocks base method.
func (*MockIScheduler) DiskMigratingStats ¶
func (m *MockIScheduler) DiskMigratingStats(arg0 context.Context, arg1 *scheduler.DiskMigratingStatsArgs) (*scheduler.DiskMigratingStats, error)
DiskMigratingStats mocks base method.
func (*MockIScheduler) EXPECT ¶
func (m *MockIScheduler) EXPECT() *MockISchedulerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockIScheduler) LeaderStats ¶
LeaderStats mocks base method.
func (*MockIScheduler) ReclaimTask ¶
func (m *MockIScheduler) ReclaimTask(arg0 context.Context, arg1 *scheduler.OperateTaskArgs) error
ReclaimTask mocks base method.
func (*MockIScheduler) RenewalTask ¶
func (m *MockIScheduler) RenewalTask(arg0 context.Context, arg1 *scheduler.TaskRenewalArgs) (*scheduler.TaskRenewalRet, error)
RenewalTask mocks base method.
func (*MockIScheduler) ReportTask ¶
func (m *MockIScheduler) ReportTask(arg0 context.Context, arg1 *scheduler.TaskReportArgs) error
ReportTask mocks base method.
func (*MockIScheduler) UpdateVolume ¶
UpdateVolume mocks base method.
type MockISchedulerMockRecorder ¶
type MockISchedulerMockRecorder struct {
// contains filtered or unexported fields
}
MockISchedulerMockRecorder is the mock recorder for MockIScheduler.
func (*MockISchedulerMockRecorder) AcquireInspectTask ¶
func (mr *MockISchedulerMockRecorder) AcquireInspectTask(arg0 interface{}) *gomock.Call
AcquireInspectTask indicates an expected call of AcquireInspectTask.
func (*MockISchedulerMockRecorder) AcquireTask ¶
func (mr *MockISchedulerMockRecorder) AcquireTask(arg0, arg1 interface{}) *gomock.Call
AcquireTask indicates an expected call of AcquireTask.
func (*MockISchedulerMockRecorder) AddManualMigrateTask ¶
func (mr *MockISchedulerMockRecorder) AddManualMigrateTask(arg0, arg1 interface{}) *gomock.Call
AddManualMigrateTask indicates an expected call of AddManualMigrateTask.
func (*MockISchedulerMockRecorder) CancelTask ¶
func (mr *MockISchedulerMockRecorder) CancelTask(arg0, arg1 interface{}) *gomock.Call
CancelTask indicates an expected call of CancelTask.
func (*MockISchedulerMockRecorder) CompleteInspectTask ¶
func (mr *MockISchedulerMockRecorder) CompleteInspectTask(arg0, arg1 interface{}) *gomock.Call
CompleteInspectTask indicates an expected call of CompleteInspectTask.
func (*MockISchedulerMockRecorder) CompleteTask ¶
func (mr *MockISchedulerMockRecorder) CompleteTask(arg0, arg1 interface{}) *gomock.Call
CompleteTask indicates an expected call of CompleteTask.
func (*MockISchedulerMockRecorder) DetailMigrateTask ¶
func (mr *MockISchedulerMockRecorder) DetailMigrateTask(arg0, arg1 interface{}) *gomock.Call
DetailMigrateTask indicates an expected call of DetailMigrateTask.
func (*MockISchedulerMockRecorder) DiskMigratingStats ¶
func (mr *MockISchedulerMockRecorder) DiskMigratingStats(arg0, arg1 interface{}) *gomock.Call
DiskMigratingStats indicates an expected call of DiskMigratingStats.
func (*MockISchedulerMockRecorder) LeaderStats ¶
func (mr *MockISchedulerMockRecorder) LeaderStats(arg0 interface{}) *gomock.Call
LeaderStats indicates an expected call of LeaderStats.
func (*MockISchedulerMockRecorder) ReclaimTask ¶
func (mr *MockISchedulerMockRecorder) ReclaimTask(arg0, arg1 interface{}) *gomock.Call
ReclaimTask indicates an expected call of ReclaimTask.
func (*MockISchedulerMockRecorder) RenewalTask ¶
func (mr *MockISchedulerMockRecorder) RenewalTask(arg0, arg1 interface{}) *gomock.Call
RenewalTask indicates an expected call of RenewalTask.
func (*MockISchedulerMockRecorder) ReportTask ¶
func (mr *MockISchedulerMockRecorder) ReportTask(arg0, arg1 interface{}) *gomock.Call
ReportTask indicates an expected call of ReportTask.
func (*MockISchedulerMockRecorder) Stats ¶
func (mr *MockISchedulerMockRecorder) Stats(arg0, arg1 interface{}) *gomock.Call
Stats indicates an expected call of Stats.
func (*MockISchedulerMockRecorder) UpdateVolume ¶
func (mr *MockISchedulerMockRecorder) UpdateVolume(arg0, arg1, arg2 interface{}) *gomock.Call
UpdateVolume indicates an expected call of UpdateVolume.
type MockProxyClient ¶
type MockProxyClient struct {
// contains filtered or unexported fields
}
MockProxyClient is a mock of Client interface.
func NewMockProxyClient ¶
func NewMockProxyClient(ctrl *gomock.Controller) *MockProxyClient
NewMockProxyClient creates a new mock instance.
func (*MockProxyClient) EXPECT ¶
func (m *MockProxyClient) EXPECT() *MockProxyClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockProxyClient) Erase ¶
func (m *MockProxyClient) Erase(arg0 context.Context, arg1, arg2 string) error
Erase mocks base method.
func (*MockProxyClient) GetCacheDisk ¶
func (m *MockProxyClient) GetCacheDisk(arg0 context.Context, arg1 string, arg2 *proxy.CacheDiskArgs) (*blobnode.DiskInfo, error)
GetCacheDisk mocks base method.
func (*MockProxyClient) GetCacheVolume ¶
func (m *MockProxyClient) GetCacheVolume(arg0 context.Context, arg1 string, arg2 *proxy.CacheVolumeArgs) (*proxy.VersionVolume, error)
GetCacheVolume mocks base method.
func (*MockProxyClient) ListVolumes ¶
func (m *MockProxyClient) ListVolumes(arg0 context.Context, arg1 string, arg2 *proxy.ListVolsArgs) (proxy.VolumeList, error)
ListVolumes mocks base method.
func (*MockProxyClient) SendDeleteMsg ¶
func (m *MockProxyClient) SendDeleteMsg(arg0 context.Context, arg1 string, arg2 *proxy.DeleteArgs) error
SendDeleteMsg mocks base method.
func (*MockProxyClient) SendShardRepairMsg ¶
func (m *MockProxyClient) SendShardRepairMsg(arg0 context.Context, arg1 string, arg2 *proxy.ShardRepairArgs) error
SendShardRepairMsg mocks base method.
func (*MockProxyClient) VolumeAlloc ¶
func (m *MockProxyClient) VolumeAlloc(arg0 context.Context, arg1 string, arg2 *proxy.AllocVolsArgs) ([]proxy.AllocRet, error)
VolumeAlloc mocks base method.
type MockProxyClientMockRecorder ¶
type MockProxyClientMockRecorder struct {
// contains filtered or unexported fields
}
MockProxyClientMockRecorder is the mock recorder for MockProxyClient.
func (*MockProxyClientMockRecorder) Erase ¶
func (mr *MockProxyClientMockRecorder) Erase(arg0, arg1, arg2 interface{}) *gomock.Call
Erase indicates an expected call of Erase.
func (*MockProxyClientMockRecorder) GetCacheDisk ¶
func (mr *MockProxyClientMockRecorder) GetCacheDisk(arg0, arg1, arg2 interface{}) *gomock.Call
GetCacheDisk indicates an expected call of GetCacheDisk.
func (*MockProxyClientMockRecorder) GetCacheVolume ¶
func (mr *MockProxyClientMockRecorder) GetCacheVolume(arg0, arg1, arg2 interface{}) *gomock.Call
GetCacheVolume indicates an expected call of GetCacheVolume.
func (*MockProxyClientMockRecorder) ListVolumes ¶
func (mr *MockProxyClientMockRecorder) ListVolumes(arg0, arg1, arg2 interface{}) *gomock.Call
ListVolumes indicates an expected call of ListVolumes.
func (*MockProxyClientMockRecorder) SendDeleteMsg ¶
func (mr *MockProxyClientMockRecorder) SendDeleteMsg(arg0, arg1, arg2 interface{}) *gomock.Call
SendDeleteMsg indicates an expected call of SendDeleteMsg.
func (*MockProxyClientMockRecorder) SendShardRepairMsg ¶
func (mr *MockProxyClientMockRecorder) SendShardRepairMsg(arg0, arg1, arg2 interface{}) *gomock.Call
SendShardRepairMsg indicates an expected call of SendShardRepairMsg.
func (*MockProxyClientMockRecorder) VolumeAlloc ¶
func (mr *MockProxyClientMockRecorder) VolumeAlloc(arg0, arg1, arg2 interface{}) *gomock.Call
VolumeAlloc indicates an expected call of VolumeAlloc.
type MockProxyLbRpcClient ¶
type MockProxyLbRpcClient struct {
// contains filtered or unexported fields
}
MockProxyLbRpcClient is a mock of LbMsgSender interface.
func NewMockProxyLbRpcClient ¶
func NewMockProxyLbRpcClient(ctrl *gomock.Controller) *MockProxyLbRpcClient
NewMockProxyLbRpcClient creates a new mock instance.
func (*MockProxyLbRpcClient) EXPECT ¶
func (m *MockProxyLbRpcClient) EXPECT() *MockProxyLbRpcClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockProxyLbRpcClient) SendDeleteMsg ¶
func (m *MockProxyLbRpcClient) SendDeleteMsg(arg0 context.Context, arg1 *proxy.DeleteArgs) error
SendDeleteMsg mocks base method.
func (*MockProxyLbRpcClient) SendShardRepairMsg ¶
func (m *MockProxyLbRpcClient) SendShardRepairMsg(arg0 context.Context, arg1 *proxy.ShardRepairArgs) error
SendShardRepairMsg mocks base method.
type MockProxyLbRpcClientMockRecorder ¶
type MockProxyLbRpcClientMockRecorder struct {
// contains filtered or unexported fields
}
MockProxyLbRpcClientMockRecorder is the mock recorder for MockProxyLbRpcClient.
func (*MockProxyLbRpcClientMockRecorder) SendDeleteMsg ¶
func (mr *MockProxyLbRpcClientMockRecorder) SendDeleteMsg(arg0, arg1 interface{}) *gomock.Call
SendDeleteMsg indicates an expected call of SendDeleteMsg.
func (*MockProxyLbRpcClientMockRecorder) SendShardRepairMsg ¶
func (mr *MockProxyLbRpcClientMockRecorder) SendShardRepairMsg(arg0, arg1 interface{}) *gomock.Call
SendShardRepairMsg indicates an expected call of SendShardRepairMsg.
type MockRPCClient ¶
type MockRPCClient struct {
// contains filtered or unexported fields
}
MockRPCClient is a mock of Client interface.
func NewMockRPCClient ¶
func NewMockRPCClient(ctrl *gomock.Controller) *MockRPCClient
NewMockRPCClient creates a new mock instance.
func (*MockRPCClient) DoWith ¶
func (m *MockRPCClient) DoWith(arg0 context.Context, arg1 *http.Request, arg2 interface{}, arg3 ...rpc.Option) error
DoWith mocks base method.
func (*MockRPCClient) EXPECT ¶
func (m *MockRPCClient) EXPECT() *MockRPCClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRPCClient) Form ¶
func (m *MockRPCClient) Form(arg0 context.Context, arg1, arg2 string, arg3 map[string][]string) (*http.Response, error)
Form mocks base method.
func (*MockRPCClient) GetWith ¶
func (m *MockRPCClient) GetWith(arg0 context.Context, arg1 string, arg2 interface{}) error
GetWith mocks base method.
func (*MockRPCClient) Post ¶
func (m *MockRPCClient) Post(arg0 context.Context, arg1 string, arg2 interface{}) (*http.Response, error)
Post mocks base method.
func (*MockRPCClient) PostWith ¶
func (m *MockRPCClient) PostWith(arg0 context.Context, arg1 string, arg2, arg3 interface{}, arg4 ...rpc.Option) error
PostWith mocks base method.
type MockRPCClientMockRecorder ¶
type MockRPCClientMockRecorder struct {
// contains filtered or unexported fields
}
MockRPCClientMockRecorder is the mock recorder for MockRPCClient.
func (*MockRPCClientMockRecorder) Close ¶
func (mr *MockRPCClientMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockRPCClientMockRecorder) Delete ¶
func (mr *MockRPCClientMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call
Delete indicates an expected call of Delete.
func (*MockRPCClientMockRecorder) Do ¶
func (mr *MockRPCClientMockRecorder) Do(arg0, arg1 interface{}) *gomock.Call
Do indicates an expected call of Do.
func (*MockRPCClientMockRecorder) DoWith ¶
func (mr *MockRPCClientMockRecorder) DoWith(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
DoWith indicates an expected call of DoWith.
func (*MockRPCClientMockRecorder) Form ¶
func (mr *MockRPCClientMockRecorder) Form(arg0, arg1, arg2, arg3 interface{}) *gomock.Call
Form indicates an expected call of Form.
func (*MockRPCClientMockRecorder) Get ¶
func (mr *MockRPCClientMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get.
func (*MockRPCClientMockRecorder) GetWith ¶
func (mr *MockRPCClientMockRecorder) GetWith(arg0, arg1, arg2 interface{}) *gomock.Call
GetWith indicates an expected call of GetWith.
func (*MockRPCClientMockRecorder) Head ¶
func (mr *MockRPCClientMockRecorder) Head(arg0, arg1 interface{}) *gomock.Call
Head indicates an expected call of Head.
func (*MockRPCClientMockRecorder) Post ¶
func (mr *MockRPCClientMockRecorder) Post(arg0, arg1, arg2 interface{}) *gomock.Call
Post indicates an expected call of Post.
func (*MockRPCClientMockRecorder) PostWith ¶
func (mr *MockRPCClientMockRecorder) PostWith(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
PostWith indicates an expected call of PostWith.
func (*MockRPCClientMockRecorder) Put ¶
func (mr *MockRPCClientMockRecorder) Put(arg0, arg1, arg2 interface{}) *gomock.Call
Put indicates an expected call of Put.
func (*MockRPCClientMockRecorder) PutWith ¶
func (mr *MockRPCClientMockRecorder) PutWith(arg0, arg1, arg2, arg3 interface{}, arg4 ...interface{}) *gomock.Call
PutWith indicates an expected call of PutWith.
type MockRaftServer ¶
type MockRaftServer struct {
// contains filtered or unexported fields
}
MockRaftServer is a mock of RaftServer interface.
func NewMockRaftServer ¶
func NewMockRaftServer(ctrl *gomock.Controller) *MockRaftServer
NewMockRaftServer creates a new mock instance.
func (*MockRaftServer) AddMember ¶
func (m *MockRaftServer) AddMember(arg0 context.Context, arg1 raftserver.Member) error
AddMember mocks base method.
func (*MockRaftServer) EXPECT ¶
func (m *MockRaftServer) EXPECT() *MockRaftServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRaftServer) IsLeader ¶
func (m *MockRaftServer) IsLeader() bool
IsLeader mocks base method.
func (*MockRaftServer) Propose ¶
func (m *MockRaftServer) Propose(arg0 context.Context, arg1 []byte) error
Propose mocks base method.
func (*MockRaftServer) ReadIndex ¶
func (m *MockRaftServer) ReadIndex(arg0 context.Context) error
ReadIndex mocks base method.
func (*MockRaftServer) RemoveMember ¶
func (m *MockRaftServer) RemoveMember(arg0 context.Context, arg1 uint64) error
RemoveMember mocks base method.
func (*MockRaftServer) Status ¶
func (m *MockRaftServer) Status() raftserver.Status
Status mocks base method.
func (*MockRaftServer) TransferLeadership ¶
func (m *MockRaftServer) TransferLeadership(arg0 context.Context, arg1, arg2 uint64)
TransferLeadership mocks base method.
func (*MockRaftServer) Truncate ¶
func (m *MockRaftServer) Truncate(arg0 uint64) error
Truncate mocks base method.
type MockRaftServerMockRecorder ¶
type MockRaftServerMockRecorder struct {
// contains filtered or unexported fields
}
MockRaftServerMockRecorder is the mock recorder for MockRaftServer.
func (*MockRaftServerMockRecorder) AddMember ¶
func (mr *MockRaftServerMockRecorder) AddMember(arg0, arg1 interface{}) *gomock.Call
AddMember indicates an expected call of AddMember.
func (*MockRaftServerMockRecorder) IsLeader ¶
func (mr *MockRaftServerMockRecorder) IsLeader() *gomock.Call
IsLeader indicates an expected call of IsLeader.
func (*MockRaftServerMockRecorder) Propose ¶
func (mr *MockRaftServerMockRecorder) Propose(arg0, arg1 interface{}) *gomock.Call
Propose indicates an expected call of Propose.
func (*MockRaftServerMockRecorder) ReadIndex ¶
func (mr *MockRaftServerMockRecorder) ReadIndex(arg0 interface{}) *gomock.Call
ReadIndex indicates an expected call of ReadIndex.
func (*MockRaftServerMockRecorder) RemoveMember ¶
func (mr *MockRaftServerMockRecorder) RemoveMember(arg0, arg1 interface{}) *gomock.Call
RemoveMember indicates an expected call of RemoveMember.
func (*MockRaftServerMockRecorder) Status ¶
func (mr *MockRaftServerMockRecorder) Status() *gomock.Call
Status indicates an expected call of Status.
func (*MockRaftServerMockRecorder) Stop ¶
func (mr *MockRaftServerMockRecorder) Stop() *gomock.Call
Stop indicates an expected call of Stop.
func (*MockRaftServerMockRecorder) TransferLeadership ¶
func (mr *MockRaftServerMockRecorder) TransferLeadership(arg0, arg1, arg2 interface{}) *gomock.Call
TransferLeadership indicates an expected call of TransferLeadership.
func (*MockRaftServerMockRecorder) Truncate ¶
func (mr *MockRaftServerMockRecorder) Truncate(arg0 interface{}) *gomock.Call
Truncate indicates an expected call of Truncate.
type MockRecordLogEncoder ¶
type MockRecordLogEncoder struct {
// contains filtered or unexported fields
}
MockRecordLogEncoder is a mock of Encoder interface.
func NewMockRecordLogEncoder ¶
func NewMockRecordLogEncoder(ctrl *gomock.Controller) *MockRecordLogEncoder
NewMockRecordLogEncoder creates a new mock instance.
func (*MockRecordLogEncoder) Close ¶
func (m *MockRecordLogEncoder) Close() error
Close mocks base method.
func (*MockRecordLogEncoder) EXPECT ¶
func (m *MockRecordLogEncoder) EXPECT() *MockRecordLogEncoderMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockRecordLogEncoder) Encode ¶
func (m *MockRecordLogEncoder) Encode(arg0 interface{}) error
Encode mocks base method.
type MockRecordLogEncoderMockRecorder ¶
type MockRecordLogEncoderMockRecorder struct {
// contains filtered or unexported fields
}
MockRecordLogEncoderMockRecorder is the mock recorder for MockRecordLogEncoder.
func (*MockRecordLogEncoderMockRecorder) Close ¶
func (mr *MockRecordLogEncoderMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockRecordLogEncoderMockRecorder) Encode ¶
func (mr *MockRecordLogEncoderMockRecorder) Encode(arg0 interface{}) *gomock.Call
Encode indicates an expected call of Encode.
type MockSelector ¶
type MockSelector struct {
// contains filtered or unexported fields
}
MockSelector is a mock of Selector interface.
func NewMockSelector ¶
func NewMockSelector(ctrl *gomock.Controller) *MockSelector
NewMockSelector creates a new mock instance.
func (*MockSelector) EXPECT ¶
func (m *MockSelector) EXPECT() *MockSelectorMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockSelector) GetHashN ¶
func (m *MockSelector) GetHashN(arg0 int, arg1 []byte) []string
GetHashN mocks base method.
func (*MockSelector) GetRandomN ¶
func (m *MockSelector) GetRandomN(arg0 int) []string
GetRandomN mocks base method.
func (*MockSelector) GetRoundRobinN ¶
func (m *MockSelector) GetRoundRobinN(arg0 int) []string
GetRoundRobinN mocks base method.
type MockSelectorMockRecorder ¶
type MockSelectorMockRecorder struct {
// contains filtered or unexported fields
}
MockSelectorMockRecorder is the mock recorder for MockSelector.
func (*MockSelectorMockRecorder) GetHashN ¶
func (mr *MockSelectorMockRecorder) GetHashN(arg0, arg1 interface{}) *gomock.Call
GetHashN indicates an expected call of GetHashN.
func (*MockSelectorMockRecorder) GetRandomN ¶
func (mr *MockSelectorMockRecorder) GetRandomN(arg0 interface{}) *gomock.Call
GetRandomN indicates an expected call of GetRandomN.
func (*MockSelectorMockRecorder) GetRoundRobinN ¶
func (mr *MockSelectorMockRecorder) GetRoundRobinN(arg0 interface{}) *gomock.Call
GetRoundRobinN indicates an expected call of GetRoundRobinN.
type MockStorageAPI ¶
type MockStorageAPI struct {
// contains filtered or unexported fields
}
MockStorageAPI is a mock of StorageAPI interface.
func NewMockStorageAPI ¶
func NewMockStorageAPI(ctrl *gomock.Controller) *MockStorageAPI
NewMockStorageAPI creates a new mock instance.
func (*MockStorageAPI) Close ¶
func (m *MockStorageAPI) Close(arg0 context.Context, arg1 string) error
Close mocks base method.
func (*MockStorageAPI) CreateChunk ¶
func (m *MockStorageAPI) CreateChunk(arg0 context.Context, arg1 string, arg2 *blobnode.CreateChunkArgs) error
CreateChunk mocks base method.
func (*MockStorageAPI) DeleteShard ¶
func (m *MockStorageAPI) DeleteShard(arg0 context.Context, arg1 string, arg2 *blobnode.DeleteShardArgs) error
DeleteShard mocks base method.
func (*MockStorageAPI) DiskInfo ¶
func (m *MockStorageAPI) DiskInfo(arg0 context.Context, arg1 string, arg2 *blobnode.DiskStatArgs) (*blobnode.DiskInfo, error)
DiskInfo mocks base method.
func (*MockStorageAPI) EXPECT ¶
func (m *MockStorageAPI) EXPECT() *MockStorageAPIMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockStorageAPI) GetShard ¶
func (m *MockStorageAPI) GetShard(arg0 context.Context, arg1 string, arg2 *blobnode.GetShardArgs) (io.ReadCloser, uint32, error)
GetShard mocks base method.
func (*MockStorageAPI) IsOnline ¶
func (m *MockStorageAPI) IsOnline(arg0 context.Context, arg1 string) bool
IsOnline mocks base method.
func (*MockStorageAPI) ListChunks ¶
func (m *MockStorageAPI) ListChunks(arg0 context.Context, arg1 string, arg2 *blobnode.ListChunkArgs) ([]*blobnode.ChunkInfo, error)
ListChunks mocks base method.
func (*MockStorageAPI) ListShards ¶
func (m *MockStorageAPI) ListShards(arg0 context.Context, arg1 string, arg2 *blobnode.ListShardsArgs) ([]*blobnode.ShardInfo, proto.BlobID, error)
ListShards mocks base method.
func (*MockStorageAPI) MarkDeleteShard ¶
func (m *MockStorageAPI) MarkDeleteShard(arg0 context.Context, arg1 string, arg2 *blobnode.DeleteShardArgs) error
MarkDeleteShard mocks base method.
func (*MockStorageAPI) PutShard ¶
func (m *MockStorageAPI) PutShard(arg0 context.Context, arg1 string, arg2 *blobnode.PutShardArgs) (uint32, error)
PutShard mocks base method.
func (*MockStorageAPI) RangeGetShard ¶
func (m *MockStorageAPI) RangeGetShard(arg0 context.Context, arg1 string, arg2 *blobnode.RangeGetShardArgs) (io.ReadCloser, uint32, error)
RangeGetShard mocks base method.
func (*MockStorageAPI) ReleaseChunk ¶
func (m *MockStorageAPI) ReleaseChunk(arg0 context.Context, arg1 string, arg2 *blobnode.ChangeChunkStatusArgs) error
ReleaseChunk mocks base method.
func (*MockStorageAPI) RepairShard ¶
func (m *MockStorageAPI) RepairShard(arg0 context.Context, arg1 string, arg2 *proto.ShardRepairTask) error
RepairShard mocks base method.
func (*MockStorageAPI) SetChunkReadonly ¶
func (m *MockStorageAPI) SetChunkReadonly(arg0 context.Context, arg1 string, arg2 *blobnode.ChangeChunkStatusArgs) error
SetChunkReadonly mocks base method.
func (*MockStorageAPI) SetChunkReadwrite ¶
func (m *MockStorageAPI) SetChunkReadwrite(arg0 context.Context, arg1 string, arg2 *blobnode.ChangeChunkStatusArgs) error
SetChunkReadwrite mocks base method.
func (*MockStorageAPI) StatChunk ¶
func (m *MockStorageAPI) StatChunk(arg0 context.Context, arg1 string, arg2 *blobnode.StatChunkArgs) (*blobnode.ChunkInfo, error)
StatChunk mocks base method.
func (*MockStorageAPI) StatShard ¶
func (m *MockStorageAPI) StatShard(arg0 context.Context, arg1 string, arg2 *blobnode.StatShardArgs) (*blobnode.ShardInfo, error)
StatShard mocks base method.
func (*MockStorageAPI) String ¶
func (m *MockStorageAPI) String(arg0 context.Context, arg1 string) string
String mocks base method.
func (*MockStorageAPI) WorkerStats ¶
func (m *MockStorageAPI) WorkerStats(arg0 context.Context, arg1 string) (blobnode.WorkerStats, error)
WorkerStats mocks base method.
type MockStorageAPIMockRecorder ¶
type MockStorageAPIMockRecorder struct {
// contains filtered or unexported fields
}
MockStorageAPIMockRecorder is the mock recorder for MockStorageAPI.
func (*MockStorageAPIMockRecorder) Close ¶
func (mr *MockStorageAPIMockRecorder) Close(arg0, arg1 interface{}) *gomock.Call
Close indicates an expected call of Close.
func (*MockStorageAPIMockRecorder) CreateChunk ¶
func (mr *MockStorageAPIMockRecorder) CreateChunk(arg0, arg1, arg2 interface{}) *gomock.Call
CreateChunk indicates an expected call of CreateChunk.
func (*MockStorageAPIMockRecorder) DeleteShard ¶
func (mr *MockStorageAPIMockRecorder) DeleteShard(arg0, arg1, arg2 interface{}) *gomock.Call
DeleteShard indicates an expected call of DeleteShard.
func (*MockStorageAPIMockRecorder) DiskInfo ¶
func (mr *MockStorageAPIMockRecorder) DiskInfo(arg0, arg1, arg2 interface{}) *gomock.Call
DiskInfo indicates an expected call of DiskInfo.
func (*MockStorageAPIMockRecorder) GetShard ¶
func (mr *MockStorageAPIMockRecorder) GetShard(arg0, arg1, arg2 interface{}) *gomock.Call
GetShard indicates an expected call of GetShard.
func (*MockStorageAPIMockRecorder) IsOnline ¶
func (mr *MockStorageAPIMockRecorder) IsOnline(arg0, arg1 interface{}) *gomock.Call
IsOnline indicates an expected call of IsOnline.
func (*MockStorageAPIMockRecorder) ListChunks ¶
func (mr *MockStorageAPIMockRecorder) ListChunks(arg0, arg1, arg2 interface{}) *gomock.Call
ListChunks indicates an expected call of ListChunks.
func (*MockStorageAPIMockRecorder) ListShards ¶
func (mr *MockStorageAPIMockRecorder) ListShards(arg0, arg1, arg2 interface{}) *gomock.Call
ListShards indicates an expected call of ListShards.
func (*MockStorageAPIMockRecorder) MarkDeleteShard ¶
func (mr *MockStorageAPIMockRecorder) MarkDeleteShard(arg0, arg1, arg2 interface{}) *gomock.Call
MarkDeleteShard indicates an expected call of MarkDeleteShard.
func (*MockStorageAPIMockRecorder) PutShard ¶
func (mr *MockStorageAPIMockRecorder) PutShard(arg0, arg1, arg2 interface{}) *gomock.Call
PutShard indicates an expected call of PutShard.
func (*MockStorageAPIMockRecorder) RangeGetShard ¶
func (mr *MockStorageAPIMockRecorder) RangeGetShard(arg0, arg1, arg2 interface{}) *gomock.Call
RangeGetShard indicates an expected call of RangeGetShard.
func (*MockStorageAPIMockRecorder) ReleaseChunk ¶
func (mr *MockStorageAPIMockRecorder) ReleaseChunk(arg0, arg1, arg2 interface{}) *gomock.Call
ReleaseChunk indicates an expected call of ReleaseChunk.
func (*MockStorageAPIMockRecorder) RepairShard ¶
func (mr *MockStorageAPIMockRecorder) RepairShard(arg0, arg1, arg2 interface{}) *gomock.Call
RepairShard indicates an expected call of RepairShard.
func (*MockStorageAPIMockRecorder) SetChunkReadonly ¶
func (mr *MockStorageAPIMockRecorder) SetChunkReadonly(arg0, arg1, arg2 interface{}) *gomock.Call
SetChunkReadonly indicates an expected call of SetChunkReadonly.
func (*MockStorageAPIMockRecorder) SetChunkReadwrite ¶
func (mr *MockStorageAPIMockRecorder) SetChunkReadwrite(arg0, arg1, arg2 interface{}) *gomock.Call
SetChunkReadwrite indicates an expected call of SetChunkReadwrite.
func (*MockStorageAPIMockRecorder) Stat ¶
func (mr *MockStorageAPIMockRecorder) Stat(arg0, arg1 interface{}) *gomock.Call
Stat indicates an expected call of Stat.
func (*MockStorageAPIMockRecorder) StatChunk ¶
func (mr *MockStorageAPIMockRecorder) StatChunk(arg0, arg1, arg2 interface{}) *gomock.Call
StatChunk indicates an expected call of StatChunk.
func (*MockStorageAPIMockRecorder) StatShard ¶
func (mr *MockStorageAPIMockRecorder) StatShard(arg0, arg1, arg2 interface{}) *gomock.Call
StatShard indicates an expected call of StatShard.
func (*MockStorageAPIMockRecorder) String ¶
func (mr *MockStorageAPIMockRecorder) String(arg0, arg1 interface{}) *gomock.Call
String indicates an expected call of String.
func (*MockStorageAPIMockRecorder) WorkerStats ¶
func (mr *MockStorageAPIMockRecorder) WorkerStats(arg0, arg1 interface{}) *gomock.Call
WorkerStats indicates an expected call of WorkerStats.
type MockSwitcher ¶
type MockSwitcher struct {
// contains filtered or unexported fields
}
MockSwitcher is a mock of ISwitcher interface.
func NewMockSwitcher ¶
func NewMockSwitcher(ctrl *gomock.Controller) *MockSwitcher
NewMockSwitcher creates a new mock instance.
func (*MockSwitcher) EXPECT ¶
func (m *MockSwitcher) EXPECT() *MockSwitcherMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
type MockSwitcherMockRecorder ¶
type MockSwitcherMockRecorder struct {
// contains filtered or unexported fields
}
MockSwitcherMockRecorder is the mock recorder for MockSwitcher.
func (*MockSwitcherMockRecorder) Enabled ¶
func (mr *MockSwitcherMockRecorder) Enabled() *gomock.Call
Enabled indicates an expected call of Enabled.
func (*MockSwitcherMockRecorder) WaitEnable ¶
func (mr *MockSwitcherMockRecorder) WaitEnable() *gomock.Call
WaitEnable indicates an expected call of WaitEnable.