taskapi

package
v0.42.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 23, 2022 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ManageJobResourcesCronPeriod = 60 * time.Second
)

Variables

This section is empty.

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)

GetAPIByName 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) (*spec.API, string, error)

UpdateAPI deploys or update a task api without triggering any task

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL