Versions in this module Expand all Collapse all v0 v0.1.0 Oct 12, 2018 Changes in this version + type MockArtifactManager struct + func NewMockArtifactManager(ctrl *gomock.Controller) *MockArtifactManager + func (m *MockArtifactManager) Close() error + func (m *MockArtifactManager) CreateArtifact(arg0 weles.ArtifactDescription) (weles.ArtifactPath, error) + func (m *MockArtifactManager) EXPECT() *MockArtifactManagerMockRecorder + func (m *MockArtifactManager) GetArtifactInfo(arg0 weles.ArtifactPath) (weles.ArtifactInfo, error) + func (m *MockArtifactManager) ListArtifact(arg0 weles.ArtifactFilter, arg1 weles.ArtifactSorter, ...) ([]weles.ArtifactInfo, weles.ListInfo, error) + func (m *MockArtifactManager) PushArtifact(arg0 weles.ArtifactDescription, arg1 chan weles.ArtifactStatusChange) (weles.ArtifactPath, error) + type MockArtifactManagerMockRecorder struct + func (mr *MockArtifactManagerMockRecorder) Close() *gomock.Call + func (mr *MockArtifactManagerMockRecorder) CreateArtifact(arg0 interface{}) *gomock.Call + func (mr *MockArtifactManagerMockRecorder) GetArtifactInfo(arg0 interface{}) *gomock.Call + func (mr *MockArtifactManagerMockRecorder) ListArtifact(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockArtifactManagerMockRecorder) PushArtifact(arg0, arg1 interface{}) *gomock.Call + type MockDryadJobManager struct + func NewMockDryadJobManager(ctrl *gomock.Controller) *MockDryadJobManager + func (m *MockDryadJobManager) Cancel(arg0 weles.JobID) error + func (m *MockDryadJobManager) Create(arg0 weles.JobID, arg1 weles.Dryad, arg2 weles.Config, ...) error + func (m *MockDryadJobManager) EXPECT() *MockDryadJobManagerMockRecorder + func (m *MockDryadJobManager) List(arg0 *weles.DryadJobFilter) ([]weles.DryadJobInfo, error) + type MockDryadJobManagerMockRecorder struct + func (mr *MockDryadJobManagerMockRecorder) Cancel(arg0 interface{}) *gomock.Call + func (mr *MockDryadJobManagerMockRecorder) Create(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockDryadJobManagerMockRecorder) List(arg0 interface{}) *gomock.Call + type MockJobManager struct + func NewMockJobManager(ctrl *gomock.Controller) *MockJobManager + func (m *MockJobManager) CancelJob(arg0 weles.JobID) error + func (m *MockJobManager) CreateJob(arg0 []byte) (weles.JobID, error) + func (m *MockJobManager) EXPECT() *MockJobManagerMockRecorder + func (m *MockJobManager) ListJobs(arg0 weles.JobFilter, arg1 weles.JobSorter, arg2 weles.JobPagination) ([]weles.JobInfo, weles.ListInfo, error) + type MockJobManagerMockRecorder struct + func (mr *MockJobManagerMockRecorder) CancelJob(arg0 interface{}) *gomock.Call + func (mr *MockJobManagerMockRecorder) CreateJob(arg0 interface{}) *gomock.Call + func (mr *MockJobManagerMockRecorder) ListJobs(arg0, arg1, arg2 interface{}) *gomock.Call + type MockParser struct + func NewMockParser(ctrl *gomock.Controller) *MockParser + func (m *MockParser) EXPECT() *MockParserMockRecorder + func (m *MockParser) ParseYaml(arg0 []byte) (*weles.Config, error) + type MockParserMockRecorder struct + func (mr *MockParserMockRecorder) ParseYaml(arg0 interface{}) *gomock.Call