job

Documentation

Index

• Variables
• func NewWithSeconds() *cron.Cron
• type CountCommentJob
  • func NewCommentJob(cj *jbiz.CountCommentJobRepo, conf *conf.Qycms, logger log.Logger) *CountCommentJob
  • func (c *CountCommentJob) Handle()
  • func (c *CountCommentJob) Stop()
• type CronJobServer
  • func NewCronJobServer(conf *conf.Qycms, logger log.Logger, cj *jbiz.CountCommentJobRepo, ...) *CronJobServer
  • func (c *CronJobServer) Handle()
  • func (c *CronJobServer) Stop()
• type PostVCountJob
  • func NewPostVCountJob(cj *jbiz.PostVCountJobRepo, conf *conf.Qycms, logger log.Logger) *PostVCountJob
  • func (c *PostVCountJob) Handle()
  • func (c *PostVCountJob) Stop()
• type QyCronJob
  • func NewQyCronJob(logger log.Logger, cjs *CronJobServer) *QyCronJob
  • func (s *QyCronJob) Start(ctx context.Context) error
  • func (s *QyCronJob) Stop(ctx context.Context) error
• type QyJob
• type SiteMapJob
  • func NewSiteMapJob(cj *jbiz.SiteMapJobRepo, conf *conf.Qycms, logger log.Logger) *SiteMapJob
  • func (c *SiteMapJob) Handle()
  • func (c *SiteMapJob) Stop()

Variables

var ProviderSet = wire.NewSet(NewCronJobServer)

Functions

func NewWithSeconds

func NewWithSeconds() *cron.Cron

Types

type CountCommentJob

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

CountCommentJob 评论数据更新定时 每天1点

func NewCommentJob

func NewCommentJob(cj *jbiz.CountCommentJobRepo, conf *conf.Qycms, logger log.Logger) *CountCommentJob

func (*CountCommentJob) Handle

func (c *CountCommentJob) Handle()

func (*CountCommentJob) Stop

func (c *CountCommentJob) Stop()

type CronJobServer

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

func NewCronJobServer

func NewCronJobServer(conf *conf.Qycms, logger log.Logger,
	cj *jbiz.CountCommentJobRepo,
	pcj *jbiz.PostVCountJobRepo,
	smj *jbiz.SiteMapJobRepo,
	emj *jbiz.EmailSendJobRepo,
) *CronJobServer

func (*CronJobServer) Handle

func (c *CronJobServer) Handle()

func (*CronJobServer) Stop

func (c *CronJobServer) Stop()

type PostVCountJob

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

func NewPostVCountJob

func NewPostVCountJob(cj *jbiz.PostVCountJobRepo, conf *conf.Qycms, logger log.Logger) *PostVCountJob

func (*PostVCountJob) Handle

func (c *PostVCountJob) Handle()

func (*PostVCountJob) Stop

func (c *PostVCountJob) Stop()

type QyCronJob

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

func NewQyCronJob

func NewQyCronJob(logger log.Logger,
	cjs *CronJobServer) *QyCronJob

func (*QyCronJob) Start

func (s *QyCronJob) Start(ctx context.Context) error

func (*QyCronJob) Stop

func (s *QyCronJob) Stop(ctx context.Context) error

type QyJob

type QyJob interface {
	Handle()
	Stop()
}

type SiteMapJob

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

func NewSiteMapJob

func NewSiteMapJob(cj *jbiz.SiteMapJobRepo, conf *conf.Qycms, logger log.Logger) *SiteMapJob

func (*SiteMapJob) Handle

func (c *SiteMapJob) Handle()

func (*SiteMapJob) Stop

func (c *SiteMapJob) Stop()