Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Package mock is a generated GoMock package.
Index ¶
- type MockCDNMgr
- func (m *MockCDNMgr) Delete(ctx context.Context, taskID string) error
- func (m *MockCDNMgr) EXPECT() *MockCDNMgrMockRecorder
- func (m *MockCDNMgr) GetHTTPPath(ctx context.Context, taskID string) (string, error)
- func (m *MockCDNMgr) GetStatus(ctx context.Context, taskID string) (string, error)
- func (m *MockCDNMgr) TriggerCDN(ctx context.Context, taskInfo *types.TaskInfo) (*types.TaskInfo, error)
- type MockCDNMgrMockRecorder
- func (mr *MockCDNMgrMockRecorder) Delete(ctx, taskID interface{}) *gomock.Call
- func (mr *MockCDNMgrMockRecorder) GetHTTPPath(ctx, taskID interface{}) *gomock.Call
- func (mr *MockCDNMgrMockRecorder) GetStatus(ctx, taskID interface{}) *gomock.Call
- func (mr *MockCDNMgrMockRecorder) TriggerCDN(ctx, taskInfo interface{}) *gomock.Call
- type MockDfgetTaskMgr
- func (m *MockDfgetTaskMgr) Add(ctx context.Context, dfgetTask *types.DfGetTask) error
- func (m *MockDfgetTaskMgr) Delete(ctx context.Context, clientID, taskID string) error
- func (m *MockDfgetTaskMgr) EXPECT() *MockDfgetTaskMgrMockRecorder
- func (m *MockDfgetTaskMgr) Get(ctx context.Context, clientID, taskID string) (*types.DfGetTask, error)
- func (m *MockDfgetTaskMgr) GetCIDByPeerIDAndTaskID(ctx context.Context, peerID, taskID string) (string, error)
- func (m *MockDfgetTaskMgr) List(ctx context.Context, filter map[string]string) ([]*types.DfGetTask, error)
- func (m *MockDfgetTaskMgr) UpdateStatus(ctx context.Context, clientID, taskID, status string) error
- type MockDfgetTaskMgrMockRecorder
- func (mr *MockDfgetTaskMgrMockRecorder) Add(ctx, dfgetTask interface{}) *gomock.Call
- func (mr *MockDfgetTaskMgrMockRecorder) Delete(ctx, clientID, taskID interface{}) *gomock.Call
- func (mr *MockDfgetTaskMgrMockRecorder) Get(ctx, clientID, taskID interface{}) *gomock.Call
- func (mr *MockDfgetTaskMgrMockRecorder) GetCIDByPeerIDAndTaskID(ctx, peerID, taskID interface{}) *gomock.Call
- func (mr *MockDfgetTaskMgrMockRecorder) List(ctx, filter interface{}) *gomock.Call
- func (mr *MockDfgetTaskMgrMockRecorder) UpdateStatus(ctx, clientID, taskID, status interface{}) *gomock.Call
- type MockPeerMgr
- func (m *MockPeerMgr) DeRegister(ctx context.Context, peerID string) error
- func (m *MockPeerMgr) EXPECT() *MockPeerMgrMockRecorder
- func (m *MockPeerMgr) Get(ctx context.Context, peerID string) (*types.PeerInfo, error)
- func (m *MockPeerMgr) List(ctx context.Context, filter *util.PageFilter) ([]*types.PeerInfo, error)
- func (m *MockPeerMgr) Register(ctx context.Context, peerCreateRequest *types.PeerCreateRequest) (*types.PeerCreateResponse, error)
- type MockPeerMgrMockRecorder
- func (mr *MockPeerMgrMockRecorder) DeRegister(ctx, peerID interface{}) *gomock.Call
- func (mr *MockPeerMgrMockRecorder) Get(ctx, peerID interface{}) *gomock.Call
- func (mr *MockPeerMgrMockRecorder) List(ctx, filter interface{}) *gomock.Call
- func (mr *MockPeerMgrMockRecorder) Register(ctx, peerCreateRequest interface{}) *gomock.Call
- type MockProgressMgr
- func (m *MockProgressMgr) DeletePeerIDByPieceNum(ctx context.Context, taskID string, pieceNum int, peerID string) error
- func (m *MockProgressMgr) DeletePeerStateByPeerID(ctx context.Context, peerID string) error
- func (m *MockProgressMgr) DeletePieceProgressByCID(ctx context.Context, taskID, clientID string) error
- func (m *MockProgressMgr) EXPECT() *MockProgressMgrMockRecorder
- func (m *MockProgressMgr) GetBlackInfoByPeerID(ctx context.Context, peerID string) (*util.SyncMap, error)
- func (m *MockProgressMgr) GetPeerIDsByPieceNum(ctx context.Context, taskID string, pieceNum int) ([]string, error)
- func (m *MockProgressMgr) GetPeerStateByPeerID(ctx context.Context, peerID string) (*mgr.PeerState, error)
- func (m *MockProgressMgr) GetPeersByTaskID(ctx context.Context, taskID string) ([]*types.PeerInfo, error)
- func (m *MockProgressMgr) GetPieceProgressByCID(ctx context.Context, taskID, clientID, filter string) ([]int, error)
- func (m *MockProgressMgr) InitProgress(ctx context.Context, taskID, peerID, clientID string) error
- func (m *MockProgressMgr) UpdateClientProgress(ctx context.Context, taskID, srcCID, dstPID string, pieceNum, pieceStatus int) error
- func (m *MockProgressMgr) UpdateProgress(ctx context.Context, taskID, srcCID, srcPID, dstPID string, ...) error
- type MockProgressMgrMockRecorder
- func (mr *MockProgressMgrMockRecorder) DeletePeerIDByPieceNum(ctx, taskID, pieceNum, peerID interface{}) *gomock.Call
- func (mr *MockProgressMgrMockRecorder) DeletePeerStateByPeerID(ctx, peerID interface{}) *gomock.Call
- func (mr *MockProgressMgrMockRecorder) DeletePieceProgressByCID(ctx, taskID, clientID interface{}) *gomock.Call
- func (mr *MockProgressMgrMockRecorder) GetBlackInfoByPeerID(ctx, peerID interface{}) *gomock.Call
- func (mr *MockProgressMgrMockRecorder) GetPeerIDsByPieceNum(ctx, taskID, pieceNum interface{}) *gomock.Call
- func (mr *MockProgressMgrMockRecorder) GetPeerStateByPeerID(ctx, peerID interface{}) *gomock.Call
- func (mr *MockProgressMgrMockRecorder) GetPeersByTaskID(ctx, taskID interface{}) *gomock.Call
- func (mr *MockProgressMgrMockRecorder) GetPieceProgressByCID(ctx, taskID, clientID, filter interface{}) *gomock.Call
- func (mr *MockProgressMgrMockRecorder) InitProgress(ctx, taskID, peerID, clientID interface{}) *gomock.Call
- func (mr *MockProgressMgrMockRecorder) UpdateClientProgress(ctx, taskID, srcCID, dstPID, pieceNum, pieceStatus interface{}) *gomock.Call
- func (mr *MockProgressMgrMockRecorder) UpdateProgress(ctx, taskID, srcCID, srcPID, dstPID, pieceNum, pieceStatus interface{}) *gomock.Call
- type MockSchedulerMgr
- type MockSchedulerMgrMockRecorder
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockCDNMgr ¶
type MockCDNMgr struct {
// contains filtered or unexported fields
}
MockCDNMgr is a mock of CDNMgr interface
func NewMockCDNMgr ¶
func NewMockCDNMgr(ctrl *gomock.Controller) *MockCDNMgr
NewMockCDNMgr creates a new mock instance
func (*MockCDNMgr) Delete ¶
func (m *MockCDNMgr) Delete(ctx context.Context, taskID string) error
Delete mocks base method
func (*MockCDNMgr) EXPECT ¶
func (m *MockCDNMgr) EXPECT() *MockCDNMgrMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockCDNMgr) GetHTTPPath ¶
GetHTTPPath mocks base method
func (*MockCDNMgr) TriggerCDN ¶
func (m *MockCDNMgr) TriggerCDN(ctx context.Context, taskInfo *types.TaskInfo) (*types.TaskInfo, error)
TriggerCDN mocks base method
type MockCDNMgrMockRecorder ¶
type MockCDNMgrMockRecorder struct {
// contains filtered or unexported fields
}
MockCDNMgrMockRecorder is the mock recorder for MockCDNMgr
func (*MockCDNMgrMockRecorder) Delete ¶
func (mr *MockCDNMgrMockRecorder) Delete(ctx, taskID interface{}) *gomock.Call
Delete indicates an expected call of Delete
func (*MockCDNMgrMockRecorder) GetHTTPPath ¶
func (mr *MockCDNMgrMockRecorder) GetHTTPPath(ctx, taskID interface{}) *gomock.Call
GetHTTPPath indicates an expected call of GetHTTPPath
func (*MockCDNMgrMockRecorder) GetStatus ¶
func (mr *MockCDNMgrMockRecorder) GetStatus(ctx, taskID interface{}) *gomock.Call
GetStatus indicates an expected call of GetStatus
func (*MockCDNMgrMockRecorder) TriggerCDN ¶
func (mr *MockCDNMgrMockRecorder) TriggerCDN(ctx, taskInfo interface{}) *gomock.Call
TriggerCDN indicates an expected call of TriggerCDN
type MockDfgetTaskMgr ¶
type MockDfgetTaskMgr struct {
// contains filtered or unexported fields
}
MockDfgetTaskMgr is a mock of DfgetTaskMgr interface
func NewMockDfgetTaskMgr ¶
func NewMockDfgetTaskMgr(ctrl *gomock.Controller) *MockDfgetTaskMgr
NewMockDfgetTaskMgr creates a new mock instance
func (*MockDfgetTaskMgr) Delete ¶
func (m *MockDfgetTaskMgr) Delete(ctx context.Context, clientID, taskID string) error
Delete mocks base method
func (*MockDfgetTaskMgr) EXPECT ¶
func (m *MockDfgetTaskMgr) EXPECT() *MockDfgetTaskMgrMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockDfgetTaskMgr) Get ¶
func (m *MockDfgetTaskMgr) Get(ctx context.Context, clientID, taskID string) (*types.DfGetTask, error)
Get mocks base method
func (*MockDfgetTaskMgr) GetCIDByPeerIDAndTaskID ¶
func (m *MockDfgetTaskMgr) GetCIDByPeerIDAndTaskID(ctx context.Context, peerID, taskID string) (string, error)
GetCIDByPeerIDAndTaskID mocks base method
func (*MockDfgetTaskMgr) List ¶
func (m *MockDfgetTaskMgr) List(ctx context.Context, filter map[string]string) ([]*types.DfGetTask, error)
List mocks base method
func (*MockDfgetTaskMgr) UpdateStatus ¶
func (m *MockDfgetTaskMgr) UpdateStatus(ctx context.Context, clientID, taskID, status string) error
UpdateStatus mocks base method
type MockDfgetTaskMgrMockRecorder ¶
type MockDfgetTaskMgrMockRecorder struct {
// contains filtered or unexported fields
}
MockDfgetTaskMgrMockRecorder is the mock recorder for MockDfgetTaskMgr
func (*MockDfgetTaskMgrMockRecorder) Add ¶
func (mr *MockDfgetTaskMgrMockRecorder) Add(ctx, dfgetTask interface{}) *gomock.Call
Add indicates an expected call of Add
func (*MockDfgetTaskMgrMockRecorder) Delete ¶
func (mr *MockDfgetTaskMgrMockRecorder) Delete(ctx, clientID, taskID interface{}) *gomock.Call
Delete indicates an expected call of Delete
func (*MockDfgetTaskMgrMockRecorder) Get ¶
func (mr *MockDfgetTaskMgrMockRecorder) Get(ctx, clientID, taskID interface{}) *gomock.Call
Get indicates an expected call of Get
func (*MockDfgetTaskMgrMockRecorder) GetCIDByPeerIDAndTaskID ¶
func (mr *MockDfgetTaskMgrMockRecorder) GetCIDByPeerIDAndTaskID(ctx, peerID, taskID interface{}) *gomock.Call
GetCIDByPeerIDAndTaskID indicates an expected call of GetCIDByPeerIDAndTaskID
func (*MockDfgetTaskMgrMockRecorder) List ¶
func (mr *MockDfgetTaskMgrMockRecorder) List(ctx, filter interface{}) *gomock.Call
List indicates an expected call of List
func (*MockDfgetTaskMgrMockRecorder) UpdateStatus ¶
func (mr *MockDfgetTaskMgrMockRecorder) UpdateStatus(ctx, clientID, taskID, status interface{}) *gomock.Call
UpdateStatus indicates an expected call of UpdateStatus
type MockPeerMgr ¶
type MockPeerMgr struct {
// contains filtered or unexported fields
}
MockPeerMgr is a mock of PeerMgr interface
func NewMockPeerMgr ¶
func NewMockPeerMgr(ctrl *gomock.Controller) *MockPeerMgr
NewMockPeerMgr creates a new mock instance
func (*MockPeerMgr) DeRegister ¶
func (m *MockPeerMgr) DeRegister(ctx context.Context, peerID string) error
DeRegister mocks base method
func (*MockPeerMgr) EXPECT ¶
func (m *MockPeerMgr) EXPECT() *MockPeerMgrMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockPeerMgr) List ¶
func (m *MockPeerMgr) List(ctx context.Context, filter *util.PageFilter) ([]*types.PeerInfo, error)
List mocks base method
func (*MockPeerMgr) Register ¶
func (m *MockPeerMgr) Register(ctx context.Context, peerCreateRequest *types.PeerCreateRequest) (*types.PeerCreateResponse, error)
Register mocks base method
type MockPeerMgrMockRecorder ¶
type MockPeerMgrMockRecorder struct {
// contains filtered or unexported fields
}
MockPeerMgrMockRecorder is the mock recorder for MockPeerMgr
func (*MockPeerMgrMockRecorder) DeRegister ¶
func (mr *MockPeerMgrMockRecorder) DeRegister(ctx, peerID interface{}) *gomock.Call
DeRegister indicates an expected call of DeRegister
func (*MockPeerMgrMockRecorder) Get ¶
func (mr *MockPeerMgrMockRecorder) Get(ctx, peerID interface{}) *gomock.Call
Get indicates an expected call of Get
func (*MockPeerMgrMockRecorder) List ¶
func (mr *MockPeerMgrMockRecorder) List(ctx, filter interface{}) *gomock.Call
List indicates an expected call of List
func (*MockPeerMgrMockRecorder) Register ¶
func (mr *MockPeerMgrMockRecorder) Register(ctx, peerCreateRequest interface{}) *gomock.Call
Register indicates an expected call of Register
type MockProgressMgr ¶
type MockProgressMgr struct {
// contains filtered or unexported fields
}
MockProgressMgr is a mock of ProgressMgr interface
func NewMockProgressMgr ¶
func NewMockProgressMgr(ctrl *gomock.Controller) *MockProgressMgr
NewMockProgressMgr creates a new mock instance
func (*MockProgressMgr) DeletePeerIDByPieceNum ¶
func (m *MockProgressMgr) DeletePeerIDByPieceNum(ctx context.Context, taskID string, pieceNum int, peerID string) error
DeletePeerIDByPieceNum mocks base method
func (*MockProgressMgr) DeletePeerStateByPeerID ¶
func (m *MockProgressMgr) DeletePeerStateByPeerID(ctx context.Context, peerID string) error
DeletePeerStateByPeerID mocks base method
func (*MockProgressMgr) DeletePieceProgressByCID ¶
func (m *MockProgressMgr) DeletePieceProgressByCID(ctx context.Context, taskID, clientID string) error
DeletePieceProgressByCID mocks base method
func (*MockProgressMgr) EXPECT ¶
func (m *MockProgressMgr) EXPECT() *MockProgressMgrMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockProgressMgr) GetBlackInfoByPeerID ¶
func (m *MockProgressMgr) GetBlackInfoByPeerID(ctx context.Context, peerID string) (*util.SyncMap, error)
GetBlackInfoByPeerID mocks base method
func (*MockProgressMgr) GetPeerIDsByPieceNum ¶
func (m *MockProgressMgr) GetPeerIDsByPieceNum(ctx context.Context, taskID string, pieceNum int) ([]string, error)
GetPeerIDsByPieceNum mocks base method
func (*MockProgressMgr) GetPeerStateByPeerID ¶
func (m *MockProgressMgr) GetPeerStateByPeerID(ctx context.Context, peerID string) (*mgr.PeerState, error)
GetPeerStateByPeerID mocks base method
func (*MockProgressMgr) GetPeersByTaskID ¶
func (m *MockProgressMgr) GetPeersByTaskID(ctx context.Context, taskID string) ([]*types.PeerInfo, error)
GetPeersByTaskID mocks base method
func (*MockProgressMgr) GetPieceProgressByCID ¶
func (m *MockProgressMgr) GetPieceProgressByCID(ctx context.Context, taskID, clientID, filter string) ([]int, error)
GetPieceProgressByCID mocks base method
func (*MockProgressMgr) InitProgress ¶
func (m *MockProgressMgr) InitProgress(ctx context.Context, taskID, peerID, clientID string) error
InitProgress mocks base method
func (*MockProgressMgr) UpdateClientProgress ¶
func (m *MockProgressMgr) UpdateClientProgress(ctx context.Context, taskID, srcCID, dstPID string, pieceNum, pieceStatus int) error
UpdateClientProgress mocks base method
func (*MockProgressMgr) UpdateProgress ¶
func (m *MockProgressMgr) UpdateProgress(ctx context.Context, taskID, srcCID, srcPID, dstPID string, pieceNum, pieceStatus int) error
UpdateProgress mocks base method
type MockProgressMgrMockRecorder ¶
type MockProgressMgrMockRecorder struct {
// contains filtered or unexported fields
}
MockProgressMgrMockRecorder is the mock recorder for MockProgressMgr
func (*MockProgressMgrMockRecorder) DeletePeerIDByPieceNum ¶
func (mr *MockProgressMgrMockRecorder) DeletePeerIDByPieceNum(ctx, taskID, pieceNum, peerID interface{}) *gomock.Call
DeletePeerIDByPieceNum indicates an expected call of DeletePeerIDByPieceNum
func (*MockProgressMgrMockRecorder) DeletePeerStateByPeerID ¶
func (mr *MockProgressMgrMockRecorder) DeletePeerStateByPeerID(ctx, peerID interface{}) *gomock.Call
DeletePeerStateByPeerID indicates an expected call of DeletePeerStateByPeerID
func (*MockProgressMgrMockRecorder) DeletePieceProgressByCID ¶
func (mr *MockProgressMgrMockRecorder) DeletePieceProgressByCID(ctx, taskID, clientID interface{}) *gomock.Call
DeletePieceProgressByCID indicates an expected call of DeletePieceProgressByCID
func (*MockProgressMgrMockRecorder) GetBlackInfoByPeerID ¶
func (mr *MockProgressMgrMockRecorder) GetBlackInfoByPeerID(ctx, peerID interface{}) *gomock.Call
GetBlackInfoByPeerID indicates an expected call of GetBlackInfoByPeerID
func (*MockProgressMgrMockRecorder) GetPeerIDsByPieceNum ¶
func (mr *MockProgressMgrMockRecorder) GetPeerIDsByPieceNum(ctx, taskID, pieceNum interface{}) *gomock.Call
GetPeerIDsByPieceNum indicates an expected call of GetPeerIDsByPieceNum
func (*MockProgressMgrMockRecorder) GetPeerStateByPeerID ¶
func (mr *MockProgressMgrMockRecorder) GetPeerStateByPeerID(ctx, peerID interface{}) *gomock.Call
GetPeerStateByPeerID indicates an expected call of GetPeerStateByPeerID
func (*MockProgressMgrMockRecorder) GetPeersByTaskID ¶
func (mr *MockProgressMgrMockRecorder) GetPeersByTaskID(ctx, taskID interface{}) *gomock.Call
GetPeersByTaskID indicates an expected call of GetPeersByTaskID
func (*MockProgressMgrMockRecorder) GetPieceProgressByCID ¶
func (mr *MockProgressMgrMockRecorder) GetPieceProgressByCID(ctx, taskID, clientID, filter interface{}) *gomock.Call
GetPieceProgressByCID indicates an expected call of GetPieceProgressByCID
func (*MockProgressMgrMockRecorder) InitProgress ¶
func (mr *MockProgressMgrMockRecorder) InitProgress(ctx, taskID, peerID, clientID interface{}) *gomock.Call
InitProgress indicates an expected call of InitProgress
func (*MockProgressMgrMockRecorder) UpdateClientProgress ¶
func (mr *MockProgressMgrMockRecorder) UpdateClientProgress(ctx, taskID, srcCID, dstPID, pieceNum, pieceStatus interface{}) *gomock.Call
UpdateClientProgress indicates an expected call of UpdateClientProgress
func (*MockProgressMgrMockRecorder) UpdateProgress ¶
func (mr *MockProgressMgrMockRecorder) UpdateProgress(ctx, taskID, srcCID, srcPID, dstPID, pieceNum, pieceStatus interface{}) *gomock.Call
UpdateProgress indicates an expected call of UpdateProgress
type MockSchedulerMgr ¶
type MockSchedulerMgr struct {
// contains filtered or unexported fields
}
MockSchedulerMgr is a mock of SchedulerMgr interface
func NewMockSchedulerMgr ¶
func NewMockSchedulerMgr(ctrl *gomock.Controller) *MockSchedulerMgr
NewMockSchedulerMgr creates a new mock instance
func (*MockSchedulerMgr) EXPECT ¶
func (m *MockSchedulerMgr) EXPECT() *MockSchedulerMgrMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockSchedulerMgr) Schedule ¶
func (m *MockSchedulerMgr) Schedule(ctx context.Context, taskID, clientID, peerID string) ([]*mgr.PieceResult, error)
Schedule mocks base method
type MockSchedulerMgrMockRecorder ¶
type MockSchedulerMgrMockRecorder struct {
// contains filtered or unexported fields
}
MockSchedulerMgrMockRecorder is the mock recorder for MockSchedulerMgr
func (*MockSchedulerMgrMockRecorder) Schedule ¶
func (mr *MockSchedulerMgrMockRecorder) Schedule(ctx, taskID, clientID, peerID interface{}) *gomock.Call
Schedule indicates an expected call of Schedule