batchapi

Documentation

Index

• Constants
• func DeleteAPI(apiName string, keepCache bool) error
• func DryRun(submission *schema.BatchJobSubmission) ([]string, error)
• func ErrorFailedToEnqueueMessages(message string) error
• func ErrorItemSizeExceedsLimit(index int, size int, limit int) error
• func ErrorMessageExceedsMaxSize(messageSize int, messageLimit int) error
• func ErrorNoDataFoundInJobSubmission() error
• func ErrorNoS3FilesFound() 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.BatchJobStatus, error)
• func ManageJobResources() error
• func StopJob(jobKey spec.JobKey) error
• func SubmitJob(apiName string, submission *schema.BatchJobSubmission) (*spec.BatchJob, error)
• func UpdateAPI(apiConfig *userconfig.API, projectID string) (*spec.API, string, error)

Constants

const (
	ErrNoS3FilesFound             = "batchapi.no_s3_files_found"
	ErrNoDataFoundInJobSubmission = "batchapi.no_data_found_in_job_submission"
	ErrFailedToEnqueueMessages    = "batchapi.failed_to_enqueue_messages"
	ErrMessageExceedsMaxSize      = "batchapi.message_exceeds_max_size"
	ErrBatchItemSizeExceedsLimit  = "batchapi.item_size_exceeds_limit"
)

const (
	ManageJobResourcesCronPeriod = 60 * time.Second // If this is going to be updated (made smaller), update the batch worker implementation

)

Functions

func DeleteAPI

func DeleteAPI(apiName string, keepCache bool) error

func DryRun

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

func ErrorFailedToEnqueueMessages

func ErrorFailedToEnqueueMessages(message string) error

func ErrorItemSizeExceedsLimit

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

func ErrorMessageExceedsMaxSize

func ErrorMessageExceedsMaxSize(messageSize int, messageLimit int) error

func ErrorNoDataFoundInJobSubmission

func ErrorNoDataFoundInJobSubmission() error

func ErrorNoS3FilesFound

func ErrorNoS3FilesFound() error

func GetAPIByName

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

func GetAllAPIs

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

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

func GetJobStatus

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

func ManageJobResources

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