tasks

Documentation

Index

• func FetcherTaskPusher(c *asynq.Client, fetchType int, id int64, updateAfter string, ...) (err error)
• func GetNewAPITaskKey(fetchType int, id int64, reqId string) string
• func GetNewFetcherTaskKey(fetchType int, id int64) string
• func NewAPITask(fetchType int, id int64, reqId string) (*asynq.Task, string, error)
• func NewFetcherTask(fetchType int, id int64, updateAfter string, searchLimit int64) (*asynq.Task, string, error)
• type APIPayload
• type FetchPayload

Functions

func FetcherTaskPusher

func FetcherTaskPusher(c *asynq.Client, fetchType int, id int64, updateAfter string, searchLimit int64) (err error)

func GetNewAPITaskKey

func GetNewAPITaskKey(fetchType int, id int64, reqId string) string

func GetNewFetcherTaskKey

func GetNewFetcherTaskKey(fetchType int, id int64) string

func NewAPITask

func NewAPITask(fetchType int, id int64, reqId string) (*asynq.Task, string, error)

func NewFetcherTask

func NewFetcherTask(fetchType int, id int64, updateAfter string, searchLimit int64) (*asynq.Task, string, error)

Types

type APIPayload

type APIPayload struct {
	Type   int    `json:"type"`
	Id     int64  `json:"id"`
	TaskId string `json:"taskId"`
}

type FetchPayload

type FetchPayload struct {
	Type        int    `json:"type"`
	Id          int64  `json:"id"`
	UpdateAfter string `json:"updateAfter"`
	SearchLimit int64  `json:"searchLimit"`
}