Documentation ¶
Overview ¶
Package mock is a generated GoMock package.
Index ¶
- type MockClient
- func (m *MockClient) Close() error
- func (m *MockClient) CreateExecutor(arg0 context.Context, arg1 *model2.Executor) error
- func (m *MockClient) CreateProject(arg0 context.Context, arg1 *model2.ProjectInfo) error
- func (m *MockClient) CreateProjectOperation(arg0 context.Context, arg1 *model2.ProjectOperation) error
- func (m *MockClient) CreateResource(arg0 context.Context, arg1 *model1.ResourceMeta) error
- func (m *MockClient) DeleteExecutor(arg0 context.Context, arg1 model0.DeployNodeID) error
- func (m *MockClient) DeleteJob(arg0 context.Context, arg1 string) (orm.Result, error)
- func (m *MockClient) DeleteProject(arg0 context.Context, arg1 string) error
- func (m *MockClient) DeleteResource(arg0 context.Context, arg1 model1.ResourceKey) (orm.Result, error)
- func (m *MockClient) DeleteResourcesByTypeAndExecutorIDs(arg0 context.Context, arg1 model1.ResourceType, arg2 ...model0.DeployNodeID) (orm.Result, error)
- func (m *MockClient) DeleteWorker(arg0 context.Context, arg1, arg2 string) (orm.Result, error)
- func (m *MockClient) EXPECT() *MockClientMockRecorder
- func (m *MockClient) GenEpoch(arg0 context.Context) (int64, error)
- func (m *MockClient) GetJobByID(arg0 context.Context, arg1 string) (*model.MasterMeta, error)
- func (m *MockClient) GetOneResourceForGC(arg0 context.Context) (*model1.ResourceMeta, error)
- func (m *MockClient) GetProjectByID(arg0 context.Context, arg1 string) (*model2.ProjectInfo, error)
- func (m *MockClient) GetResourceByID(arg0 context.Context, arg1 model1.ResourceKey) (*model1.ResourceMeta, error)
- func (m *MockClient) GetWorkerByID(arg0 context.Context, arg1, arg2 string) (*model.WorkerStatus, error)
- func (m *MockClient) InsertJob(arg0 context.Context, arg1 *model.MasterMeta) error
- func (m *MockClient) QueryExecutors(arg0 context.Context) ([]*model2.Executor, error)
- func (m *MockClient) QueryJobOp(arg0 context.Context, arg1 string) (*model2.JobOp, error)
- func (m *MockClient) QueryJobOpsByStatus(arg0 context.Context, arg1 model2.JobOpStatus) ([]*model2.JobOp, error)
- func (m *MockClient) QueryJobs(arg0 context.Context) ([]*model.MasterMeta, error)
- func (m *MockClient) QueryJobsByProjectID(arg0 context.Context, arg1 string) ([]*model.MasterMeta, error)
- func (m *MockClient) QueryJobsByState(arg0 context.Context, arg1 string, arg2 int) ([]*model.MasterMeta, error)
- func (m *MockClient) QueryProjectOperations(arg0 context.Context, arg1 string) ([]*model2.ProjectOperation, error)
- func (m *MockClient) QueryProjectOperationsByTimeRange(arg0 context.Context, arg1 string, arg2 orm.TimeRange) ([]*model2.ProjectOperation, error)
- func (m *MockClient) QueryProjects(arg0 context.Context) ([]*model2.ProjectInfo, error)
- func (m *MockClient) QueryResources(arg0 context.Context) ([]*model1.ResourceMeta, error)
- func (m *MockClient) QueryResourcesByExecutorIDs(arg0 context.Context, arg1 ...model0.DeployNodeID) ([]*model1.ResourceMeta, error)
- func (m *MockClient) QueryResourcesByJobID(arg0 context.Context, arg1 string) ([]*model1.ResourceMeta, error)
- func (m *MockClient) QueryWorkersByMasterID(arg0 context.Context, arg1 string) ([]*model.WorkerStatus, error)
- func (m *MockClient) QueryWorkersByState(arg0 context.Context, arg1 string, arg2 int) ([]*model.WorkerStatus, error)
- func (m *MockClient) SetGCPendingByJobs(arg0 context.Context, arg1 ...string) error
- func (m *MockClient) SetJobCanceled(arg0 context.Context, arg1 string) (orm.Result, error)
- func (m *MockClient) SetJobCanceling(arg0 context.Context, arg1 string) (orm.Result, error)
- func (m *MockClient) SetJobNoop(arg0 context.Context, arg1 string) (orm.Result, error)
- func (m *MockClient) UpdateExecutor(arg0 context.Context, arg1 *model2.Executor) error
- func (m *MockClient) UpdateJob(arg0 context.Context, arg1 string, arg2 map[string]interface{}) error
- func (m *MockClient) UpdateResource(arg0 context.Context, arg1 *model1.ResourceMeta) error
- func (m *MockClient) UpdateWorker(arg0 context.Context, arg1 *model.WorkerStatus) error
- func (m *MockClient) UpsertJob(arg0 context.Context, arg1 *model.MasterMeta) error
- func (m *MockClient) UpsertResource(arg0 context.Context, arg1 *model1.ResourceMeta) error
- func (m *MockClient) UpsertWorker(arg0 context.Context, arg1 *model.WorkerStatus) error
- type MockClientMockRecorder
- func (mr *MockClientMockRecorder) Close() *gomock.Call
- func (mr *MockClientMockRecorder) CreateExecutor(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) CreateProject(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) CreateProjectOperation(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) CreateResource(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DeleteExecutor(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DeleteJob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DeleteProject(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DeleteResource(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DeleteResourcesByTypeAndExecutorIDs(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) DeleteWorker(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GenEpoch(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetJobByID(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetOneResourceForGC(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetProjectByID(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetResourceByID(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) GetWorkerByID(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) InsertJob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryExecutors(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryJobOp(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryJobOpsByStatus(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryJobs(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryJobsByProjectID(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryJobsByState(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryProjectOperations(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryProjectOperationsByTimeRange(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryProjects(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryResources(arg0 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryResourcesByExecutorIDs(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryResourcesByJobID(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryWorkersByMasterID(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) QueryWorkersByState(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) SetGCPendingByJobs(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) SetJobCanceled(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) SetJobCanceling(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) SetJobNoop(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UpdateExecutor(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UpdateJob(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UpdateResource(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UpdateWorker(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UpsertJob(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UpsertResource(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockClientMockRecorder) UpsertWorker(arg0, arg1 interface{}) *gomock.Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockClient ¶
type MockClient struct {
// contains filtered or unexported fields
}
MockClient is a mock of Client interface.
func NewMockClient ¶
func NewMockClient(ctrl *gomock.Controller) *MockClient
NewMockClient creates a new mock instance.
func (*MockClient) CreateExecutor ¶
CreateExecutor mocks base method.
func (*MockClient) CreateProject ¶
func (m *MockClient) CreateProject(arg0 context.Context, arg1 *model2.ProjectInfo) error
CreateProject mocks base method.
func (*MockClient) CreateProjectOperation ¶
func (m *MockClient) CreateProjectOperation(arg0 context.Context, arg1 *model2.ProjectOperation) error
CreateProjectOperation mocks base method.
func (*MockClient) CreateResource ¶
func (m *MockClient) CreateResource(arg0 context.Context, arg1 *model1.ResourceMeta) error
CreateResource mocks base method.
func (*MockClient) DeleteExecutor ¶
func (m *MockClient) DeleteExecutor(arg0 context.Context, arg1 model0.DeployNodeID) error
DeleteExecutor mocks base method.
func (*MockClient) DeleteProject ¶
func (m *MockClient) DeleteProject(arg0 context.Context, arg1 string) error
DeleteProject mocks base method.
func (*MockClient) DeleteResource ¶
func (m *MockClient) DeleteResource(arg0 context.Context, arg1 model1.ResourceKey) (orm.Result, error)
DeleteResource mocks base method.
func (*MockClient) DeleteResourcesByTypeAndExecutorIDs ¶
func (m *MockClient) DeleteResourcesByTypeAndExecutorIDs(arg0 context.Context, arg1 model1.ResourceType, arg2 ...model0.DeployNodeID) (orm.Result, error)
DeleteResourcesByTypeAndExecutorIDs mocks base method.
func (*MockClient) DeleteWorker ¶
DeleteWorker mocks base method.
func (*MockClient) EXPECT ¶
func (m *MockClient) EXPECT() *MockClientMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockClient) GenEpoch ¶
func (m *MockClient) GenEpoch(arg0 context.Context) (int64, error)
GenEpoch mocks base method.
func (*MockClient) GetJobByID ¶
func (m *MockClient) GetJobByID(arg0 context.Context, arg1 string) (*model.MasterMeta, error)
GetJobByID mocks base method.
func (*MockClient) GetOneResourceForGC ¶
func (m *MockClient) GetOneResourceForGC(arg0 context.Context) (*model1.ResourceMeta, error)
GetOneResourceForGC mocks base method.
func (*MockClient) GetProjectByID ¶
func (m *MockClient) GetProjectByID(arg0 context.Context, arg1 string) (*model2.ProjectInfo, error)
GetProjectByID mocks base method.
func (*MockClient) GetResourceByID ¶
func (m *MockClient) GetResourceByID(arg0 context.Context, arg1 model1.ResourceKey) (*model1.ResourceMeta, error)
GetResourceByID mocks base method.
func (*MockClient) GetWorkerByID ¶
func (m *MockClient) GetWorkerByID(arg0 context.Context, arg1, arg2 string) (*model.WorkerStatus, error)
GetWorkerByID mocks base method.
func (*MockClient) InsertJob ¶
func (m *MockClient) InsertJob(arg0 context.Context, arg1 *model.MasterMeta) error
InsertJob mocks base method.
func (*MockClient) QueryExecutors ¶
QueryExecutors mocks base method.
func (*MockClient) QueryJobOp ¶
QueryJobOp mocks base method.
func (*MockClient) QueryJobOpsByStatus ¶
func (m *MockClient) QueryJobOpsByStatus(arg0 context.Context, arg1 model2.JobOpStatus) ([]*model2.JobOp, error)
QueryJobOpsByStatus mocks base method.
func (*MockClient) QueryJobs ¶
func (m *MockClient) QueryJobs(arg0 context.Context) ([]*model.MasterMeta, error)
QueryJobs mocks base method.
func (*MockClient) QueryJobsByProjectID ¶
func (m *MockClient) QueryJobsByProjectID(arg0 context.Context, arg1 string) ([]*model.MasterMeta, error)
QueryJobsByProjectID mocks base method.
func (*MockClient) QueryJobsByState ¶
func (m *MockClient) QueryJobsByState(arg0 context.Context, arg1 string, arg2 int) ([]*model.MasterMeta, error)
QueryJobsByState mocks base method.
func (*MockClient) QueryProjectOperations ¶
func (m *MockClient) QueryProjectOperations(arg0 context.Context, arg1 string) ([]*model2.ProjectOperation, error)
QueryProjectOperations mocks base method.
func (*MockClient) QueryProjectOperationsByTimeRange ¶
func (m *MockClient) QueryProjectOperationsByTimeRange(arg0 context.Context, arg1 string, arg2 orm.TimeRange) ([]*model2.ProjectOperation, error)
QueryProjectOperationsByTimeRange mocks base method.
func (*MockClient) QueryProjects ¶
func (m *MockClient) QueryProjects(arg0 context.Context) ([]*model2.ProjectInfo, error)
QueryProjects mocks base method.
func (*MockClient) QueryResources ¶
func (m *MockClient) QueryResources(arg0 context.Context) ([]*model1.ResourceMeta, error)
QueryResources mocks base method.
func (*MockClient) QueryResourcesByExecutorIDs ¶
func (m *MockClient) QueryResourcesByExecutorIDs(arg0 context.Context, arg1 ...model0.DeployNodeID) ([]*model1.ResourceMeta, error)
QueryResourcesByExecutorIDs mocks base method.
func (*MockClient) QueryResourcesByJobID ¶
func (m *MockClient) QueryResourcesByJobID(arg0 context.Context, arg1 string) ([]*model1.ResourceMeta, error)
QueryResourcesByJobID mocks base method.
func (*MockClient) QueryWorkersByMasterID ¶
func (m *MockClient) QueryWorkersByMasterID(arg0 context.Context, arg1 string) ([]*model.WorkerStatus, error)
QueryWorkersByMasterID mocks base method.
func (*MockClient) QueryWorkersByState ¶
func (m *MockClient) QueryWorkersByState(arg0 context.Context, arg1 string, arg2 int) ([]*model.WorkerStatus, error)
QueryWorkersByState mocks base method.
func (*MockClient) SetGCPendingByJobs ¶
func (m *MockClient) SetGCPendingByJobs(arg0 context.Context, arg1 ...string) error
SetGCPendingByJobs mocks base method.
func (*MockClient) SetJobCanceled ¶
SetJobCanceled mocks base method.
func (*MockClient) SetJobCanceling ¶
SetJobCanceling mocks base method.
func (*MockClient) SetJobNoop ¶
SetJobNoop mocks base method.
func (*MockClient) UpdateExecutor ¶
UpdateExecutor mocks base method.
func (*MockClient) UpdateJob ¶
func (m *MockClient) UpdateJob(arg0 context.Context, arg1 string, arg2 map[string]interface{}) error
UpdateJob mocks base method.
func (*MockClient) UpdateResource ¶
func (m *MockClient) UpdateResource(arg0 context.Context, arg1 *model1.ResourceMeta) error
UpdateResource mocks base method.
func (*MockClient) UpdateWorker ¶
func (m *MockClient) UpdateWorker(arg0 context.Context, arg1 *model.WorkerStatus) error
UpdateWorker mocks base method.
func (*MockClient) UpsertJob ¶
func (m *MockClient) UpsertJob(arg0 context.Context, arg1 *model.MasterMeta) error
UpsertJob mocks base method.
func (*MockClient) UpsertResource ¶
func (m *MockClient) UpsertResource(arg0 context.Context, arg1 *model1.ResourceMeta) error
UpsertResource mocks base method.
func (*MockClient) UpsertWorker ¶
func (m *MockClient) UpsertWorker(arg0 context.Context, arg1 *model.WorkerStatus) error
UpsertWorker mocks base method.
type MockClientMockRecorder ¶
type MockClientMockRecorder struct {
// contains filtered or unexported fields
}
MockClientMockRecorder is the mock recorder for MockClient.
func (*MockClientMockRecorder) Close ¶
func (mr *MockClientMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close.
func (*MockClientMockRecorder) CreateExecutor ¶
func (mr *MockClientMockRecorder) CreateExecutor(arg0, arg1 interface{}) *gomock.Call
CreateExecutor indicates an expected call of CreateExecutor.
func (*MockClientMockRecorder) CreateProject ¶
func (mr *MockClientMockRecorder) CreateProject(arg0, arg1 interface{}) *gomock.Call
CreateProject indicates an expected call of CreateProject.
func (*MockClientMockRecorder) CreateProjectOperation ¶
func (mr *MockClientMockRecorder) CreateProjectOperation(arg0, arg1 interface{}) *gomock.Call
CreateProjectOperation indicates an expected call of CreateProjectOperation.
func (*MockClientMockRecorder) CreateResource ¶
func (mr *MockClientMockRecorder) CreateResource(arg0, arg1 interface{}) *gomock.Call
CreateResource indicates an expected call of CreateResource.
func (*MockClientMockRecorder) DeleteExecutor ¶
func (mr *MockClientMockRecorder) DeleteExecutor(arg0, arg1 interface{}) *gomock.Call
DeleteExecutor indicates an expected call of DeleteExecutor.
func (*MockClientMockRecorder) DeleteJob ¶
func (mr *MockClientMockRecorder) DeleteJob(arg0, arg1 interface{}) *gomock.Call
DeleteJob indicates an expected call of DeleteJob.
func (*MockClientMockRecorder) DeleteProject ¶
func (mr *MockClientMockRecorder) DeleteProject(arg0, arg1 interface{}) *gomock.Call
DeleteProject indicates an expected call of DeleteProject.
func (*MockClientMockRecorder) DeleteResource ¶
func (mr *MockClientMockRecorder) DeleteResource(arg0, arg1 interface{}) *gomock.Call
DeleteResource indicates an expected call of DeleteResource.
func (*MockClientMockRecorder) DeleteResourcesByTypeAndExecutorIDs ¶
func (mr *MockClientMockRecorder) DeleteResourcesByTypeAndExecutorIDs(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
DeleteResourcesByTypeAndExecutorIDs indicates an expected call of DeleteResourcesByTypeAndExecutorIDs.
func (*MockClientMockRecorder) DeleteWorker ¶
func (mr *MockClientMockRecorder) DeleteWorker(arg0, arg1, arg2 interface{}) *gomock.Call
DeleteWorker indicates an expected call of DeleteWorker.
func (*MockClientMockRecorder) GenEpoch ¶
func (mr *MockClientMockRecorder) GenEpoch(arg0 interface{}) *gomock.Call
GenEpoch indicates an expected call of GenEpoch.
func (*MockClientMockRecorder) GetJobByID ¶
func (mr *MockClientMockRecorder) GetJobByID(arg0, arg1 interface{}) *gomock.Call
GetJobByID indicates an expected call of GetJobByID.
func (*MockClientMockRecorder) GetOneResourceForGC ¶
func (mr *MockClientMockRecorder) GetOneResourceForGC(arg0 interface{}) *gomock.Call
GetOneResourceForGC indicates an expected call of GetOneResourceForGC.
func (*MockClientMockRecorder) GetProjectByID ¶
func (mr *MockClientMockRecorder) GetProjectByID(arg0, arg1 interface{}) *gomock.Call
GetProjectByID indicates an expected call of GetProjectByID.
func (*MockClientMockRecorder) GetResourceByID ¶
func (mr *MockClientMockRecorder) GetResourceByID(arg0, arg1 interface{}) *gomock.Call
GetResourceByID indicates an expected call of GetResourceByID.
func (*MockClientMockRecorder) GetWorkerByID ¶
func (mr *MockClientMockRecorder) GetWorkerByID(arg0, arg1, arg2 interface{}) *gomock.Call
GetWorkerByID indicates an expected call of GetWorkerByID.
func (*MockClientMockRecorder) InsertJob ¶
func (mr *MockClientMockRecorder) InsertJob(arg0, arg1 interface{}) *gomock.Call
InsertJob indicates an expected call of InsertJob.
func (*MockClientMockRecorder) QueryExecutors ¶
func (mr *MockClientMockRecorder) QueryExecutors(arg0 interface{}) *gomock.Call
QueryExecutors indicates an expected call of QueryExecutors.
func (*MockClientMockRecorder) QueryJobOp ¶
func (mr *MockClientMockRecorder) QueryJobOp(arg0, arg1 interface{}) *gomock.Call
QueryJobOp indicates an expected call of QueryJobOp.
func (*MockClientMockRecorder) QueryJobOpsByStatus ¶
func (mr *MockClientMockRecorder) QueryJobOpsByStatus(arg0, arg1 interface{}) *gomock.Call
QueryJobOpsByStatus indicates an expected call of QueryJobOpsByStatus.
func (*MockClientMockRecorder) QueryJobs ¶
func (mr *MockClientMockRecorder) QueryJobs(arg0 interface{}) *gomock.Call
QueryJobs indicates an expected call of QueryJobs.
func (*MockClientMockRecorder) QueryJobsByProjectID ¶
func (mr *MockClientMockRecorder) QueryJobsByProjectID(arg0, arg1 interface{}) *gomock.Call
QueryJobsByProjectID indicates an expected call of QueryJobsByProjectID.
func (*MockClientMockRecorder) QueryJobsByState ¶
func (mr *MockClientMockRecorder) QueryJobsByState(arg0, arg1, arg2 interface{}) *gomock.Call
QueryJobsByState indicates an expected call of QueryJobsByState.
func (*MockClientMockRecorder) QueryProjectOperations ¶
func (mr *MockClientMockRecorder) QueryProjectOperations(arg0, arg1 interface{}) *gomock.Call
QueryProjectOperations indicates an expected call of QueryProjectOperations.
func (*MockClientMockRecorder) QueryProjectOperationsByTimeRange ¶
func (mr *MockClientMockRecorder) QueryProjectOperationsByTimeRange(arg0, arg1, arg2 interface{}) *gomock.Call
QueryProjectOperationsByTimeRange indicates an expected call of QueryProjectOperationsByTimeRange.
func (*MockClientMockRecorder) QueryProjects ¶
func (mr *MockClientMockRecorder) QueryProjects(arg0 interface{}) *gomock.Call
QueryProjects indicates an expected call of QueryProjects.
func (*MockClientMockRecorder) QueryResources ¶
func (mr *MockClientMockRecorder) QueryResources(arg0 interface{}) *gomock.Call
QueryResources indicates an expected call of QueryResources.
func (*MockClientMockRecorder) QueryResourcesByExecutorIDs ¶
func (mr *MockClientMockRecorder) QueryResourcesByExecutorIDs(arg0 interface{}, arg1 ...interface{}) *gomock.Call
QueryResourcesByExecutorIDs indicates an expected call of QueryResourcesByExecutorIDs.
func (*MockClientMockRecorder) QueryResourcesByJobID ¶
func (mr *MockClientMockRecorder) QueryResourcesByJobID(arg0, arg1 interface{}) *gomock.Call
QueryResourcesByJobID indicates an expected call of QueryResourcesByJobID.
func (*MockClientMockRecorder) QueryWorkersByMasterID ¶
func (mr *MockClientMockRecorder) QueryWorkersByMasterID(arg0, arg1 interface{}) *gomock.Call
QueryWorkersByMasterID indicates an expected call of QueryWorkersByMasterID.
func (*MockClientMockRecorder) QueryWorkersByState ¶
func (mr *MockClientMockRecorder) QueryWorkersByState(arg0, arg1, arg2 interface{}) *gomock.Call
QueryWorkersByState indicates an expected call of QueryWorkersByState.
func (*MockClientMockRecorder) SetGCPendingByJobs ¶
func (mr *MockClientMockRecorder) SetGCPendingByJobs(arg0 interface{}, arg1 ...interface{}) *gomock.Call
SetGCPendingByJobs indicates an expected call of SetGCPendingByJobs.
func (*MockClientMockRecorder) SetJobCanceled ¶
func (mr *MockClientMockRecorder) SetJobCanceled(arg0, arg1 interface{}) *gomock.Call
SetJobCanceled indicates an expected call of SetJobCanceled.
func (*MockClientMockRecorder) SetJobCanceling ¶
func (mr *MockClientMockRecorder) SetJobCanceling(arg0, arg1 interface{}) *gomock.Call
SetJobCanceling indicates an expected call of SetJobCanceling.
func (*MockClientMockRecorder) SetJobNoop ¶
func (mr *MockClientMockRecorder) SetJobNoop(arg0, arg1 interface{}) *gomock.Call
SetJobNoop indicates an expected call of SetJobNoop.
func (*MockClientMockRecorder) UpdateExecutor ¶
func (mr *MockClientMockRecorder) UpdateExecutor(arg0, arg1 interface{}) *gomock.Call
UpdateExecutor indicates an expected call of UpdateExecutor.
func (*MockClientMockRecorder) UpdateJob ¶
func (mr *MockClientMockRecorder) UpdateJob(arg0, arg1, arg2 interface{}) *gomock.Call
UpdateJob indicates an expected call of UpdateJob.
func (*MockClientMockRecorder) UpdateResource ¶
func (mr *MockClientMockRecorder) UpdateResource(arg0, arg1 interface{}) *gomock.Call
UpdateResource indicates an expected call of UpdateResource.
func (*MockClientMockRecorder) UpdateWorker ¶
func (mr *MockClientMockRecorder) UpdateWorker(arg0, arg1 interface{}) *gomock.Call
UpdateWorker indicates an expected call of UpdateWorker.
func (*MockClientMockRecorder) UpsertJob ¶
func (mr *MockClientMockRecorder) UpsertJob(arg0, arg1 interface{}) *gomock.Call
UpsertJob indicates an expected call of UpsertJob.
func (*MockClientMockRecorder) UpsertResource ¶
func (mr *MockClientMockRecorder) UpsertResource(arg0, arg1 interface{}) *gomock.Call
UpsertResource indicates an expected call of UpsertResource.
func (*MockClientMockRecorder) UpsertWorker ¶
func (mr *MockClientMockRecorder) UpsertWorker(arg0, arg1 interface{}) *gomock.Call
UpsertWorker indicates an expected call of UpsertWorker.