scheduler

package

v1.0.1 Latest Latest Go to latest Published: Feb 6, 2025 License: Apache-2.0 Imports: 20 Imported by: 1

Details

This section is empty.

This section is empty.

This section is empty.

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

func (s *HttpServer) CreateTask(c *gin.Context)

func (s *HttpServer) ListTask(c *gin.Context)

ListTask 查询任务列表

func (s *HttpServer) OperateTask(c *gin.Context)

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

func NewScheduler(
	elector election.Interface,
	discover discover.Interface,
	taskRepo taskrepo.Interface,
) (*Scheduler, error)

func (s *Scheduler) CreateTask(ctx context.Context, task *model.Task) error

func (s *Scheduler) HttpServer() *HttpServer

func (s *Scheduler) ListTask(ctx context.Context, filter *model.TaskFilter) ([]*model.Task, error)

func (s *Scheduler) OperateTask(ctx context.Context, bizID, taskKey string, nextStatus model.TaskStatus) error

func (s *Scheduler) Run() error