Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Context ¶
type Context struct { Status api.TaskStatus InitData interface{} IntermediateData interface{} FinalData interface{} }
type Decider ¶
type Decider struct {
// contains filtered or unexported fields
}
func NewDecider ¶
func NewDecider(pool *WorkerPool, taskQ <-chan *Task) *Decider
type Job ¶
type Job interface { Spliterator Id() string GetResult() map[string]interface{} }
type JobRunner ¶
type JobRunner struct {
// contains filtered or unexported fields
}
func NewJobRunner ¶
func (JobRunner) InterruptCurrentJob ¶
func (j JobRunner) InterruptCurrentJob()
type JobStore ¶
func NewSimpleStore ¶
func NewSimpleStore() JobStore
type Spliterator ¶
type WorkerPool ¶
type WorkerPool struct {
// contains filtered or unexported fields
}
func NewWorkerPool ¶
func NewWorkerPool() *WorkerPool
func (*WorkerPool) InterruptJobTasks ¶
func (w *WorkerPool) InterruptJobTasks(jobId string)
func (*WorkerPool) Remove ¶
func (w *WorkerPool) Remove(id string)
func (*WorkerPool) UpdateStatus ¶
func (w *WorkerPool) UpdateStatus(id string, payload *api.StatusPayload) error
Click to show internal directories.
Click to hide internal directories.