batchapi

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: 35 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ErrNoS3FilesFound            = "batchapi.no_s3_files_found"
	ErrBatchItemSizeExceedsLimit = "batchapi.item_size_exceeds_limit"
)

Variables

This section is empty.

Functions

func DeleteAPI

func DeleteAPI(apiName string, keepCache bool) error

func DryRun

func DryRun(submission *schema.BatchJobSubmission) ([]string, error)

func ErrorItemSizeExceedsLimit

func ErrorItemSizeExceedsLimit(index int, size int, limit int) error

func ErrorNoS3FilesFound

func ErrorNoS3FilesFound() error

func GetAPIByName

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

func GetAllAPIs

func GetAllAPIs(virtualServices []istioclientnetworking.VirtualService, batchJobList []batch.BatchJob) ([]schema.APIResponse, error)

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

func GetJob added in v0.39.0

func GetJob(jobKey spec.JobKey) (*schema.BatchJobResponse, error)

func StopJob

func StopJob(jobKey spec.JobKey) error

func SubmitJob

func SubmitJob(apiName string, submission *schema.BatchJobSubmission) (*spec.BatchJob, error)

func UpdateAPI

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

Types

This section is empty.

Jump to

Keyboard shortcuts

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