batchapi

Documentation

Index

• Constants
• func DeleteAPI(apiName string, keepCache bool) error
• func DryRun(submission *schema.BatchJobSubmission) ([]string, error)
• func ErrorItemSizeExceedsLimit(index int, size int, limit int) error
• func ErrorNoS3FilesFound() error
• func GetAPIByName(deployedResource *operator.DeployedResource) ([]schema.APIResponse, error)
• func GetAllAPIs(virtualServices []istioclientnetworking.VirtualService, ...) ([]schema.APIResponse, error)
• func GetJob(jobKey spec.JobKey) (*schema.BatchJobResponse, error)
• func StopJob(jobKey spec.JobKey) error
• func SubmitJob(apiName string, submission *schema.BatchJobSubmission) (*spec.BatchJob, error)
• func UpdateAPI(apiConfig *userconfig.API) (*spec.API, string, error)

Constants

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

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

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)