task

Documentation

Index

• Variables
• func FetchLianjiaHouse(ctx context.Context, ts *TaskScheduler)
• type CronTaskStatus
• type TaskScheduler
  • func NewTaskScheduler(confData *conf.Data, uc *biz.LianjiaUsecase, svc *service.Service, ...) *TaskScheduler
  • func (taskScheduler *TaskScheduler) Start(ctx context.Context) error
  • func (taskScheduler *TaskScheduler) StartAllTask() error
  • func (taskScheduler *TaskScheduler) Stop(ctx context.Context) error

Variables

var FuncMap = map[string]func(ctx context.Context, ts *TaskScheduler){
	"fetch_lianjia_house": FetchLianjiaHouse,
}

var ProviderSet = wire.NewSet(NewTaskScheduler)

ProviderSet is server providers.

Functions

func FetchLianjiaHouse

func FetchLianjiaHouse(ctx context.Context, ts *TaskScheduler)

Types

type CronTaskStatus

type CronTaskStatus string

const (
	CronTaskKey                          = "cron_task"
	CronTaskStatusKey                    = "cron_task_%s_status"
	CronTaskStatusFailed  CronTaskStatus = "failed"
	CronTaskStatusSuccess CronTaskStatus = "success"
	CronTaskStatusRunning CronTaskStatus = "running"
)

type TaskScheduler

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

func NewTaskScheduler

func NewTaskScheduler(confData *conf.Data, uc *biz.LianjiaUsecase, svc *service.Service, redisClient *redis.Client,
	repo biz.LianjiaRepo, logger log.Logger) *TaskScheduler

func (*TaskScheduler) Start

func (taskScheduler *TaskScheduler) Start(ctx context.Context) error

func (*TaskScheduler) StartAllTask

func (taskScheduler *TaskScheduler) StartAllTask() error

func (*TaskScheduler) Stop

func (taskScheduler *TaskScheduler) Stop(ctx context.Context) error