repositories

Documentation

Index

• type Messenger
• type TaskRepository
• type VideoRepository
• type WorkerRepository

Types

type Messenger

type Messenger interface {
	ResourcesWatcher() // TODO: remove this unused function, make sure to regenerate mock
	Publish(data interface{}, queueName string) error
	ReadMessage(result chan<- interface{}, queueName string, setQos bool)
}

type TaskRepository

type TaskRepository interface {
	Get(taskId string) models.Task
	GetAll(limit int64) ([]*models.Task, error)
	GetOneByVideoNameAndKind(name string, kind models.TaskKind) (*models.Task, error)
	GetTranscodeTasksByVideoNameAndResolution(name, resolution string) ([]*models.Task, error)
	Add(task *models.Task) error
	Update(task *models.Task) error
	Delete(taskId string) error
}

type VideoRepository

type VideoRepository interface {
	Get(videoId uint) models.Video
	GetAvailable(limit int64) ([]*models.Video, error)
	GetOneByName(key string) (*models.Video, error)
	Find(key string) []*models.Video
	Add(video *models.Video) error
	AddMany(videoList []*models.Video) error
	Update(video *models.Video) error
	Delete(videoId uint) error
}

type WorkerRepository

type WorkerRepository interface {
	Get(workerId uint) models.Worker
	GetAll(limit int64) ([]*models.Worker, error)
	Add(worker *models.Worker) error
	Upsert(worker *models.Worker) error
	Delete(podName string) error
}