Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewRouter ¶
func NewRouter( schedulerHandler SchedulerHandler, workerHandler WorkerHandler, videoHandler VideoHandler, ) *chi.Mux
Types ¶
type SchedulerHandler ¶
type SchedulerHandler interface {
GetTaskUpdate(w http.ResponseWriter, r *http.Request)
GetAllTaskProgress(w http.ResponseWriter, r *http.Request)
Post(w http.ResponseWriter, r *http.Request)
}
func NewSchedulerHandler ¶
func NewSchedulerHandler(schedulerSvc services.Scheduler) SchedulerHandler
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func (*Server) AddEventStreamRoute ¶
func (server *Server) AddEventStreamRoute(s *sse.Server)
type VideoHandler ¶
type VideoHandler interface {
//GetPlaylist fetch all video with finished dask task
GetPlaylist(w http.ResponseWriter, r *http.Request)
UploadHandler(w http.ResponseWriter, r *http.Request)
}
func NewVideoHandler ¶
func NewVideoHandler(cfg *config.Configuration, videoService services.VideoService) VideoHandler
type WorkerHandler ¶
type WorkerHandler interface {
GetWorkerInfo(w http.ResponseWriter, r *http.Request)
ScaleHandler(w http.ResponseWriter, r *http.Request)
}
func NewWorkerHandler ¶
func NewWorkerHandler(workerSvc services.WorkerService) WorkerHandler
Source Files
Click to show internal directories.
Click to hide internal directories.