Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LocalMemScheduler ¶
type LocalMemScheduler struct {
// contains filtered or unexported fields
}
scheduler use memory as task and result queue
func NewLocalMemScheduler ¶
func NewLocalMemScheduler() *LocalMemScheduler
func (*LocalMemScheduler) AddTask ¶
func (this *LocalMemScheduler) AddTask(task model.Task)
func (*LocalMemScheduler) GetTask ¶
func (this *LocalMemScheduler) GetTask() model.Task
func (*LocalMemScheduler) GetTaskSize ¶
func (this *LocalMemScheduler) GetTaskSize() int
type SqlScheduler ¶
type SqlScheduler struct {
// contains filtered or unexported fields
}
scheduler use sql database as task and result queue
func NewLocalSqlScheduler ¶
func NewLocalSqlScheduler(db *gorm.DB) *SqlScheduler
func (*SqlScheduler) AddTask ¶
func (this *SqlScheduler) AddTask(task model.Task)
func (*SqlScheduler) GetTask ¶
func (this *SqlScheduler) GetTask() model.Task
func (*SqlScheduler) GetTaskSize ¶
func (this *SqlScheduler) GetTaskSize() int
Click to show internal directories.
Click to hide internal directories.