batchapi

package

Versions in this module

v0

v0.26.0

Jan 6, 2021 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.25.0

Dec 23, 2020 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

type JobState

+ func (j JobState) GetFirstCreated() time.Time

v0.24.1

Dec 13, 2020 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.24.0

Dec 9, 2020 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.23.0

Nov 24, 2020 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.22.1

Nov 19, 2020 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.22.0

Nov 11, 2020 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.21.0

Oct 27, 2020 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.20.0

Sep 29, 2020 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

v0.19.0

Aug 25, 2020 GO-2024-3036

GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Changes in this version

+ const ErrBatchItemSizeExceedsLimit

+ const ErrConflictingFields

+ const ErrFailedToEnqueueMessages

+ const ErrJobHasAlreadyBeenStopped

+ const ErrJobIsNotInProgress

+ const ErrJobNotFound

+ const ErrMessageExceedsMaxSize

+ const ErrNoDataFoundInJobSubmission

+ const ErrNoS3FilesFound

+ const ErrSpecifyExactlyOneKey

+ const ManageJobResourcesCronPeriod

+ func DeleteAPI(apiName string, keepCache bool) error

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

+ func ErrorConflictingFields(key string, keys ...string) error

+ func ErrorFailedToEnqueueMessages(message string) error

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

+ func ErrorJobHasAlreadyBeenStopped() error

+ func ErrorJobIsNotInProgress() error

+ func ErrorJobNotFound(jobKey spec.JobKey) error

+ func ErrorMessageExceedsMaxSize(messageSize int, messageLimit int) error

+ func ErrorNoDataFoundInJobSubmission() error

+ func ErrorNoS3FilesFound() error

+ func ErrorSpecifyExactlyOneKey(key string, keys ...string) error

+ func GetAPIByName(deployedResource *operator.DeployedResource) (*schema.GetAPIResponse, error)

+ func GetAllAPIs(virtualServices []istioclientnetworking.VirtualService, k8sJobs []kbatch.Job, ...) ([]schema.BatchAPI, error)

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

+ func ManageJobResources() error

+ func ReadLogs(jobKey spec.JobKey, socket *websocket.Conn)

+ func StopJob(jobKey spec.JobKey) error

+ func SubmitJob(apiName string, submission *schema.JobSubmission) (*spec.Job, error)

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

+ type JobState struct

+ EndTime *time.Time

+ LastUpdatedMap map[string]time.Time

+ Status status.JobCode

+ func (j JobState) GetLastUpdated() time.Time

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