base

package
v1.0.0 Latest Latest
Warning

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

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

Documentation

Overview

Package base is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockDataloader added in v0.7.0 

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

MockDataloader is a mock of Dataloader interface.

func NewMockDataloader added in v0.7.0 

func NewMockDataloader(ctrl *gomock.Controller) *MockDataloader

NewMockDataloader creates a new mock instance.

func (*MockDataloader) CheckExistenceOfPath added in v0.7.0 

func (m *MockDataloader) CheckExistenceOfPath(targetDataload v1alpha1.DataLoad) (bool, error)

CheckExistenceOfPath mocks base method.

func (*MockDataloader) CheckRuntimeReady added in v0.7.0 

func (m *MockDataloader) CheckRuntimeReady() bool

CheckRuntimeReady mocks base method.

func (*MockDataloader) EXPECT added in v0.7.0 

func (m *MockDataloader) EXPECT() *MockDataloaderMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockDataloader) LoadData added in v0.7.0 

func (m *MockDataloader) LoadData(ctx runtime.ReconcileRequestContext, targetDataload v1alpha1.DataLoad) error

LoadData mocks base method.

type MockDataloaderMockRecorder added in v0.7.0 

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

MockDataloaderMockRecorder is the mock recorder for MockDataloader.

func (*MockDataloaderMockRecorder) CheckExistenceOfPath added in v0.7.0 

func (mr *MockDataloaderMockRecorder) CheckExistenceOfPath(targetDataload interface{}) *gomock.Call

CheckExistenceOfPath indicates an expected call of CheckExistenceOfPath.

func (*MockDataloaderMockRecorder) CheckRuntimeReady added in v0.7.0 

func (mr *MockDataloaderMockRecorder) CheckRuntimeReady() *gomock.Call

CheckRuntimeReady indicates an expected call of CheckRuntimeReady.

func (*MockDataloaderMockRecorder) LoadData added in v0.7.0 

func (mr *MockDataloaderMockRecorder) LoadData(ctx, targetDataload interface{}) *gomock.Call

LoadData indicates an expected call of LoadData.

type MockEngine 

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

MockEngine is a mock of Engine interface.

func NewMockEngine 

func NewMockEngine(ctrl *gomock.Controller) *MockEngine

NewMockEngine creates a new mock instance.

func (*MockEngine) CheckExistenceOfPath added in v0.7.0 

func (m *MockEngine) CheckExistenceOfPath(targetDataload v1alpha1.DataLoad) (bool, error)

CheckExistenceOfPath mocks base method.

func (*MockEngine) CheckRuntimeReady added in v0.7.0 

func (m *MockEngine) CheckRuntimeReady() bool

CheckRuntimeReady mocks base method.

func (*MockEngine) CreateVolume 

func (m *MockEngine) CreateVolume() error

CreateVolume mocks base method.

func (*MockEngine) DeleteVolume 

func (m *MockEngine) DeleteVolume() error

DeleteVolume mocks base method.

func (*MockEngine) EXPECT 

func (m *MockEngine) EXPECT() *MockEngineMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockEngine) ID 

func (m *MockEngine) ID() string

ID mocks base method.

func (*MockEngine) LoadData added in v0.7.0 

func (m *MockEngine) LoadData(ctx runtime.ReconcileRequestContext, targetDataload v1alpha1.DataLoad) error

LoadData mocks base method.

func (*MockEngine) MigrateData added in v0.9.0 

func (m *MockEngine) MigrateData(ctx runtime.ReconcileRequestContext, targetDataMigrate v1alpha1.DataMigrate) (err error)

func (*MockEngine) Operate added in v0.9.0 

func (m *MockEngine) Operate(ctx runtime.ReconcileRequestContext, opStatus *v1alpha1.OperationStatus, operation dataoperation.OperationInterface) (ctrl.Result, error)

func (*MockEngine) Setup 

func (m *MockEngine) Setup(ctx runtime.ReconcileRequestContext) (bool, error)

Setup mocks base method.

func (*MockEngine) Shutdown 

func (m *MockEngine) Shutdown() error

Shutdown mocks base method.

func (*MockEngine) Sync 

func (m *MockEngine) Sync(ctx runtime.ReconcileRequestContext) error

Sync mocks base method.

type MockEngineMockRecorder 

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

MockEngineMockRecorder is the mock recorder for MockEngine.

func (*MockEngineMockRecorder) CheckExistenceOfPath added in v0.7.0 

func (mr *MockEngineMockRecorder) CheckExistenceOfPath(targetDataload interface{}) *gomock.Call

CheckExistenceOfPath indicates an expected call of CheckExistenceOfPath.

func (*MockEngineMockRecorder) CheckRuntimeReady added in v0.7.0 

func (mr *MockEngineMockRecorder) CheckRuntimeReady() *gomock.Call

CheckRuntimeReady indicates an expected call of CheckRuntimeReady.

func (*MockEngineMockRecorder) CreateVolume 

func (mr *MockEngineMockRecorder) CreateVolume() *gomock.Call

CreateVolume indicates an expected call of CreateVolume.

func (*MockEngineMockRecorder) DeleteVolume 

func (mr *MockEngineMockRecorder) DeleteVolume() *gomock.Call

DeleteVolume indicates an expected call of DeleteVolume.

func (*MockEngineMockRecorder) ID 

func (mr *MockEngineMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*MockEngineMockRecorder) LoadData added in v0.7.0 

func (mr *MockEngineMockRecorder) LoadData(ctx, targetDataload interface{}) *gomock.Call

LoadData indicates an expected call of LoadData.

func (*MockEngineMockRecorder) Setup 

func (mr *MockEngineMockRecorder) Setup(ctx interface{}) *gomock.Call

Setup indicates an expected call of Setup.

func (*MockEngineMockRecorder) Shutdown 

func (mr *MockEngineMockRecorder) Shutdown() *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockEngineMockRecorder) Sync 

func (mr *MockEngineMockRecorder) Sync(ctx interface{}) *gomock.Call

Sync indicates an expected call of Sync.

type MockImplement 

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

MockImplement is a mock of implement interface.

func NewMockImplement 

func NewMockImplement(ctrl *gomock.Controller) *MockImplement

NewMockImplement creates a new mock instance.

func (*MockImplement) AssignNodesToCache 

func (m *MockImplement) AssignNodesToCache(desiredNum int32) (int32, error)

AssignNodesToCache mocks base method.

func (*MockImplement) BindToDataset added in v0.5.0 

func (m *MockImplement) BindToDataset() error

BindToDataset mocks base method.

func (*MockImplement) CheckAndUpdateRuntimeStatus 

func (m *MockImplement) CheckAndUpdateRuntimeStatus() (bool, error)

CheckAndUpdateRuntimeStatus mocks base method.

func (*MockImplement) CheckExistenceOfPath added in v0.6.0 

func (m *MockImplement) CheckExistenceOfPath(targetDataload v1alpha1.DataLoad) (bool, error)

CheckExistenceOfPath mocks base method.

func (*MockImplement) CheckMasterReady 

func (m *MockImplement) CheckMasterReady() (bool, error)

CheckMasterReady mocks base method.

func (*MockImplement) CheckRuntimeHealthy 

func (m *MockImplement) CheckRuntimeHealthy() error

CheckRuntimeHealthy mocks base method.

func (*MockImplement) CheckRuntimeReady added in v0.6.0 

func (m *MockImplement) CheckRuntimeReady() bool

CheckRuntimeReady mocks base method.

func (*MockImplement) CheckWorkersReady 

func (m *MockImplement) CheckWorkersReady() (bool, error)

CheckWorkersReady mocks base method.

func (*MockImplement) CreateDataLoadJob added in v0.6.0 

func (m *MockImplement) CreateDataLoadJob(ctx runtime.ReconcileRequestContext, targetDataload v1alpha1.DataLoad) error

CreateDataLoadJob mocks base method.

func (*MockImplement) CreateDataMigrateJob added in v0.9.0 

func (m *MockImplement) CreateDataMigrateJob(ctx runtime.ReconcileRequestContext, targetDataMigrate v1alpha1.DataMigrate) error

func (*MockImplement) CreateVolume 

func (m *MockImplement) CreateVolume() error

CreateVolume mocks base method.

func (*MockImplement) DeleteVolume 

func (m *MockImplement) DeleteVolume() error

DeleteVolume mocks base method.

func (*MockImplement) EXPECT 

func (m *MockImplement) EXPECT() *MockImplementMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockImplement) FreeStorageBytes 

func (m *MockImplement) FreeStorageBytes() (int64, error)

FreeStorageBytes mocks base method.

func (*MockImplement) GetDataOperationValueFile added in v0.9.0 

func (m *MockImplement) GetDataOperationValueFile(ctx runtime.ReconcileRequestContext, operation dataoperation.OperationInterface) (valueFileName string, err error)

func (*MockImplement) PrepareUFS 

func (m *MockImplement) PrepareUFS() error

PrepareUFS mocks base method.

func (*MockImplement) SetupMaster 

func (m *MockImplement) SetupMaster() error

SetupMaster mocks base method.

func (*MockImplement) SetupWorkers 

func (m *MockImplement) SetupWorkers() error

SetupWorkers mocks base method.

func (*MockImplement) ShouldCheckUFS 

func (m *MockImplement) ShouldCheckUFS() (bool, error)

ShouldCheckUFS mocks base method.

func (*MockImplement) ShouldSetupMaster 

func (m *MockImplement) ShouldSetupMaster() (bool, error)

ShouldSetupMaster mocks base method.

func (*MockImplement) ShouldSetupWorkers 

func (m *MockImplement) ShouldSetupWorkers() (bool, error)

ShouldSetupWorkers mocks base method.

func (*MockImplement) ShouldUpdateUFS added in v0.6.0 

func (m *MockImplement) ShouldUpdateUFS() *utils.UFSToUpdate

ShouldUpdateUFS mocks base method.

func (*MockImplement) Shutdown 

func (m *MockImplement) Shutdown() error

Shutdown mocks base method.

func (*MockImplement) SyncMetadata added in v0.4.0 

func (m *MockImplement) SyncMetadata() error

SyncMetadata mocks base method.

func (*MockImplement) SyncReplicas 

func (m *MockImplement) SyncReplicas(ctx runtime.ReconcileRequestContext) error

SyncReplicas mocks base method.

func (*MockImplement) SyncRuntime added in v0.8.0 

func (m *MockImplement) SyncRuntime(ctx runtime.ReconcileRequestContext) (bool, error)

SyncRuntime mocks base method.

func (*MockImplement) SyncScheduleInfoToCacheNodes added in v0.7.0 

func (m *MockImplement) SyncScheduleInfoToCacheNodes() error

SyncScheduleInfoToCacheNodes mocks base method.

func (*MockImplement) TotalFileNums 

func (m *MockImplement) TotalFileNums() (int64, error)

TotalFileNums mocks base method.

func (*MockImplement) TotalStorageBytes 

func (m *MockImplement) TotalStorageBytes() (int64, error)

TotalStorageBytes mocks base method.

func (*MockImplement) UpdateCacheOfDataset 

func (m *MockImplement) UpdateCacheOfDataset() error

UpdateCacheOfDataset mocks base method.

func (*MockImplement) UpdateDatasetStatus 

func (m *MockImplement) UpdateDatasetStatus(phase v1alpha1.DatasetPhase) error

UpdateDatasetStatus mocks base method.

func (*MockImplement) UpdateOnUFSChange added in v0.6.0 

func (m *MockImplement) UpdateOnUFSChange(ufsToUpdate *utils.UFSToUpdate) (bool, error)

UpdateOnUFSChange mocks base method.

func (*MockImplement) UsedStorageBytes 

func (m *MockImplement) UsedStorageBytes() (int64, error)

UsedStorageBytes mocks base method.

type MockImplementMockRecorder 

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

MockImplementMockRecorder is the mock recorder for MockImplement.

func (*MockImplementMockRecorder) AssignNodesToCache 

func (mr *MockImplementMockRecorder) AssignNodesToCache(desiredNum interface{}) *gomock.Call

AssignNodesToCache indicates an expected call of AssignNodesToCache.

func (*MockImplementMockRecorder) BindToDataset added in v0.5.0 

func (mr *MockImplementMockRecorder) BindToDataset() *gomock.Call

BindToDataset indicates an expected call of BindToDataset.

func (*MockImplementMockRecorder) CheckAndUpdateRuntimeStatus 

func (mr *MockImplementMockRecorder) CheckAndUpdateRuntimeStatus() *gomock.Call

CheckAndUpdateRuntimeStatus indicates an expected call of CheckAndUpdateRuntimeStatus.

func (*MockImplementMockRecorder) CheckExistenceOfPath added in v0.7.0 

func (mr *MockImplementMockRecorder) CheckExistenceOfPath(targetDataload interface{}) *gomock.Call

CheckExistenceOfPath indicates an expected call of CheckExistenceOfPath.

func (*MockImplementMockRecorder) CheckMasterReady 

func (mr *MockImplementMockRecorder) CheckMasterReady() *gomock.Call

CheckMasterReady indicates an expected call of CheckMasterReady.

func (*MockImplementMockRecorder) CheckRuntimeHealthy 

func (mr *MockImplementMockRecorder) CheckRuntimeHealthy() *gomock.Call

CheckRuntimeHealthy indicates an expected call of CheckRuntimeHealthy.

func (*MockImplementMockRecorder) CheckRuntimeReady added in v0.7.0 

func (mr *MockImplementMockRecorder) CheckRuntimeReady() *gomock.Call

CheckRuntimeReady indicates an expected call of CheckRuntimeReady.

func (*MockImplementMockRecorder) CheckWorkersReady 

func (mr *MockImplementMockRecorder) CheckWorkersReady() *gomock.Call

CheckWorkersReady indicates an expected call of CheckWorkersReady.

func (*MockImplementMockRecorder) CreateDataLoadJob added in v0.7.0 

func (mr *MockImplementMockRecorder) CreateDataLoadJob(ctx, targetDataload interface{}) *gomock.Call

CreateDataLoadJob indicates an expected call of CreateDataLoadJob.

func (*MockImplementMockRecorder) CreateVolume 

func (mr *MockImplementMockRecorder) CreateVolume() *gomock.Call

CreateVolume indicates an expected call of CreateVolume.

func (*MockImplementMockRecorder) DeleteVolume 

func (mr *MockImplementMockRecorder) DeleteVolume() *gomock.Call

DeleteVolume indicates an expected call of DeleteVolume.

func (*MockImplementMockRecorder) FreeStorageBytes 

func (mr *MockImplementMockRecorder) FreeStorageBytes() *gomock.Call

FreeStorageBytes indicates an expected call of FreeStorageBytes.

func (*MockImplementMockRecorder) PrepareUFS 

func (mr *MockImplementMockRecorder) PrepareUFS() *gomock.Call

PrepareUFS indicates an expected call of PrepareUFS.

func (*MockImplementMockRecorder) SetupMaster 

func (mr *MockImplementMockRecorder) SetupMaster() *gomock.Call

SetupMaster indicates an expected call of SetupMaster.

func (*MockImplementMockRecorder) SetupWorkers 

func (mr *MockImplementMockRecorder) SetupWorkers() *gomock.Call

SetupWorkers indicates an expected call of SetupWorkers.

func (*MockImplementMockRecorder) ShouldCheckUFS 

func (mr *MockImplementMockRecorder) ShouldCheckUFS() *gomock.Call

ShouldCheckUFS indicates an expected call of ShouldCheckUFS.

func (*MockImplementMockRecorder) ShouldSetupMaster 

func (mr *MockImplementMockRecorder) ShouldSetupMaster() *gomock.Call

ShouldSetupMaster indicates an expected call of ShouldSetupMaster.

func (*MockImplementMockRecorder) ShouldSetupWorkers 

func (mr *MockImplementMockRecorder) ShouldSetupWorkers() *gomock.Call

ShouldSetupWorkers indicates an expected call of ShouldSetupWorkers.

func (*MockImplementMockRecorder) ShouldUpdateUFS added in v0.6.0 

func (mr *MockImplementMockRecorder) ShouldUpdateUFS() *gomock.Call

ShouldUpdateUFS indicates an expected call of ShouldUpdateUFS.

func (*MockImplementMockRecorder) Shutdown 

func (mr *MockImplementMockRecorder) Shutdown() *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockImplementMockRecorder) SyncMetadata added in v0.4.0 

func (mr *MockImplementMockRecorder) SyncMetadata() *gomock.Call

SyncMetadata indicates an expected call of SyncMetadata.

func (*MockImplementMockRecorder) SyncReplicas 

func (mr *MockImplementMockRecorder) SyncReplicas(ctx interface{}) *gomock.Call

SyncReplicas indicates an expected call of SyncReplicas.

func (*MockImplementMockRecorder) SyncRuntime added in v0.8.0 

func (mr *MockImplementMockRecorder) SyncRuntime(ctx interface{}) *gomock.Call

SyncRuntime indicates an expected call of SyncRuntime.

func (*MockImplementMockRecorder) SyncScheduleInfoToCacheNodes added in v0.7.0 

func (mr *MockImplementMockRecorder) SyncScheduleInfoToCacheNodes() *gomock.Call

SyncScheduleInfoToCacheNodes indicates an expected call of SyncScheduleInfoToCacheNodes.

func (*MockImplementMockRecorder) TotalFileNums 

func (mr *MockImplementMockRecorder) TotalFileNums() *gomock.Call

TotalFileNums indicates an expected call of TotalFileNums.

func (*MockImplementMockRecorder) TotalStorageBytes 

func (mr *MockImplementMockRecorder) TotalStorageBytes() *gomock.Call

TotalStorageBytes indicates an expected call of TotalStorageBytes.

func (*MockImplementMockRecorder) UpdateCacheOfDataset 

func (mr *MockImplementMockRecorder) UpdateCacheOfDataset() *gomock.Call

UpdateCacheOfDataset indicates an expected call of UpdateCacheOfDataset.

func (*MockImplementMockRecorder) UpdateDatasetStatus 

func (mr *MockImplementMockRecorder) UpdateDatasetStatus(phase interface{}) *gomock.Call

UpdateDatasetStatus indicates an expected call of UpdateDatasetStatus.

func (*MockImplementMockRecorder) UpdateOnUFSChange added in v0.6.0 

func (mr *MockImplementMockRecorder) UpdateOnUFSChange(ufsToUpdate interface{}) *gomock.Call

UpdateOnUFSChange indicates an expected call of UpdateOnUFSChange.

func (*MockImplementMockRecorder) UsedStorageBytes 

func (mr *MockImplementMockRecorder) UsedStorageBytes() *gomock.Call

UsedStorageBytes indicates an expected call of UsedStorageBytes.

type MockUnderFileSystemService 

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

MockUnderFileSystemService is a mock of UnderFileSystemService interface.

func NewMockUnderFileSystemService 

func NewMockUnderFileSystemService(ctrl *gomock.Controller) *MockUnderFileSystemService

NewMockUnderFileSystemService creates a new mock instance.

func (*MockUnderFileSystemService) EXPECT 

func (m *MockUnderFileSystemService) EXPECT() *MockUnderFileSystemServiceMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockUnderFileSystemService) FreeStorageBytes 

func (m *MockUnderFileSystemService) FreeStorageBytes() (int64, error)

FreeStorageBytes mocks base method.

func (*MockUnderFileSystemService) TotalFileNums 

func (m *MockUnderFileSystemService) TotalFileNums() (int64, error)

TotalFileNums mocks base method.

func (*MockUnderFileSystemService) TotalStorageBytes 

func (m *MockUnderFileSystemService) TotalStorageBytes() (int64, error)

TotalStorageBytes mocks base method.

func (*MockUnderFileSystemService) UsedStorageBytes 

func (m *MockUnderFileSystemService) UsedStorageBytes() (int64, error)

UsedStorageBytes mocks base method.

type MockUnderFileSystemServiceMockRecorder 

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

MockUnderFileSystemServiceMockRecorder is the mock recorder for MockUnderFileSystemService.

func (*MockUnderFileSystemServiceMockRecorder) FreeStorageBytes 

func (mr *MockUnderFileSystemServiceMockRecorder) FreeStorageBytes() *gomock.Call

FreeStorageBytes indicates an expected call of FreeStorageBytes.

func (*MockUnderFileSystemServiceMockRecorder) TotalFileNums 

func (mr *MockUnderFileSystemServiceMockRecorder) TotalFileNums() *gomock.Call

TotalFileNums indicates an expected call of TotalFileNums.

func (*MockUnderFileSystemServiceMockRecorder) TotalStorageBytes 

func (mr *MockUnderFileSystemServiceMockRecorder) TotalStorageBytes() *gomock.Call

TotalStorageBytes indicates an expected call of TotalStorageBytes.

func (*MockUnderFileSystemServiceMockRecorder) UsedStorageBytes 

func (mr *MockUnderFileSystemServiceMockRecorder) UsedStorageBytes() *gomock.Call

UsedStorageBytes indicates an expected call of UsedStorageBytes.

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.