job

Documentation

Index

• type CronJobBuilder
  • func NewCronJobBuilder(l logger.Logger, opts prometheus.SummaryOpts) *CronJobBuilder
  • func (c *CronJobBuilder) Build(job Job) cron.Job
• type Job
• type RankingJob
  • func NewRankingJob(rankingSvc service.RankingService) *RankingJob
  • func (r *RankingJob) Name() string
  • func (r *RankingJob) Run() error

Types

type CronJobBuilder

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

func NewCronJobBuilder

func NewCronJobBuilder(l logger.Logger, opts prometheus.SummaryOpts) *CronJobBuilder

func (*CronJobBuilder) Build

func (c *CronJobBuilder) Build(job Job) cron.Job

type Job

type Job interface {
	Name() string
	Run() error
}

type RankingJob

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

func NewRankingJob

func NewRankingJob(rankingSvc service.RankingService) *RankingJob

func (*RankingJob) Name

func (r *RankingJob) Name() string

func (*RankingJob) Run

func (r *RankingJob) Run() error