workloads

Nov 28, 2019

Changes in this version

+ func GetMemoryCapacityFromConfigMap() (*kresource.Quantity, error)

+ func GetMemoryCapacityFromNodes() (*kresource.Quantity, error)

+ func UpdateMemoryCapacityConfigMap() (*kresource.Quantity, error)

Nov 5, 2019

Changes in this version

+ func CheckAPIEndpointCollisions(ctx *context.Context) error

+ func ErrorDuplicateEndpointOtherDeployment(appName string, apiName string) error

type ErrorKind

+ const ErrDuplicateEndpointOtherDeployment

Sep 24, 2019

Changes in this version

+ func ErrorAPIInitializing() error

+ func ErrorNoAvailableNodeComputeLimit(resource string, reqStr string, maxStr string) error

+ func GetMetrics(appName, apiName string) (schema.APIMetrics, error)

+ func StreamFromCloudWatch(podCheckCancel chan struct{}, appName string, podLabels map[string]string, ...)

type ErrorKind

+ const ErrAPIInitializing

+ const ErrNoAvailableNodeComputeLimit

+ type FluentdLog struct

+ Log string

Jul 30, 2019

Changes in this version

+ func BaseWorkloadPtrsEqual(bw1 *BaseWorkload, bw2 *BaseWorkload) bool

+ func GetCurrentAPIAndGroupStatuses(dataStatuses map[string]*resource.DataStatus, ctx *context.Context) (map[string]*resource.APIStatus, map[string]*resource.APIGroupStatus, error)

+ func GetDeploymentStatus(appName string) (resource.DeploymentStatus, error)

+ func IsWorkloadEnded(appName string, workloadID string) (bool, error)

+ func PopulateWorkloadIDs(ctx *context.Context) error

+ func UpdateWorkflows() error

+ func ValidateDeploy(ctx *context.Context) error

+ type APIWorkload struct

+ func (aw *APIWorkload) CanRun(ctx *context.Context) (bool, error)

+ func (aw *APIWorkload) IsFailed(ctx *context.Context) (bool, error)

+ func (aw *APIWorkload) IsRunning(ctx *context.Context) (bool, error)

+ func (aw *APIWorkload) IsStarted(ctx *context.Context) (bool, error)

+ func (aw *APIWorkload) IsSucceeded(ctx *context.Context) (bool, error)

+ func (aw *APIWorkload) Start(ctx *context.Context) error

+ type BaseWorkload struct

+ AppName string

+ Resources map[string]context.ResourceFields

+ WorkloadID string

+ WorkloadType string

+ func (bw *BaseWorkload) AddResource(res context.ComputedResource)

+ func (bw *BaseWorkload) Copy() *BaseWorkload

+ func (bw *BaseWorkload) CreatesResource(resourceID string) bool

+ func (bw *BaseWorkload) Equal(bw2 BaseWorkload) bool

+ func (bw *BaseWorkload) GetAppName() string

+ func (bw *BaseWorkload) GetBaseWorkloadPtr() *BaseWorkload

+ func (bw *BaseWorkload) GetResourceIDs() strset.Set

+ func (bw *BaseWorkload) GetResources() map[string]context.ResourceFields

+ func (bw *BaseWorkload) GetSingleResourceID() string

+ func (bw *BaseWorkload) GetWorkloadID() string

+ func (bw *BaseWorkload) GetWorkloadType() string

+ type BaseWorkloadInterface interface

+ AddResource func(res context.ComputedResource)

+ CreatesResource func(resourceID string) bool

+ GetAppName func() string

+ GetBaseWorkloadPtr func() *BaseWorkload

+ GetResourceIDs func() strset.Set

+ GetResources func() map[string]context.ResourceFields

+ GetSingleResourceID func() string

+ GetWorkloadID func() string

+ GetWorkloadType func() string

+ type HPAWorkload struct

+ APIID string

+ func (hw *HPAWorkload) CanRun(ctx *context.Context) (bool, error)

+ func (hw *HPAWorkload) IsFailed(ctx *context.Context) (bool, error)

+ func (hw *HPAWorkload) IsRunning(ctx *context.Context) (bool, error)

+ func (hw *HPAWorkload) IsStarted(ctx *context.Context) (bool, error)

+ func (hw *HPAWorkload) IsSucceeded(ctx *context.Context) (bool, error)

+ func (hw *HPAWorkload) Start(ctx *context.Context) error

+ type PythonPackagesWorkload struct

+ func (pyw *PythonPackagesWorkload) CanRun(ctx *context.Context) (bool, error)

+ func (pyw *PythonPackagesWorkload) IsFailed(ctx *context.Context) (bool, error)

+ func (pyw *PythonPackagesWorkload) IsRunning(ctx *context.Context) (bool, error)

+ func (pyw *PythonPackagesWorkload) IsStarted(ctx *context.Context) (bool, error)

+ func (pyw *PythonPackagesWorkload) IsSucceeded(ctx *context.Context) (bool, error)

+ func (pyw *PythonPackagesWorkload) Start(ctx *context.Context) error

+ type SparkWorkload struct

+ func (sw *SparkWorkload) CanRun(ctx *context.Context) (bool, error)

+ func (sw *SparkWorkload) IsFailed(ctx *context.Context) (bool, error)

+ func (sw *SparkWorkload) IsRunning(ctx *context.Context) (bool, error)

+ func (sw *SparkWorkload) IsStarted(ctx *context.Context) (bool, error)

+ func (sw *SparkWorkload) IsSucceeded(ctx *context.Context) (bool, error)

+ func (sw *SparkWorkload) Start(ctx *context.Context) error

+ type TrainingWorkload struct

+ func (tw *TrainingWorkload) CanRun(ctx *context.Context) (bool, error)

+ func (tw *TrainingWorkload) IsFailed(ctx *context.Context) (bool, error)

+ func (tw *TrainingWorkload) IsRunning(ctx *context.Context) (bool, error)

+ func (tw *TrainingWorkload) IsStarted(ctx *context.Context) (bool, error)

+ func (tw *TrainingWorkload) IsSucceeded(ctx *context.Context) (bool, error)

+ func (tw *TrainingWorkload) Start(ctx *context.Context) error

+ type Workload interface

+ CanRun func(*context.Context) (bool, error)

+ IsFailed func(*context.Context) (bool, error)

+ IsRunning func(*context.Context) (bool, error)

+ IsStarted func(*context.Context) (bool, error)

+ IsSucceeded func(*context.Context) (bool, error)

+ Start func(*context.Context) error

Jul 8, 2019

Changes in this version

+ func APIDeploymentMap(appName string) (map[string]*appsv1b1.Deployment, error)

+ func APIPodComputeID(containers []corev1.Container) string

type WorkloadSpec

+ K8sSpecs []metav1.Object

Jun 14, 2019

Changes in this version

+ func ErrorContextAppMismatch() error

+ func ErrorCortexInstallationBroken() error

+ func ErrorExternalDataUnavailable(s3Path string) error

+ func ErrorLoadBalancerInitializing() error

+ func ErrorMoreThanOneWorkflow() error

+ func ErrorNotFound() error

+ func ErrorWorkflowAppMismatch() error

+ func Init() error

+ type Error struct

+ Kind ErrorKind

+ func (e Error) Error() string

+ type ErrorKind int

+ const ErrContextAppMismatch

+ const ErrCortexInstallationBroken

+ const ErrExternalDataUnavailable

+ const ErrLoadBalancerInitializing

+ const ErrMoreThanOneWorkflow

+ const ErrNotFound

+ const ErrUnknown

+ const ErrWorkflowAppMismatch

+ func (t *ErrorKind) UnmarshalBinary(data []byte) error

+ func (t *ErrorKind) UnmarshalText(text []byte) error

+ func (t ErrorKind) MarshalBinary() ([]byte, error)

+ func (t ErrorKind) MarshalText() ([]byte, error)

+ func (t ErrorKind) String() string

Feb 14, 2019

Changes in this version

+ const WorkloadTypeAPI

+ func APIDeploymentCompute(deployment *appsv1b1.Deployment) userconfig.APICompute

+ func APIPodCompute(containers []corev1.Container) (*userconfig.Quantity, *userconfig.Quantity)

+ func APIsBaseURL() (string, error)

+ func Create(ctx *context.Context) (*awfv1.Workflow, error)

+ func CurrentContext(appName string) *context.Context

+ func CurrentContexts() []*context.Context

+ func DeleteApp(appName string, keepCache bool) bool

+ func GetAPIGroupStatuses(apiStatuses map[string]*resource.APIStatus, ctx *context.Context) (map[string]*resource.APIGroupStatus, error)

+ func GetCurrentAPIStatuses(ctx *context.Context, dataStatuses map[string]*resource.DataStatus) (map[string]*resource.APIStatus, error)

+ func GetCurrentDataStatuses(ctx *context.Context) (map[string]*resource.DataStatus, error)

+ func GetLatestWorkloadID(resourceID string, appName string) (string, error)

+ func GetWorkflow(appName string) (*awfv1.Workflow, error)

+ func ReadLogs(appName string, workloadID string, verbose bool, socket *websocket.Conn)

+ func Run(wf *awfv1.Workflow, ctx *context.Context, existingWf *awfv1.Workflow) error

+ func Stop(wf *awfv1.Workflow, ctx *context.Context) error

+ func UpdateAPISavedStatuses(allPods []corev1.Pod) error

+ func UpdateDataWorkflowErrors(failedPods []corev1.Pod) error

+ func UploadLogPrefixesFromAPIPods(pods []corev1.Pod) error

+ type LogPrefixInfo struct

+ AppName string

+ LogPrefix string

+ WorkloadID string

+ type ParsedWorkflow struct

+ Wf *awfv1.Workflow

+ Workloads map[string]*WorkflowItem

+ type SavedWorkloadSpec struct

+ AppName string

+ Resources map[string]*context.ResourceFields

+ WorkloadID string

+ WorkloadType string

+ type WorkflowItem struct

+ AllDependencies strset.Set

+ ArgoPhase *awfv1.NodePhase

+ DirectDependencies strset.Set

+ FinishedAt *time.Time

+ StartedAt *time.Time

+ WorkloadID string

+ WorkloadType string

+ type WorkloadSpec struct

+ FailureCondition string

+ K8sAction string

+ ResourceIDs strset.Set

+ Spec metav1.Object

+ SuccessCondition string

+ WorkloadID string

+ WorkloadType string