workloads

Documentation

Index

• Constants
• func APIDeploymentCompute(deployment *appsv1b1.Deployment) userconfig.APICompute
• func APIPodCompute(containers []corev1.Container) (*userconfig.Quantity, *userconfig.Quantity, int64)
• 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
• type ParsedWorkflow
• type SavedWorkloadSpec
• type WorkflowItem
• type WorkloadSpec

Constants

const (
	WorkloadTypeAPI = "api"
)

Functions

func APIDeploymentCompute

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

func APIPodCompute

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

func APIsBaseURL

func APIsBaseURL() (string, error)

func Create

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

func CurrentContext

func CurrentContext(appName string) *context.Context

func CurrentContexts

func CurrentContexts() []*context.Context

func DeleteApp

func DeleteApp(appName string, keepCache bool) bool

func GetAPIGroupStatuses

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

func GetCurrentAPIStatuses

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

func GetCurrentDataStatuses

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

func GetLatestWorkloadID

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

func GetWorkflow

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

func ReadLogs

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

func Run

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

func Stop

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

func UpdateAPISavedStatuses

func UpdateAPISavedStatuses(allPods []corev1.Pod) error

func UpdateDataWorkflowErrors

func UpdateDataWorkflowErrors(failedPods []corev1.Pod) error

func UploadLogPrefixesFromAPIPods

func UploadLogPrefixesFromAPIPods(pods []corev1.Pod) error

Types

type LogPrefixInfo

type LogPrefixInfo struct {
	LogPrefix  string
	WorkloadID string
	AppName    string
}

type ParsedWorkflow

type ParsedWorkflow struct {
	Workloads map[string]*WorkflowItem // workloadID -> *WorkflowItem
	Wf        *awfv1.Workflow
}

type SavedWorkloadSpec

type SavedWorkloadSpec struct {
	AppName      string
	WorkloadID   string
	WorkloadType string
	Resources    map[string]*context.ResourceFields
}

type WorkflowItem

type WorkflowItem struct {
	WorkloadID         string
	WorkloadType       string
	StartedAt          *time.Time
	FinishedAt         *time.Time
	ArgoPhase          *awfv1.NodePhase
	DirectDependencies strset.Set
	AllDependencies    strset.Set
}

type WorkloadSpec

type WorkloadSpec struct {
	WorkloadID       string
	ResourceIDs      strset.Set
	Spec             metav1.Object
	K8sAction        string
	SuccessCondition string
	FailureCondition string
	WorkloadType     string
}