task

Documentation

Index

• type TaskGenerator
  • func NewTaskGenerator(mq models.MessageQueue, taskchaname string, retrys uint, ...) *TaskGenerator
  • func (gen *TaskGenerator) IllustDetailTask(id uint64) error
  • func (gen *TaskGenerator) RankInitTask(mode string, date string, content string) error
  • func (gen *TaskGenerator) SendTask(task models.CrawlTask) error
  • func (gen *TaskGenerator) UgoiraDetailTask(id uint64) error
  • func (gen *TaskGenerator) UserDetailTask(id uint64) error
  • func (gen *TaskGenerator) UserIllustsTask(id uint64) error

Types

type TaskGenerator

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

func NewTaskGenerator

func NewTaskGenerator(mq models.MessageQueue, taskchaname string, retrys uint, tracer *tasktracer.TaskTracer) *TaskGenerator

func (*TaskGenerator) IllustDetailTask

func (gen *TaskGenerator) IllustDetailTask(id uint64) error

func (*TaskGenerator) RankInitTask

func (gen *TaskGenerator) RankInitTask(mode string, date string, content string) error

func (*TaskGenerator) SendTask

func (gen *TaskGenerator) SendTask(task models.CrawlTask) error

func (*TaskGenerator) UgoiraDetailTask

func (gen *TaskGenerator) UgoiraDetailTask(id uint64) error

func (*TaskGenerator) UserDetailTask

func (gen *TaskGenerator) UserDetailTask(id uint64) error

func (*TaskGenerator) UserIllustsTask

func (gen *TaskGenerator) UserIllustsTask(id uint64) error