mocks

package
v0.0.0-...-303e327 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 22, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

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

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.

func (*MockAccessAPI) Put 

func (m *MockAccessAPI) Put(arg0 context.Context, arg1 *access.PutArgs) (access.Location, access.HashSumMap, error)

Put 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) GetConfig 

func (m *MockClientAPI) GetConfig(arg0 context.Context, arg1 string) (string, error)

GetConfig mocks base method.

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 

func (m *MockIScheduler) LeaderStats(arg0 context.Context) (scheduler.TasksStat, error)

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) Stats 

func (m *MockIScheduler) Stats(arg0 context.Context, arg1 string) (scheduler.TasksStat, error)

Stats mocks base method.

func (*MockIScheduler) UpdateVolume 

func (m *MockIScheduler) UpdateVolume(arg0 context.Context, arg1 string, arg2 proto.Vid) error

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) Close 

func (m *MockRPCClient) Close()

Close mocks base method.

func (*MockRPCClient) Delete 

func (m *MockRPCClient) Delete(arg0 context.Context, arg1 string) (*http.Response, error)

Delete mocks base method.

func (*MockRPCClient) Do 

func (m *MockRPCClient) Do(arg0 context.Context, arg1 *http.Request) (*http.Response, error)

Do mocks base method.

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) Get 

func (m *MockRPCClient) Get(arg0 context.Context, arg1 string) (*http.Response, error)

Get mocks base method.

func (*MockRPCClient) GetWith 

func (m *MockRPCClient) GetWith(arg0 context.Context, arg1 string, arg2 interface{}) error

GetWith mocks base method.

func (*MockRPCClient) Head 

func (m *MockRPCClient) Head(arg0 context.Context, arg1 string) (*http.Response, error)

Head 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.

func (*MockRPCClient) Put 

func (m *MockRPCClient) Put(arg0 context.Context, arg1 string, arg2 interface{}) (*http.Response, error)

Put mocks base method.

func (*MockRPCClient) PutWith 

func (m *MockRPCClient) PutWith(arg0 context.Context, arg1 string, arg2, arg3 interface{}, arg4 ...rpc.Option) error

PutWith 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) Stop 

func (m *MockRaftServer) Stop()

Stop 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) Stat 

func (m *MockStorageAPI) Stat(arg0 context.Context, arg1 string) ([]*blobnode.DiskInfo, error)

Stat 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.

func (*MockSwitcher) Enabled 

func (m *MockSwitcher) Enabled() bool

Enabled mocks base method.

func (*MockSwitcher) WaitEnable 

func (m *MockSwitcher) WaitEnable()

WaitEnable mocks base method.

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.