A PodSource that exposes and external API for submitting pods in an orchestrator-independent manner.
type PodSubmissionApi struct {
// contains filtered or unexported fields
}
func NewPodSubmissionApi(schedConfig *config.SchedulerConfig) *PodSubmissionApi
func (ps *PodSubmissionApi) IncomingPods() chan *pipeline.IncomingPod
func (ps *PodSubmissionApi) RegisterStatusEndpoint(relativePath string, ginEngine *gin.Engine) error
Registers the status endpoint (relative to the engine's root path).
func (ps *PodSubmissionApi) RegisterSubmitPodEndpoint(relativePath string, ginEngine *gin.Engine) error
Registers the submit pod endpoint with the specified gin engine under the specified path (relative to the engine's root path).
DTO for error responses.
type PodSubmissionApiError struct {
Error *client.PolarisErrorDto `json:"error" yaml:"error"`
}