Documentation
¶
Index ¶
- Constants
- func InitHealthCheck(cfg *config.Configuration, connection *amqp.Connection, rabbitmqUri string)
- type Services
- type Svc
- func (s *Svc) GetMessageBroker() repositories.Messenger
- func (s *Svc) GetWorkerInfo() *models.Worker
- func (s *Svc) ProcessTaskDash(task *models.Task) error
- func (s *Svc) ProcessTaskMerge(task *models.Task) error
- func (s *Svc) ProcessTaskSplit(task *models.Task) error
- func (s Svc) ProcessTaskTranscodeAudio(task *models.Task) error
- func (s *Svc) ProcessTaskTranscodeVideo(task *models.Task) error
- func (s *Svc) RegisterWorker()
Constants ¶
View Source
const (
TmpPath = "tmpworker"
)
Variables ¶
This section is empty.
Functions ¶
func InitHealthCheck ¶
func InitHealthCheck(cfg *config.Configuration, connection *amqp.Connection, rabbitmqUri string)
Types ¶
type Services ¶
type Services interface {
GetWorkerInfo() *models.Worker
//RegisterWorker will register worker to API Server
RegisterWorker()
GetMessageBroker() repositories.Messenger
ProcessTaskDash(task *models.Task) error
ProcessTaskSplit(task *models.Task) error
ProcessTaskTranscodeVideo(task *models.Task) error
ProcessTaskMerge(task *models.Task) error
ProcessTaskTranscodeAudio(task *models.Task) error
}
func NewWorkerService ¶
func NewWorkerService(mb repositories.Messenger, conf *config.Configuration) Services
type Svc ¶
type Svc struct {
// contains filtered or unexported fields
}
func (*Svc) GetMessageBroker ¶
func (s *Svc) GetMessageBroker() repositories.Messenger
func (*Svc) GetWorkerInfo ¶
func (Svc) ProcessTaskTranscodeAudio ¶
func (*Svc) ProcessTaskTranscodeVideo ¶
func (*Svc) RegisterWorker ¶
func (s *Svc) RegisterWorker()
RegisterWorker will execute every 30 second to regularly register. This is current workaround to prevent worker from falsely marked as terminated when actually there is a network partition during api server check
Source Files
Click to show internal directories.
Click to hide internal directories.