Documentation ¶
Overview ¶
Package mock_storage is a generated GoMock package.
Index ¶
- type MockManager
- func (m *MockManager) Alive(alive time.Duration) bool
- func (m *MockManager) CleanUp()
- func (m *MockManager) EXPECT() *MockManagerMockRecorder
- func (m *MockManager) FindCompletedTask(taskID string) *storage.ReusePeerTask
- func (m *MockManager) GetPieces(ctx context.Context, req *base.PieceTaskRequest) (*base.PiecePacket, error)
- func (m *MockManager) Keep()
- func (m *MockManager) ReadAllPieces(ctx context.Context, req *storage.PeerTaskMetaData) (io.ReadCloser, error)
- func (m *MockManager) ReadPiece(ctx context.Context, req *storage.ReadPieceRequest) (io.Reader, io.Closer, error)
- func (m *MockManager) RegisterTask(ctx context.Context, req storage.RegisterTaskRequest) error
- func (m *MockManager) Store(ctx context.Context, req *storage.StoreRequest) error
- func (m *MockManager) UpdateTask(ctx context.Context, req *storage.UpdateTaskRequest) error
- func (m *MockManager) WritePiece(ctx context.Context, req *storage.WritePieceRequest) (int64, error)
- type MockManagerMockRecorder
- func (mr *MockManagerMockRecorder) Alive(alive interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) CleanUp() *gomock.Call
- func (mr *MockManagerMockRecorder) FindCompletedTask(taskID interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) GetPieces(ctx, req interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) Keep() *gomock.Call
- func (mr *MockManagerMockRecorder) ReadAllPieces(ctx, req interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) ReadPiece(ctx, req interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) RegisterTask(ctx, req interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) Store(ctx, req interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) UpdateTask(ctx, req interface{}) *gomock.Call
- func (mr *MockManagerMockRecorder) WritePiece(ctx, req interface{}) *gomock.Call
- type MockReclaimer
- type MockReclaimerMockRecorder
- type MockTaskStorageDriver
- func (m *MockTaskStorageDriver) EXPECT() *MockTaskStorageDriverMockRecorder
- func (m *MockTaskStorageDriver) GetPieces(ctx context.Context, req *base.PieceTaskRequest) (*base.PiecePacket, error)
- func (m *MockTaskStorageDriver) ReadAllPieces(ctx context.Context, req *storage.PeerTaskMetaData) (io.ReadCloser, error)
- func (m *MockTaskStorageDriver) ReadPiece(ctx context.Context, req *storage.ReadPieceRequest) (io.Reader, io.Closer, error)
- func (m *MockTaskStorageDriver) Store(ctx context.Context, req *storage.StoreRequest) error
- func (m *MockTaskStorageDriver) UpdateTask(ctx context.Context, req *storage.UpdateTaskRequest) error
- func (m *MockTaskStorageDriver) WritePiece(ctx context.Context, req *storage.WritePieceRequest) (int64, error)
- type MockTaskStorageDriverMockRecorder
- func (mr *MockTaskStorageDriverMockRecorder) GetPieces(ctx, req interface{}) *gomock.Call
- func (mr *MockTaskStorageDriverMockRecorder) ReadAllPieces(ctx, req interface{}) *gomock.Call
- func (mr *MockTaskStorageDriverMockRecorder) ReadPiece(ctx, req interface{}) *gomock.Call
- func (mr *MockTaskStorageDriverMockRecorder) Store(ctx, req interface{}) *gomock.Call
- func (mr *MockTaskStorageDriverMockRecorder) UpdateTask(ctx, req interface{}) *gomock.Call
- func (mr *MockTaskStorageDriverMockRecorder) WritePiece(ctx, req interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockManager ¶
type MockManager struct {
// contains filtered or unexported fields
}
MockManager is a mock of Manager interface.
func NewMockManager ¶
func NewMockManager(ctrl *gomock.Controller) *MockManager
NewMockManager creates a new mock instance.
func (*MockManager) Alive ¶
func (m *MockManager) Alive(alive time.Duration) bool
Alive mocks base method.
func (*MockManager) EXPECT ¶
func (m *MockManager) EXPECT() *MockManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockManager) FindCompletedTask ¶
func (m *MockManager) FindCompletedTask(taskID string) *storage.ReusePeerTask
FindCompletedTask mocks base method.
func (*MockManager) GetPieces ¶
func (m *MockManager) GetPieces(ctx context.Context, req *base.PieceTaskRequest) (*base.PiecePacket, error)
GetPieces mocks base method.
func (*MockManager) ReadAllPieces ¶
func (m *MockManager) ReadAllPieces(ctx context.Context, req *storage.PeerTaskMetaData) (io.ReadCloser, error)
ReadAllPieces mocks base method.
func (*MockManager) ReadPiece ¶
func (m *MockManager) ReadPiece(ctx context.Context, req *storage.ReadPieceRequest) (io.Reader, io.Closer, error)
ReadPiece mocks base method.
func (*MockManager) RegisterTask ¶
func (m *MockManager) RegisterTask(ctx context.Context, req storage.RegisterTaskRequest) error
RegisterTask mocks base method.
func (*MockManager) Store ¶
func (m *MockManager) Store(ctx context.Context, req *storage.StoreRequest) error
Store mocks base method.
func (*MockManager) UpdateTask ¶
func (m *MockManager) UpdateTask(ctx context.Context, req *storage.UpdateTaskRequest) error
UpdateTask mocks base method.
func (*MockManager) WritePiece ¶
func (m *MockManager) WritePiece(ctx context.Context, req *storage.WritePieceRequest) (int64, error)
WritePiece mocks base method.
type MockManagerMockRecorder ¶
type MockManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockManagerMockRecorder is the mock recorder for MockManager.
func (*MockManagerMockRecorder) Alive ¶
func (mr *MockManagerMockRecorder) Alive(alive interface{}) *gomock.Call
Alive indicates an expected call of Alive.
func (*MockManagerMockRecorder) CleanUp ¶
func (mr *MockManagerMockRecorder) CleanUp() *gomock.Call
CleanUp indicates an expected call of CleanUp.
func (*MockManagerMockRecorder) FindCompletedTask ¶
func (mr *MockManagerMockRecorder) FindCompletedTask(taskID interface{}) *gomock.Call
FindCompletedTask indicates an expected call of FindCompletedTask.
func (*MockManagerMockRecorder) GetPieces ¶
func (mr *MockManagerMockRecorder) GetPieces(ctx, req interface{}) *gomock.Call
GetPieces indicates an expected call of GetPieces.
func (*MockManagerMockRecorder) Keep ¶
func (mr *MockManagerMockRecorder) Keep() *gomock.Call
Keep indicates an expected call of Keep.
func (*MockManagerMockRecorder) ReadAllPieces ¶
func (mr *MockManagerMockRecorder) ReadAllPieces(ctx, req interface{}) *gomock.Call
ReadAllPieces indicates an expected call of ReadAllPieces.
func (*MockManagerMockRecorder) ReadPiece ¶
func (mr *MockManagerMockRecorder) ReadPiece(ctx, req interface{}) *gomock.Call
ReadPiece indicates an expected call of ReadPiece.
func (*MockManagerMockRecorder) RegisterTask ¶
func (mr *MockManagerMockRecorder) RegisterTask(ctx, req interface{}) *gomock.Call
RegisterTask indicates an expected call of RegisterTask.
func (*MockManagerMockRecorder) Store ¶
func (mr *MockManagerMockRecorder) Store(ctx, req interface{}) *gomock.Call
Store indicates an expected call of Store.
func (*MockManagerMockRecorder) UpdateTask ¶
func (mr *MockManagerMockRecorder) UpdateTask(ctx, req interface{}) *gomock.Call
UpdateTask indicates an expected call of UpdateTask.
func (*MockManagerMockRecorder) WritePiece ¶
func (mr *MockManagerMockRecorder) WritePiece(ctx, req interface{}) *gomock.Call
WritePiece indicates an expected call of WritePiece.
type MockReclaimer ¶
type MockReclaimer struct {
// contains filtered or unexported fields
}
MockReclaimer is a mock of Reclaimer interface.
func NewMockReclaimer ¶
func NewMockReclaimer(ctrl *gomock.Controller) *MockReclaimer
NewMockReclaimer creates a new mock instance.
func (*MockReclaimer) CanReclaim ¶
func (m *MockReclaimer) CanReclaim() bool
CanReclaim mocks base method.
func (*MockReclaimer) EXPECT ¶
func (m *MockReclaimer) EXPECT() *MockReclaimerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockReclaimer) MarkReclaim ¶
func (m *MockReclaimer) MarkReclaim()
MarkReclaim mocks base method.
type MockReclaimerMockRecorder ¶
type MockReclaimerMockRecorder struct {
// contains filtered or unexported fields
}
MockReclaimerMockRecorder is the mock recorder for MockReclaimer.
func (*MockReclaimerMockRecorder) CanReclaim ¶
func (mr *MockReclaimerMockRecorder) CanReclaim() *gomock.Call
CanReclaim indicates an expected call of CanReclaim.
func (*MockReclaimerMockRecorder) MarkReclaim ¶
func (mr *MockReclaimerMockRecorder) MarkReclaim() *gomock.Call
MarkReclaim indicates an expected call of MarkReclaim.
func (*MockReclaimerMockRecorder) Reclaim ¶
func (mr *MockReclaimerMockRecorder) Reclaim() *gomock.Call
Reclaim indicates an expected call of Reclaim.
type MockTaskStorageDriver ¶
type MockTaskStorageDriver struct {
// contains filtered or unexported fields
}
MockTaskStorageDriver is a mock of TaskStorageDriver interface.
func NewMockTaskStorageDriver ¶
func NewMockTaskStorageDriver(ctrl *gomock.Controller) *MockTaskStorageDriver
NewMockTaskStorageDriver creates a new mock instance.
func (*MockTaskStorageDriver) EXPECT ¶
func (m *MockTaskStorageDriver) EXPECT() *MockTaskStorageDriverMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTaskStorageDriver) GetPieces ¶
func (m *MockTaskStorageDriver) GetPieces(ctx context.Context, req *base.PieceTaskRequest) (*base.PiecePacket, error)
GetPieces mocks base method.
func (*MockTaskStorageDriver) ReadAllPieces ¶
func (m *MockTaskStorageDriver) ReadAllPieces(ctx context.Context, req *storage.PeerTaskMetaData) (io.ReadCloser, error)
ReadAllPieces mocks base method.
func (*MockTaskStorageDriver) ReadPiece ¶
func (m *MockTaskStorageDriver) ReadPiece(ctx context.Context, req *storage.ReadPieceRequest) (io.Reader, io.Closer, error)
ReadPiece mocks base method.
func (*MockTaskStorageDriver) Store ¶
func (m *MockTaskStorageDriver) Store(ctx context.Context, req *storage.StoreRequest) error
Store mocks base method.
func (*MockTaskStorageDriver) UpdateTask ¶
func (m *MockTaskStorageDriver) UpdateTask(ctx context.Context, req *storage.UpdateTaskRequest) error
UpdateTask mocks base method.
func (*MockTaskStorageDriver) WritePiece ¶
func (m *MockTaskStorageDriver) WritePiece(ctx context.Context, req *storage.WritePieceRequest) (int64, error)
WritePiece mocks base method.
type MockTaskStorageDriverMockRecorder ¶
type MockTaskStorageDriverMockRecorder struct {
// contains filtered or unexported fields
}
MockTaskStorageDriverMockRecorder is the mock recorder for MockTaskStorageDriver.
func (*MockTaskStorageDriverMockRecorder) GetPieces ¶
func (mr *MockTaskStorageDriverMockRecorder) GetPieces(ctx, req interface{}) *gomock.Call
GetPieces indicates an expected call of GetPieces.
func (*MockTaskStorageDriverMockRecorder) ReadAllPieces ¶
func (mr *MockTaskStorageDriverMockRecorder) ReadAllPieces(ctx, req interface{}) *gomock.Call
ReadAllPieces indicates an expected call of ReadAllPieces.
func (*MockTaskStorageDriverMockRecorder) ReadPiece ¶
func (mr *MockTaskStorageDriverMockRecorder) ReadPiece(ctx, req interface{}) *gomock.Call
ReadPiece indicates an expected call of ReadPiece.
func (*MockTaskStorageDriverMockRecorder) Store ¶
func (mr *MockTaskStorageDriverMockRecorder) Store(ctx, req interface{}) *gomock.Call
Store indicates an expected call of Store.
func (*MockTaskStorageDriverMockRecorder) UpdateTask ¶
func (mr *MockTaskStorageDriverMockRecorder) UpdateTask(ctx, req interface{}) *gomock.Call
UpdateTask indicates an expected call of UpdateTask.
func (*MockTaskStorageDriverMockRecorder) WritePiece ¶
func (mr *MockTaskStorageDriverMockRecorder) WritePiece(ctx, req interface{}) *gomock.Call
WritePiece indicates an expected call of WritePiece.