tasks

Documentation

Index

• Constants
• func EnqueueCrawlTask(client AsynqClient, payload *CrawlTaskPayload) (string, error)
• func NewCrawlTask(payload *CrawlTaskPayload) (*asynq.Task, error)
• type AsynqClient
• type CrawlTaskPayload

Constants

const (
	CrawlTaskType = "crawl"
)

Functions

func EnqueueCrawlTask

func EnqueueCrawlTask(client AsynqClient, payload *CrawlTaskPayload) (string, error)

EnqueueCrawlTask creates asynq task

func NewCrawlTask

func NewCrawlTask(payload *CrawlTaskPayload) (*asynq.Task, error)

Types

type AsynqClient

type AsynqClient interface {
	Enqueue(task *asynq.Task, opts ...asynq.Option) (*asynq.TaskInfo, error)
}

AsynqClient defines an interface with the methods you use from asynq.Client.

type CrawlTaskPayload

type CrawlTaskPayload struct {
	URL         string `json:"url"`
	SearchTerms string `json:"search_terms"`
	CrawlSiteID string `json:"crawl_site_id"`
	MaxDepth    int    `json:"max_depth"`
	Debug       bool   `json:"debug"`
}