Documentation ¶
Index ¶
Constants ¶
View Source
const ( SCHEDULED_STATUS = "scheduled" RUNNING_STATUS = "running" COMPLETED_STATUS = "completed" FAILED_STATUS = "failed" )
View Source
const (
DefaultNumExecutors = 5
)
Variables ¶
View Source
var JobNotFound error = errors.New("Job not found")
Functions ¶
func DefaultExecutor ¶
Types ¶
type InMemoryJobRepository ¶
type InMemoryJobRepository struct {
// contains filtered or unexported fields
}
func NewInMemoryJobRepository ¶
func NewInMemoryJobRepository() *InMemoryJobRepository
func (*InMemoryJobRepository) Load ¶
func (i *InMemoryJobRepository) Load(jobID string) (Job, error)
func (*InMemoryJobRepository) Save ¶
func (i *InMemoryJobRepository) Save(job Job) error
type Job ¶
type JobRepository ¶
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
func NewCustomScheduler ¶
func NewCustomScheduler(numExecutors int, repository JobRepository, executorStrategy Executor) *Scheduler
func NewScheduler ¶
func NewScheduler() *Scheduler
Click to show internal directories.
Click to hide internal directories.