task

Documentation

Index

• type TaskGenerator
  • func NewTaskGenerator(mq models.MessageQueue, taskchaname string, retrys uint, ...) *TaskGenerator
  • func (gen *TaskGenerator) IllustDetailTask(ctx context.Context, id uint64) error
  • func (gen *TaskGenerator) RankInitTask(ctx context.Context, mode string, date string, content string) error
  • func (gen *TaskGenerator) SendTask(task models.CrawlTask) error
  • func (gen *TaskGenerator) UgoiraDetailTask(ctx context.Context, id uint64) error
  • func (gen *TaskGenerator) UserDetailTask(ctx context.Context, id uint64) error
  • func (gen *TaskGenerator) UserIllustsTask(ctx context.Context, 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(ctx context.Context, id uint64) error

func (*TaskGenerator) RankInitTask

func (gen *TaskGenerator) RankInitTask(ctx context.Context, 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(ctx context.Context, id uint64) error

func (*TaskGenerator) UserDetailTask

func (gen *TaskGenerator) UserDetailTask(ctx context.Context, id uint64) error

func (*TaskGenerator) UserIllustsTask

func (gen *TaskGenerator) UserIllustsTask(ctx context.Context, id uint64) error