module

type Context struct {
	Status           api.TaskStatus
	InitData         interface{}
	IntermediateData interface{}
	FinalData        interface{}
}

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

type Job interface {
	Spliterator
	Id() string
	GetResult() map[string]interface{}
}

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

type JobStore interface {
	Store(job Job)
	Load(jobId string) (job Job, exist bool)
}

type Spliterator interface {
	TryAdvance(func(task *Task)) (finished bool)
}

type Task struct {
	Id            string
	JobId         string
	Ctx           *Context
	FuncId        string
	UpdateHandler func(*Task)
}

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