Documentation ¶
Index ¶
- type Agent
- type JobManager
- func (mgr *JobManager) AddJobProcessor(jobProcessor JobProcessor)
- func (mgr *JobManager) CleanupJob(job *model.Job)
- func (mgr *JobManager) PollPendingJobs() (*model.Job, error)
- func (mgr *JobManager) ProcessJob(job *model.Job) (io.ReadCloser, error)
- func (mgr *JobManager) Start()
- func (mgr *JobManager) Stop()
- func (mgr *JobManager) StreamJobResults(job *model.Job, reader io.ReadCloser) error
- func (mgr *JobManager) UpdateJob(job *model.Job) error
- type JobProcessor
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Agent ¶
type Agent struct { Client *web.Client Config *config.AgentConfig JobMgr *JobManager Version string // contains filtered or unexported fields }
type JobManager ¶
type JobManager struct {
// contains filtered or unexported fields
}
func NewJobManager ¶
func NewJobManager(agent *Agent) *JobManager
func (*JobManager) AddJobProcessor ¶
func (mgr *JobManager) AddJobProcessor(jobProcessor JobProcessor)
func (*JobManager) CleanupJob ¶
func (mgr *JobManager) CleanupJob(job *model.Job)
func (*JobManager) PollPendingJobs ¶
func (mgr *JobManager) PollPendingJobs() (*model.Job, error)
func (*JobManager) ProcessJob ¶
func (mgr *JobManager) ProcessJob(job *model.Job) (io.ReadCloser, error)
func (*JobManager) Start ¶
func (mgr *JobManager) Start()
func (*JobManager) Stop ¶
func (mgr *JobManager) Stop()
func (*JobManager) StreamJobResults ¶
func (mgr *JobManager) StreamJobResults(job *model.Job, reader io.ReadCloser) error
type JobProcessor ¶
Click to show internal directories.
Click to hide internal directories.