jobs

Documentation

Index

• Constants
• type Job
• type JobManager
  • func GetJobManager() *JobManager
  • func (jm *JobManager) AddJob(jobType string, params map[string]string) string
  • func (jm *JobManager) ExecuteJob(jobFunc func(params map[string]string), job *Job)
  • func (jm *JobManager) GetJobs() map[string]*Job
  • func (jm *JobManager) JobComplete(jobId string)
  • func (jm *JobManager) StartJob(jobFunc func(params map[string]string), jobType string, ...) string

Constants

const JobStatusDone = "Done"

const JobStatusStarted = "Started"

const JobTypeParser = "Parser"

const JobTypeScraper = "Scraper"

Types

type Job

type Job struct {
	StartTime, EndTime        int64
	JobId, JobType, JobStatus string
	Params                    map[string]string
}

type JobManager

type JobManager struct {
	// contains filtered or unexported fields
}

Keeps track of running jobs in memory. No need to persist since jobs will only run in the single go process for now.

func GetJobManager

func GetJobManager() *JobManager

func (*JobManager) AddJob

func (jm *JobManager) AddJob(jobType string, params map[string]string) string

func (*JobManager) ExecuteJob

func (jm *JobManager) ExecuteJob(jobFunc func(params map[string]string), job *Job)

func (*JobManager) GetJobs

func (jm *JobManager) GetJobs() map[string]*Job

func (*JobManager) JobComplete

func (jm *JobManager) JobComplete(jobId string)

func (*JobManager) StartJob

func (jm *JobManager) StartJob(jobFunc func(params map[string]string), jobType string, params map[string]string) string