Versions in this module Expand all Collapse all v0 v0.3.0 Mar 9, 2022 v0.2.0 Jan 5, 2022 Changes in this version + type MockJobProcessor struct + func NewMockJobProcessor(ctrl *gomock.Controller) *MockJobProcessor + func (m *MockJobProcessor) EXPECT() *MockJobProcessorMockRecorder + func (m *MockJobProcessor) Execute(arg0 []byte, arg1 storage.JobStorage, arg2 config.ResourcesAware) ([]byte, error) + func (m *MockJobProcessor) Remove(arg0 metapb.Job, arg1 storage.JobStorage, arg2 config.ResourcesAware) + func (m *MockJobProcessor) Start(arg0 metapb.Job, arg1 storage.JobStorage, arg2 config.ResourcesAware) + func (m *MockJobProcessor) Stop(arg0 metapb.Job, arg1 storage.JobStorage, arg2 config.ResourcesAware) + type MockJobProcessorMockRecorder struct + func (mr *MockJobProcessorMockRecorder) Execute(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockJobProcessorMockRecorder) Remove(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockJobProcessorMockRecorder) Start(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockJobProcessorMockRecorder) Stop(arg0, arg1, arg2 interface{}) *gomock.Call + type MockResourcesAware struct + func NewMockResourcesAware(ctrl *gomock.Controller) *MockResourcesAware + func (m *MockResourcesAware) EXPECT() *MockResourcesAwareMockRecorder + func (m *MockResourcesAware) ForeachResources(group uint64, fn func(metadata.Resource)) + func (m *MockResourcesAware) ForeachWaittingCreateResources(do func(metadata.Resource)) + func (m *MockResourcesAware) GetResource(resourceID uint64) *core.CachedResource + type MockResourcesAwareMockRecorder struct + func (mr *MockResourcesAwareMockRecorder) ForeachResources(group, fn interface{}) *gomock.Call + func (mr *MockResourcesAwareMockRecorder) ForeachWaittingCreateResources(do interface{}) *gomock.Call + func (mr *MockResourcesAwareMockRecorder) GetResource(resourceID interface{}) *gomock.Call
Go to main page