queue

Documentation

Index

• Constants
• Variables
• func InitCutWorker()
• func InitEncodeWorker()
• func InitMergeWorker()
• func InitServer()

Constants

const (
	CUT_QUEUE             = "cut_" + version.FINALRIP_VERSION
	ENCODE_QUEUE_DEFAULT  = "encode_default_" + version.FINALRIP_VERSION
	ENCODE_QUEUE_PRIORITY = "encode_priority_" + version.FINALRIP_VERSION
	MERGE_QUEUE           = "merge_" + version.FINALRIP_VERSION
)

Variables

var (
	Qc  *asynq.Client
	Qs  *asynq.Server
	Isp *asynq.Inspector
)

Functions

func InitCutWorker

func InitCutWorker()

func InitEncodeWorker

func InitEncodeWorker()

func InitMergeWorker

func InitMergeWorker()

func InitServer

func InitServer()