controller

type Boruter interface {
	notifier.Notifier
	// Request creates request for Dryad and awaits until it is ready,
	// then acquires it and sends notification.
	Request(weles.JobID)
	// Release returns no longer used Dryad to Boruta's pool.
	Release(weles.JobID)
}

type BoruterImpl struct {
	// Notifier provides channel for communication with Controller.
	notifier.Notifier
	// contains filtered or unexported fields
}

type Controller struct {
	weles.JobManager
	// contains filtered or unexported fields
}

type Downloader interface {
	notifier.Notifier
	// DispatchDownloads requests downloading of artifacts required to start the Job.
	// It prepares paths for tests results and updates Job's config with artifacts paths.
	DispatchDownloads(weles.JobID)
}

type DownloaderImpl struct {
	// Notifier provides channel for communication with Controller.
	notifier.Notifier
	// contains filtered or unexported fields
}

type Dryader interface {
	notifier.Notifier
	// StartJob delegates Job execution to DryadJobManager.
	StartJob(weles.JobID)
	// CancelJob stops execution of the Job.
	CancelJob(weles.JobID)
}

type DryaderImpl struct {
	// Notifier provides channel for communication with Controller.
	notifier.Notifier
	// contains filtered or unexported fields
}

type Job struct {
	weles.JobInfo
	// contains filtered or unexported fields
}

type JobsController interface {
	// NewJob creates a new Job and returns newly assigned JobID.
	NewJob(yaml []byte) (weles.JobID, error)
	// GetYaml returns yaml Job description.
	GetYaml(weles.JobID) ([]byte, error)
	// SetConfig sets config in Job.
	SetConfig(weles.JobID, weles.Config) error
	// SetStatusAndInfo changes status and info of the Job.
	SetStatusAndInfo(weles.JobID, weles.JobStatus, string) error
	// GetConfig gets Job's config.
	GetConfig(weles.JobID) (weles.Config, error)
	// SetDryad saves access info for acquired Dryad.
	SetDryad(weles.JobID, weles.Dryad) error
	// GetDryad returns Dryad acquired for the Job.
	GetDryad(weles.JobID) (weles.Dryad, error)
	// List returns information on Jobs. It takes 3 arguments:
	// - JobFilter containing filters
	// - JobSorter containing sorting key and sorting direction
	// - JobPagination containing element after/before which a page should be returned. It also
	// contains information about direction of pagination and the size of the returned page which
	// must always be set.
	List(filter weles.JobFilter, sorter weles.JobSorter, paginator weles.JobPagination) ([]weles.JobInfo, weles.ListInfo, error) // nolint: lll
}

type JobsControllerImpl struct {
	JobsController
	// contains filtered or unexported fields
}

type Parser interface {
	notifier.Notifier
	// Parse prepares Job's config.
	Parse(weles.JobID)
}

type ParserImpl struct {
	// Notifier provides channel for communication with Controller.
	notifier.Notifier
	// contains filtered or unexported fields
}