mock

package
v1.0.5 Latest Latest
Warning

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

 Go to latest Published: Aug 25, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

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

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) CheckFile added in v1.0.0 

func (m *MockCDNMgr) CheckFile(ctx context.Context, taskID string) bool

CheckFile mocks base method

func (*MockCDNMgr) Delete 

func (m *MockCDNMgr) Delete(ctx context.Context, taskID string, force bool) 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) GetGCTaskIDs added in v1.0.0 

func (m *MockCDNMgr) GetGCTaskIDs(ctx context.Context, taskMgr mgr.TaskMgr) ([]string, error)

GetGCTaskIDs mocks base method

func (*MockCDNMgr) GetHTTPPath 

func (m *MockCDNMgr) GetHTTPPath(ctx context.Context, taskInfo *types.TaskInfo) (string, error)

GetHTTPPath mocks base method

func (*MockCDNMgr) GetPieceMD5 added in v1.0.0 

func (m *MockCDNMgr) GetPieceMD5(ctx context.Context, taskID string, pieceNum int, pieceRange, source string) (string, error)

GetPieceMD5 mocks base method

func (*MockCDNMgr) GetStatus 

func (m *MockCDNMgr) GetStatus(ctx context.Context, taskID string) (string, error)

GetStatus 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) CheckFile added in v1.0.0 

func (mr *MockCDNMgrMockRecorder) CheckFile(ctx, taskID interface{}) *gomock.Call

CheckFile indicates an expected call of CheckFile

func (*MockCDNMgrMockRecorder) Delete 

func (mr *MockCDNMgrMockRecorder) Delete(ctx, taskID, force interface{}) *gomock.Call

Delete indicates an expected call of Delete

func (*MockCDNMgrMockRecorder) GetGCTaskIDs added in v1.0.0 

func (mr *MockCDNMgrMockRecorder) GetGCTaskIDs(ctx, taskMgr interface{}) *gomock.Call

GetGCTaskIDs indicates an expected call of GetGCTaskIDs

func (*MockCDNMgrMockRecorder) GetHTTPPath 

func (mr *MockCDNMgrMockRecorder) GetHTTPPath(ctx, taskInfo interface{}) *gomock.Call

GetHTTPPath indicates an expected call of GetHTTPPath

func (*MockCDNMgrMockRecorder) GetPieceMD5 added in v1.0.0 

func (mr *MockCDNMgrMockRecorder) GetPieceMD5(ctx, taskID, pieceNum, pieceRange, source interface{}) *gomock.Call

GetPieceMD5 indicates an expected call of GetPieceMD5

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

func (m *MockDfgetTaskMgr) Add(ctx context.Context, dfgetTask *types.DfGetTask) error

Add mocks base method

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) GetCIDAndTaskIDsByPeerID added in v1.0.0 

func (m *MockDfgetTaskMgr) GetCIDAndTaskIDsByPeerID(ctx context.Context, peerID string) (map[string]string, error)

GetCIDAndTaskIDsByPeerID mocks base method

func (*MockDfgetTaskMgr) GetCIDByPeerIDAndTaskID 

func (m *MockDfgetTaskMgr) GetCIDByPeerIDAndTaskID(ctx context.Context, peerID, taskID string) (string, error)

GetCIDByPeerIDAndTaskID mocks base method

func (*MockDfgetTaskMgr) GetCIDsByTaskID added in v1.0.0 

func (m *MockDfgetTaskMgr) GetCIDsByTaskID(ctx context.Context, taskID string) ([]string, error)

GetCIDsByTaskID 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) GetCIDAndTaskIDsByPeerID added in v1.0.0 

func (mr *MockDfgetTaskMgrMockRecorder) GetCIDAndTaskIDsByPeerID(ctx, peerID interface{}) *gomock.Call

GetCIDAndTaskIDsByPeerID indicates an expected call of GetCIDAndTaskIDsByPeerID

func (*MockDfgetTaskMgrMockRecorder) GetCIDByPeerIDAndTaskID 

func (mr *MockDfgetTaskMgrMockRecorder) GetCIDByPeerIDAndTaskID(ctx, peerID, taskID interface{}) *gomock.Call

GetCIDByPeerIDAndTaskID indicates an expected call of GetCIDByPeerIDAndTaskID

func (*MockDfgetTaskMgrMockRecorder) GetCIDsByTaskID added in v1.0.0 

func (mr *MockDfgetTaskMgrMockRecorder) GetCIDsByTaskID(ctx, taskID interface{}) *gomock.Call

GetCIDsByTaskID indicates an expected call of GetCIDsByTaskID

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

func (m *MockPeerMgr) Get(ctx context.Context, peerID string) (*types.PeerInfo, error)

Get mocks base method

func (*MockPeerMgr) GetAllPeerIDs added in v1.0.0 

func (m *MockPeerMgr) GetAllPeerIDs(ctx context.Context) []string

GetAllPeerIDs mocks base method

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) GetAllPeerIDs added in v1.0.0 

func (mr *MockPeerMgrMockRecorder) GetAllPeerIDs(ctx interface{}) *gomock.Call

GetAllPeerIDs indicates an expected call of GetAllPeerIDs

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) DeleteCID added in v1.0.0 

func (m *MockProgressMgr) DeleteCID(ctx context.Context, clientID string) error

DeleteCID mocks base method

func (*MockProgressMgr) DeletePeerID added in v1.0.0 

func (m *MockProgressMgr) DeletePeerID(ctx context.Context, peerID string) error

DeletePeerID mocks base method

func (*MockProgressMgr) DeletePeerIDByPieceNum 

func (m *MockProgressMgr) DeletePeerIDByPieceNum(ctx context.Context, taskID string, pieceNum int, peerID string) error

DeletePeerIDByPieceNum mocks base method

func (*MockProgressMgr) DeleteTaskID added in v1.0.0 

func (m *MockProgressMgr) DeleteTaskID(ctx context.Context, taskID string, pieceTotal int) error

DeleteTaskID 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) (*syncmap.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) UpdatePeerServiceDown added in v1.0.0 

func (m *MockProgressMgr) UpdatePeerServiceDown(ctx context.Context, peerID string) error

UpdatePeerServiceDown 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

func (*MockProgressMgr) UpdateSuperLoad added in v1.0.0 

func (m *MockProgressMgr) UpdateSuperLoad(ctx context.Context, taskID string, delta, limit int32) (bool, error)

UpdateSuperLoad mocks base method

type MockProgressMgrMockRecorder 

type MockProgressMgrMockRecorder struct {
	// contains filtered or unexported fields
}

MockProgressMgrMockRecorder is the mock recorder for MockProgressMgr

func (*MockProgressMgrMockRecorder) DeleteCID added in v1.0.0 

func (mr *MockProgressMgrMockRecorder) DeleteCID(ctx, clientID interface{}) *gomock.Call

DeleteCID indicates an expected call of DeleteCID

func (*MockProgressMgrMockRecorder) DeletePeerID added in v1.0.0 

func (mr *MockProgressMgrMockRecorder) DeletePeerID(ctx, peerID interface{}) *gomock.Call

DeletePeerID indicates an expected call of DeletePeerID

func (*MockProgressMgrMockRecorder) DeletePeerIDByPieceNum 

func (mr *MockProgressMgrMockRecorder) DeletePeerIDByPieceNum(ctx, taskID, pieceNum, peerID interface{}) *gomock.Call

DeletePeerIDByPieceNum indicates an expected call of DeletePeerIDByPieceNum

func (*MockProgressMgrMockRecorder) DeleteTaskID added in v1.0.0 

func (mr *MockProgressMgrMockRecorder) DeleteTaskID(ctx, taskID, pieceTotal interface{}) *gomock.Call

DeleteTaskID indicates an expected call of DeleteTaskID

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) UpdatePeerServiceDown added in v1.0.0 

func (mr *MockProgressMgrMockRecorder) UpdatePeerServiceDown(ctx, peerID interface{}) *gomock.Call

UpdatePeerServiceDown indicates an expected call of UpdatePeerServiceDown

func (*MockProgressMgrMockRecorder) UpdateProgress 

func (mr *MockProgressMgrMockRecorder) UpdateProgress(ctx, taskID, srcCID, srcPID, dstPID, pieceNum, pieceStatus interface{}) *gomock.Call

UpdateProgress indicates an expected call of UpdateProgress

func (*MockProgressMgrMockRecorder) UpdateSuperLoad added in v1.0.0 

func (mr *MockProgressMgrMockRecorder) UpdateSuperLoad(ctx, taskID, delta, limit interface{}) *gomock.Call

UpdateSuperLoad indicates an expected call of UpdateSuperLoad

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

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.