Versions in this module Expand all Collapse all v0 v0.1.0 Oct 12, 2018 Changes in this version + func NewJobManager(arm weles.ArtifactManager, yap weles.Parser, bor boruta.Requests, ...) weles.JobManager + type Boruter interface + Release func(weles.JobID) + Request func(weles.JobID) + func NewBoruter(j JobsController, b boruta.Requests, period time.Duration) Boruter + type BoruterImpl struct + func (h *BoruterImpl) Finish() + func (h *BoruterImpl) Release(j weles.JobID) + func (h *BoruterImpl) Request(j weles.JobID) + type Controller struct + func NewController(js JobsController, pa Parser, do Downloader, bo Boruter, dr Dryader) *Controller + func (c *Controller) CancelJob(j weles.JobID) error + func (c *Controller) CreateJob(yaml []byte) (weles.JobID, error) + func (c *Controller) Finish() + func (c *Controller) ListJobs(filter weles.JobFilter, sorter weles.JobSorter, paginator weles.JobPagination) ([]weles.JobInfo, weles.ListInfo, error) + type Downloader interface + DispatchDownloads func(weles.JobID) + func NewDownloader(j JobsController, a weles.ArtifactManager) Downloader + type DownloaderImpl struct + func (h *DownloaderImpl) DispatchDownloads(j weles.JobID) + type Dryader interface + CancelJob func(weles.JobID) + StartJob func(weles.JobID) + func NewDryader(j JobsController, d weles.DryadJobManager) Dryader + type DryaderImpl struct + func (h *DryaderImpl) CancelJob(j weles.JobID) + func (h *DryaderImpl) Finish() + func (h *DryaderImpl) StartJob(j weles.JobID) + type Job struct + type JobsController interface + GetConfig func(weles.JobID) (weles.Config, error) + GetDryad func(weles.JobID) (weles.Dryad, error) + GetYaml func(weles.JobID) ([]byte, error) + List func(filter weles.JobFilter, sorter weles.JobSorter, paginator weles.JobPagination) ([]weles.JobInfo, weles.ListInfo, error) + NewJob func(yaml []byte) (weles.JobID, error) + SetConfig func(weles.JobID, weles.Config) error + SetDryad func(weles.JobID, weles.Dryad) error + SetStatusAndInfo func(weles.JobID, weles.JobStatus, string) error + func NewJobsController() JobsController + type JobsControllerImpl struct + func (js *JobsControllerImpl) GetConfig(j weles.JobID) (weles.Config, error) + func (js *JobsControllerImpl) GetDryad(j weles.JobID) (weles.Dryad, error) + func (js *JobsControllerImpl) GetYaml(j weles.JobID) ([]byte, error) + func (js *JobsControllerImpl) List(filter weles.JobFilter, sorter weles.JobSorter, paginator weles.JobPagination) ([]weles.JobInfo, weles.ListInfo, error) + func (js *JobsControllerImpl) NewJob(yaml []byte) (weles.JobID, error) + func (js *JobsControllerImpl) SetConfig(j weles.JobID, conf weles.Config) error + func (js *JobsControllerImpl) SetDryad(j weles.JobID, d weles.Dryad) error + func (js *JobsControllerImpl) SetStatusAndInfo(j weles.JobID, newStatus weles.JobStatus, msg string) error + type Parser interface + Parse func(weles.JobID) + func NewParser(j JobsController, a weles.ArtifactManager, p weles.Parser) Parser + type ParserImpl struct + func (h *ParserImpl) Parse(j weles.JobID)
Go to main page