core

Documentation

Overview

Package core holds the business logic for yps

Index

• Constants
• func ProcessPlaylistTasks(playlistMq, videoMq *queue.Queue, resp chan<- error)
• func ProcessUserInput(url string) ([]byte, error)
• func ProcessUserInputTasks(msgMq, playlistMq, videoMq *queue.Queue, resp chan<- error)

Constants

const (
	// UserInputQueue holds the name of the user input queue
	UserInputQueue = `userInput`
	// PlaylistQueue holds the name of the playlists queue
	PlaylistQueue = `playlist`
	// VideoQueue holds the name of the video queue
	VideoQueue = `video`
)

Functions

func ProcessPlaylistTasks

func ProcessPlaylistTasks(playlistMq, videoMq *queue.Queue, resp chan<- error)

ProcessPlaylistTasks processes all the messages from the playlist queue to convert them into video tasks

func ProcessUserInput

func ProcessUserInput(url string) ([]byte, error)

ProcessUserInput transforms the input taken fro the user and returns it in the format needed

func ProcessUserInputTasks

func ProcessUserInputTasks(msgMq, playlistMq, videoMq *queue.Queue, resp chan<- error)

ProcessUserInputTasks processes all the messages from the user input queue