logic

Documentation

Index

• type AddFlowHandler
  • func NewAddFlowHandler(svcCtx *svc.ServiceContext) *AddFlowHandler
  • func (l *AddFlowHandler) ProcessTask(ctx context.Context, _ *asynq.Task) error
• type CronJob
  • func NewCronJob(ctx context.Context, svcCtx *svc.ServiceContext) *CronJob
  • func (l *CronJob) Register() *asynq.ServeMux

Types

type AddFlowHandler

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

SettleRecordHandler shcedule billing to home business

func NewAddFlowHandler

func NewAddFlowHandler(svcCtx *svc.ServiceContext) *AddFlowHandler

func (*AddFlowHandler) ProcessTask

func (l *AddFlowHandler) ProcessTask(ctx context.Context, _ *asynq.Task) error

every one minute exec : if return err != nil , asynq will retry

type CronJob

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

func NewCronJob

func NewCronJob(ctx context.Context, svcCtx *svc.ServiceContext) *CronJob

func (*CronJob) Register

func (l *CronJob) Register() *asynq.ServeMux

register job