Documentation ¶
Index ¶
- Constants
- Variables
- func NewResponse(ID string, Status string, ResponseCode int, Message string, ...)
- func PermissiveCORS(w http.ResponseWriter, r *http.Request)
- func PermissiveCORSMiddleware(next func(http.ResponseWriter, *http.Request)) func(http.ResponseWriter, *http.Request)
- func RegisterLogger() log.Logger
- type STATE
- type Scheduler
- func (schd *Scheduler) CheckTaskPresent(id ulid.ULID) bool
- func (schd *Scheduler) DecrementTaskCount()
- func (schd *Scheduler) GetState(id ulid.ULID) (STATE, error)
- func (schd *Scheduler) IncrementTaskCount()
- func (schd *Scheduler) ModifyState(id ulid.ULID, newState STATE) error
- func (schd *Scheduler) RemoveTask(id ulid.ULID) error
- func (schd *Scheduler) ScheduleTask(task *Task) error
- func (schd *Scheduler) TotalTask() uint64
- type ServerComponent
- func (comp *ServerComponent) CreateNewJob(w http.ResponseWriter, r *http.Request)
- func (comp *ServerComponent) CreateWorkerHandler(w http.ResponseWriter, r *http.Request)
- func (comp *ServerComponent) DownloadWorkerHandler(w http.ResponseWriter, r *http.Request)
- func (comp *ServerComponent) GetWorkerStatus(w http.ResponseWriter, r *http.Request)
- func (comp *ServerComponent) HandleJob(w http.ResponseWriter, r *http.Request)
- func (comp *ServerComponent) ModifyWorkerStatus(w http.ResponseWriter, r *http.Request)
- type Task
- type WorkerStatus
Constants ¶
View Source
const MAXDURATION int = 10000
View Source
const MAXWORKER uint64 = 2
The total concurrent jobs we want to handle
View Source
const WORKERIDEXPIRE uint64 = 5
Variables ¶
View Source
var MapStatetoMsg = map[STATE]string{ NOT_RUNNING: "Not Running", PLAY: "Running", PAUSE: "Paused", STOP: "Terminated", COMPLETED: "Completed", }
Functions ¶
func NewResponse ¶
func PermissiveCORS ¶
func PermissiveCORS(w http.ResponseWriter, r *http.Request)
func PermissiveCORSMiddleware ¶
func PermissiveCORSMiddleware(next func(http.ResponseWriter, *http.Request)) func(http.ResponseWriter, *http.Request)
func RegisterLogger ¶
Types ¶
type Scheduler ¶
type Scheduler struct {
// contains filtered or unexported fields
}
func NewScheduler ¶
func NewScheduler() *Scheduler
func (*Scheduler) CheckTaskPresent ¶
Check if the task is present in the scheduler
func (*Scheduler) DecrementTaskCount ¶
func (schd *Scheduler) DecrementTaskCount()
func (*Scheduler) IncrementTaskCount ¶
func (schd *Scheduler) IncrementTaskCount()
func (*Scheduler) ModifyState ¶
func (*Scheduler) ScheduleTask ¶
type ServerComponent ¶
type ServerComponent struct {
// contains filtered or unexported fields
}
func NewServerComponent ¶
func NewServerComponent(srv *http.Server, logger log.Logger) *ServerComponent
func (*ServerComponent) CreateNewJob ¶
func (comp *ServerComponent) CreateNewJob(w http.ResponseWriter, r *http.Request)
General Server API Handler
func (*ServerComponent) CreateWorkerHandler ¶
func (comp *ServerComponent) CreateWorkerHandler(w http.ResponseWriter, r *http.Request)
Upload API Handler
func (*ServerComponent) DownloadWorkerHandler ¶
func (comp *ServerComponent) DownloadWorkerHandler(w http.ResponseWriter, r *http.Request)
Download API Handler
func (*ServerComponent) GetWorkerStatus ¶
func (comp *ServerComponent) GetWorkerStatus(w http.ResponseWriter, r *http.Request)
func (*ServerComponent) HandleJob ¶
func (comp *ServerComponent) HandleJob(w http.ResponseWriter, r *http.Request)
Long Running task API Handler
func (*ServerComponent) ModifyWorkerStatus ¶
func (comp *ServerComponent) ModifyWorkerStatus(w http.ResponseWriter, r *http.Request)
Click to show internal directories.
Click to hide internal directories.