queue

Documentation

Index

• type Queue
• type Service
  • func NewService(store *database.Database, vodService *vod.Service, ...) *Service
  • func (s *Service) ArchiveGetQueueItem(qID uuid.UUID) (*ent.Queue, error)
  • func (s *Service) CreateQueueItem(queueDto Queue, vID uuid.UUID) (*ent.Queue, error)
  • func (s *Service) DeleteQueueItem(c echo.Context, qID uuid.UUID) error
  • func (s *Service) GetQueueItem(qID uuid.UUID) (*ent.Queue, error)
  • func (s *Service) GetQueueItems(c echo.Context) ([]*ent.Queue, error)
  • func (s *Service) GetQueueItemsFilter(c echo.Context, processing bool) ([]*ent.Queue, error)
  • func (s *Service) ReadLogFile(c echo.Context, qID uuid.UUID, logType string) ([]byte, error)
  • func (s *Service) UpdateQueueItem(queueDto Queue, qID uuid.UUID) (*ent.Queue, error)

Types

type Queue

type Queue struct {
	ID                       uuid.UUID        `json:"id"`
	LiveArchive              bool             `json:"live_archive"`
	OnHold                   bool             `json:"on_hold"`
	VideoProcessing          bool             `json:"video_processing"`
	ChatProcessing           bool             `json:"chat_processing"`
	Processing               bool             `json:"processing"`
	TaskVodCreateFolder      utils.TaskStatus `json:"task_vod_create_folder"`
	TaskVodDownloadThumbnail utils.TaskStatus `json:"task_vod_download_thumbnail"`
	TaskVodSaveInfo          utils.TaskStatus `json:"task_vod_save_info"`
	TaskVideoDownload        utils.TaskStatus `json:"task_video_download"`
	TaskVideoConvert         utils.TaskStatus `json:"task_video_convert"`
	TaskVideoMove            utils.TaskStatus `json:"task_video_move"`
	TaskChatDownload         utils.TaskStatus `json:"task_chat_download"`
	TaskChatConvert          utils.TaskStatus `json:"task_chat_convert"`
	TaskChatRender           utils.TaskStatus `json:"task_chat_render"`
	TaskChatMove             utils.TaskStatus `json:"task_chat_move"`
	UpdatedAt                time.Time        `json:"updated_at"`
	CreatedAt                time.Time        `json:"created_at"`
}

type Service

type Service struct {
	Store          *database.Database
	VodService     *vod.Service
	ChannelService *channel.Service
}

func NewService

func NewService(store *database.Database, vodService *vod.Service, channelService *channel.Service) *Service

func (*Service) ArchiveGetQueueItem

func (s *Service) ArchiveGetQueueItem(qID uuid.UUID) (*ent.Queue, error)

func (*Service) CreateQueueItem

func (s *Service) CreateQueueItem(queueDto Queue, vID uuid.UUID) (*ent.Queue, error)

func (*Service) DeleteQueueItem

func (s *Service) DeleteQueueItem(c echo.Context, qID uuid.UUID) error

func (*Service) GetQueueItem

func (s *Service) GetQueueItem(qID uuid.UUID) (*ent.Queue, error)

func (*Service) GetQueueItems

func (s *Service) GetQueueItems(c echo.Context) ([]*ent.Queue, error)

func (*Service) GetQueueItemsFilter

func (s *Service) GetQueueItemsFilter(c echo.Context, processing bool) ([]*ent.Queue, error)

func (*Service) ReadLogFile

func (s *Service) ReadLogFile(c echo.Context, qID uuid.UUID, logType string) ([]byte, error)

func (*Service) UpdateQueueItem

func (s *Service) UpdateQueueItem(queueDto Queue, qID uuid.UUID) (*ent.Queue, error)