mocks

package
v2.1.43 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Code generated by MockGen. DO NOT EDIT. Source: storage_manager.go

Generated by this command: 

mockgen -destination mocks/stroage_manager_mock.go -source storage_manager.go -package mocks

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

func (m *MockManager) CleanUp()

CleanUp 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) FindCompletedSubTask 

func (m *MockManager) FindCompletedSubTask(taskID string) *storage.ReusePeerTask

FindCompletedSubTask mocks base method.

func (*MockManager) FindCompletedTask 

func (m *MockManager) FindCompletedTask(taskID string) *storage.ReusePeerTask

FindCompletedTask mocks base method.

func (*MockManager) FindPartialCompletedTask 

func (m *MockManager) FindPartialCompletedTask(taskID string, rg *http.Range) *storage.ReusePeerTask

FindPartialCompletedTask mocks base method.

func (*MockManager) GetExtendAttribute 

func (m *MockManager) GetExtendAttribute(ctx context.Context, req *storage.PeerTaskMetadata) (*common.ExtendAttribute, error)

GetExtendAttribute mocks base method.

func (*MockManager) GetPieces 

func (m *MockManager) GetPieces(ctx context.Context, req *common.PieceTaskRequest) (*common.PiecePacket, error)

GetPieces mocks base method.

func (*MockManager) GetTotalPieces 

func (m *MockManager) GetTotalPieces(ctx context.Context, req *storage.PeerTaskMetadata) (int32, error)

GetTotalPieces mocks base method.

func (*MockManager) IsInvalid 

func (m *MockManager) IsInvalid(req *storage.PeerTaskMetadata) (bool, error)

IsInvalid mocks base method.

func (*MockManager) Keep 

func (m *MockManager) Keep()

Keep mocks base method.

func (*MockManager) ListAllPeers added in v2.1.40 

func (m *MockManager) ListAllPeers(perGroupCount int) [][]*dfdaemon.PeerMetadata

ListAllPeers mocks base method.

func (*MockManager) ReadAllPieces 

func (m *MockManager) ReadAllPieces(ctx context.Context, req *storage.ReadAllPiecesRequest) (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) RegisterSubTask 

func (m *MockManager) RegisterSubTask(ctx context.Context, req *storage.RegisterSubTaskRequest) (storage.TaskStorageDriver, error)

RegisterSubTask mocks base method.

func (*MockManager) RegisterTask 

func (m *MockManager) RegisterTask(ctx context.Context, req *storage.RegisterTaskRequest) (storage.TaskStorageDriver, 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) UnregisterTask 

func (m *MockManager) UnregisterTask(ctx context.Context, req storage.CommonTaskRequest) error

UnregisterTask mocks base method.

func (*MockManager) UpdateTask 

func (m *MockManager) UpdateTask(ctx context.Context, req *storage.UpdateTaskRequest) error

UpdateTask mocks base method.

func (*MockManager) ValidateDigest 

func (m *MockManager) ValidateDigest(req *storage.PeerTaskMetadata) error

ValidateDigest 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 any) *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) FindCompletedSubTask 

func (mr *MockManagerMockRecorder) FindCompletedSubTask(taskID any) *gomock.Call

FindCompletedSubTask indicates an expected call of FindCompletedSubTask.

func (*MockManagerMockRecorder) FindCompletedTask 

func (mr *MockManagerMockRecorder) FindCompletedTask(taskID any) *gomock.Call

FindCompletedTask indicates an expected call of FindCompletedTask.

func (*MockManagerMockRecorder) FindPartialCompletedTask 

func (mr *MockManagerMockRecorder) FindPartialCompletedTask(taskID, rg any) *gomock.Call

FindPartialCompletedTask indicates an expected call of FindPartialCompletedTask.

func (*MockManagerMockRecorder) GetExtendAttribute 

func (mr *MockManagerMockRecorder) GetExtendAttribute(ctx, req any) *gomock.Call

GetExtendAttribute indicates an expected call of GetExtendAttribute.

func (*MockManagerMockRecorder) GetPieces 

func (mr *MockManagerMockRecorder) GetPieces(ctx, req any) *gomock.Call

GetPieces indicates an expected call of GetPieces.

func (*MockManagerMockRecorder) GetTotalPieces 

func (mr *MockManagerMockRecorder) GetTotalPieces(ctx, req any) *gomock.Call

GetTotalPieces indicates an expected call of GetTotalPieces.

func (*MockManagerMockRecorder) IsInvalid 

func (mr *MockManagerMockRecorder) IsInvalid(req any) *gomock.Call

IsInvalid indicates an expected call of IsInvalid.

func (*MockManagerMockRecorder) Keep 

func (mr *MockManagerMockRecorder) Keep() *gomock.Call

Keep indicates an expected call of Keep.

func (*MockManagerMockRecorder) ListAllPeers added in v2.1.40 

func (mr *MockManagerMockRecorder) ListAllPeers(perGroupCount any) *gomock.Call

ListAllPeers indicates an expected call of ListAllPeers.

func (*MockManagerMockRecorder) ReadAllPieces 

func (mr *MockManagerMockRecorder) ReadAllPieces(ctx, req any) *gomock.Call

ReadAllPieces indicates an expected call of ReadAllPieces.

func (*MockManagerMockRecorder) ReadPiece 

func (mr *MockManagerMockRecorder) ReadPiece(ctx, req any) *gomock.Call

ReadPiece indicates an expected call of ReadPiece.

func (*MockManagerMockRecorder) RegisterSubTask 

func (mr *MockManagerMockRecorder) RegisterSubTask(ctx, req any) *gomock.Call

RegisterSubTask indicates an expected call of RegisterSubTask.

func (*MockManagerMockRecorder) RegisterTask 

func (mr *MockManagerMockRecorder) RegisterTask(ctx, req any) *gomock.Call

RegisterTask indicates an expected call of RegisterTask.

func (*MockManagerMockRecorder) Store 

func (mr *MockManagerMockRecorder) Store(ctx, req any) *gomock.Call

Store indicates an expected call of Store.

func (*MockManagerMockRecorder) UnregisterTask 

func (mr *MockManagerMockRecorder) UnregisterTask(ctx, req any) *gomock.Call

UnregisterTask indicates an expected call of UnregisterTask.

func (*MockManagerMockRecorder) UpdateTask 

func (mr *MockManagerMockRecorder) UpdateTask(ctx, req any) *gomock.Call

UpdateTask indicates an expected call of UpdateTask.

func (*MockManagerMockRecorder) ValidateDigest 

func (mr *MockManagerMockRecorder) ValidateDigest(req any) *gomock.Call

ValidateDigest indicates an expected call of ValidateDigest.

func (*MockManagerMockRecorder) WritePiece 

func (mr *MockManagerMockRecorder) WritePiece(ctx, req any) *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.

func (*MockReclaimer) Reclaim 

func (m *MockReclaimer) Reclaim() error

Reclaim 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) GetExtendAttribute 

func (m *MockTaskStorageDriver) GetExtendAttribute(ctx context.Context, req *storage.PeerTaskMetadata) (*common.ExtendAttribute, error)

GetExtendAttribute mocks base method.

func (*MockTaskStorageDriver) GetPieces 

func (m *MockTaskStorageDriver) GetPieces(ctx context.Context, req *common.PieceTaskRequest) (*common.PiecePacket, error)

GetPieces mocks base method.

func (*MockTaskStorageDriver) GetTotalPieces 

func (m *MockTaskStorageDriver) GetTotalPieces(ctx context.Context, req *storage.PeerTaskMetadata) (int32, error)

GetTotalPieces mocks base method.

func (*MockTaskStorageDriver) IsInvalid 

func (m *MockTaskStorageDriver) IsInvalid(req *storage.PeerTaskMetadata) (bool, error)

IsInvalid mocks base method.

func (*MockTaskStorageDriver) ReadAllPieces 

func (m *MockTaskStorageDriver) ReadAllPieces(ctx context.Context, req *storage.ReadAllPiecesRequest) (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) ValidateDigest 

func (m *MockTaskStorageDriver) ValidateDigest(req *storage.PeerTaskMetadata) error

ValidateDigest 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) GetExtendAttribute 

func (mr *MockTaskStorageDriverMockRecorder) GetExtendAttribute(ctx, req any) *gomock.Call

GetExtendAttribute indicates an expected call of GetExtendAttribute.

func (*MockTaskStorageDriverMockRecorder) GetPieces 

func (mr *MockTaskStorageDriverMockRecorder) GetPieces(ctx, req any) *gomock.Call

GetPieces indicates an expected call of GetPieces.

func (*MockTaskStorageDriverMockRecorder) GetTotalPieces 

func (mr *MockTaskStorageDriverMockRecorder) GetTotalPieces(ctx, req any) *gomock.Call

GetTotalPieces indicates an expected call of GetTotalPieces.

func (*MockTaskStorageDriverMockRecorder) IsInvalid 

func (mr *MockTaskStorageDriverMockRecorder) IsInvalid(req any) *gomock.Call

IsInvalid indicates an expected call of IsInvalid.

func (*MockTaskStorageDriverMockRecorder) ReadAllPieces 

func (mr *MockTaskStorageDriverMockRecorder) ReadAllPieces(ctx, req any) *gomock.Call

ReadAllPieces indicates an expected call of ReadAllPieces.

func (*MockTaskStorageDriverMockRecorder) ReadPiece 

func (mr *MockTaskStorageDriverMockRecorder) ReadPiece(ctx, req any) *gomock.Call

ReadPiece indicates an expected call of ReadPiece.

func (*MockTaskStorageDriverMockRecorder) Store 

func (mr *MockTaskStorageDriverMockRecorder) Store(ctx, req any) *gomock.Call

Store indicates an expected call of Store.

func (*MockTaskStorageDriverMockRecorder) UpdateTask 

func (mr *MockTaskStorageDriverMockRecorder) UpdateTask(ctx, req any) *gomock.Call

UpdateTask indicates an expected call of UpdateTask.

func (*MockTaskStorageDriverMockRecorder) ValidateDigest 

func (mr *MockTaskStorageDriverMockRecorder) ValidateDigest(req any) *gomock.Call

ValidateDigest indicates an expected call of ValidateDigest.

func (*MockTaskStorageDriverMockRecorder) WritePiece 

func (mr *MockTaskStorageDriverMockRecorder) WritePiece(ctx, req any) *gomock.Call

WritePiece indicates an expected call of WritePiece.

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.