services

Documentation

Index

• Constants
• type Scheduler
  • func NewSchedulerService(taskRepo repositories.TaskRepository, videoRepo repositories.VideoRepository, ...) Scheduler
• type VideoService
  • func NewVideoService(vidRepo repositories.VideoRepository, schedulerSvc Scheduler, ...) VideoService
• type WorkerService
  • func NewWorkerService(workerRepo repositories.WorkerRepository, mb repositories.Messenger, ...) WorkerService

Constants

const (
	MessageBrokerQueueTaskNew          = "task_new"
	MessageBrokerQueueTaskFinished     = "task_finished"
	MessageBrokerQueueTaskUpdateStatus = "task_update_status"
)

const (
	WorkerNew      = "worker_new"
	WorkerAssigned = "worker_assigned"
	WorkerStatus   = "worker_status"
)

const (
	KeyGetAllTaskProgress = "GetAllTaskProgress"
)

const (
	KeyGetAllVideo = "KeyGetAllVideo"
)

const (
	KeyGetAllWorker = "KeyGetAllWorker"
)

const (
	TaskHTTPEventStream = "task"
)

const (
	WorkerHTTPEventStream = "worker"
)

Types

type Scheduler

type Scheduler interface {
	GetAllTaskProgress() []*models.TaskProgressResponse
	CreateSplitTask(video *models.Video) error
	CreateTranscodeTask(task *models.Task) error
	CreateDashTask(task *models.Task) error
	CreateMergeTask(task *models.Task) error
	ReadMessages()
	//UpdateTask(task *models.Task) error
	DeleteTask(taskId string) error
}

func NewSchedulerService

func NewSchedulerService(
	taskRepo repositories.TaskRepository,
	videoRepo repositories.VideoRepository,
	messenger repositories.Messenger,
	sse *sse.Server,
	cache *cache.Cache,
) Scheduler

type VideoService

type VideoService interface {
	Inspect(filePath string) models.Video
	GetAll() ([]*models.Video, error)
}

func NewVideoService

func NewVideoService(vidRepo repositories.VideoRepository, schedulerSvc Scheduler, cache *cache.Cache) VideoService

type WorkerService

type WorkerService interface {
	//ReadMessage will read all message from message broker
	ReadMessage()
	Scale(replicaNum int32) (*autoscalingv1.Scale, error)
	Get(workerName string) models.Worker
	GetAll() ([]*models.Worker, error)
	Update(workerName string) models.Worker
	Terminate(workerName string) error
}

func NewWorkerService

func NewWorkerService(
	workerRepo repositories.WorkerRepository,
	mb repositories.Messenger,
	sse *sse.Server,
	cache *cache.Cache,
	k8sClient *kubernetes.Clientset,
) WorkerService