tasks

Documentation

Index

• Constants
• func NewDownloadVideoTask(id string) (*asynq.Task, error)
• type DownloadVideoPayload
• type VideoDownloader
  • func NewVideoDownloader(mediaService mediaService) *VideoDownloader
  • func (d *VideoDownloader) ProcessTask(ctx context.Context, t *asynq.Task) error

Constants

const (
	TypeDownloadVideo = "video:download"
)

Functions

func NewDownloadVideoTask

func NewDownloadVideoTask(id string) (*asynq.Task, error)

Types

type DownloadVideoPayload

type DownloadVideoPayload struct {
	ID string `json:"id"`
}

type VideoDownloader

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

func NewVideoDownloader

func NewVideoDownloader(mediaService mediaService) *VideoDownloader

func (*VideoDownloader) ProcessTask

func (d *VideoDownloader) ProcessTask(ctx context.Context, t *asynq.Task) error