worker

Documentation

Index

• Constants
• func InitHealthCheck(cfg *config.Configuration, connection *amqp.Connection, rabbitmqUri string)
• type Services
  • func NewWorkerService(mb repositories.Messenger, conf *config.Configuration) 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

const (
	TmpPath = "tmpworker"
)

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 (s *Svc) GetWorkerInfo() *models.Worker

func (*Svc) ProcessTaskDash

func (s *Svc) ProcessTaskDash(task *models.Task) error

func (*Svc) ProcessTaskMerge

func (s *Svc) ProcessTaskMerge(task *models.Task) error

func (*Svc) ProcessTaskSplit

func (s *Svc) ProcessTaskSplit(task *models.Task) error

func (Svc) ProcessTaskTranscodeAudio

func (s Svc) ProcessTaskTranscodeAudio(task *models.Task) error

func (*Svc) ProcessTaskTranscodeVideo

func (s *Svc) ProcessTaskTranscodeVideo(task *models.Task) error

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