taskapi

Documentation

Index

• Constants
• func DeleteAPI(apiName string, keepCache bool) error
• func GetAPIByName(deployedResource *operator.DeployedResource) ([]schema.APIResponse, error)
• func GetAllAPIs(virtualServices []istioclientnetworking.VirtualService, k8sJobs []kbatch.Job, ...) ([]schema.APIResponse, error)
• func GetJobStatus(jobKey spec.JobKey) (*status.TaskJobStatus, error)
• func ManageJobResources() error
• func StopJob(jobKey spec.JobKey) error
• func SubmitJob(apiName string, submission *schema.TaskJobSubmission) (*spec.TaskJob, error)
• func UpdateAPI(apiConfig *userconfig.API, projectID string) (*spec.API, string, error)

Constants

const (
	ManageJobResourcesCronPeriod = 60 * time.Second
)

Functions

func DeleteAPI

func DeleteAPI(apiName string, keepCache bool) error

DeleteAPI deletes a task api

func GetAPIByName

func GetAPIByName(deployedResource *operator.DeployedResource) ([]schema.APIResponse, error)

GetAllAPIs returns a single task API and its most recently submitted job along with all running task jobs

func GetAllAPIs

func GetAllAPIs(virtualServices []istioclientnetworking.VirtualService, k8sJobs []kbatch.Job, pods []kcore.Pod) ([]schema.APIResponse, error)

GetAllAPIs returns all task APIs, for each API returning the most recently submitted job and all running jobs

func GetJobStatus

func GetJobStatus(jobKey spec.JobKey) (*status.TaskJobStatus, error)

func ManageJobResources

func ManageJobResources() error

func StopJob

func StopJob(jobKey spec.JobKey) error

func SubmitJob

func SubmitJob(apiName string, submission *schema.TaskJobSubmission) (*spec.TaskJob, error)

func UpdateAPI

func UpdateAPI(apiConfig *userconfig.API, projectID string) (*spec.API, string, error)

UpdateAPI deploys or update a task api without triggering any task