Function getPlanFromHTTPRequest

pkg/scheduler/scheduler.go:209–219

(req *httpgrpc.HTTPRequest)

}

func getPlanFromHTTPRequest(req *httpgrpc.HTTPRequest) ([]byte, error) {
	if req.Body == nil {
		return nil, nil
	}
	values, err := url.ParseQuery(string(req.Body))
	if err != nil {
		return nil, err
	}
	plan := values.Get("plan")
	return []byte(plan), nil
}

// FrontendLoop handles connection from frontend.
func (s *Scheduler) FrontendLoop(frontend schedulerpb.SchedulerForFrontend_FrontendLoopServer) error {