workflow_handler

Documentation

Index

• Constants
• func AddFilesToTemplates(templates []v1alpha1.Template, files []*git_provider.CommitFile) ([]v1alpha1.Template, error)
• func ConvertToValidString(input string) string
• func CreateDAGTemplate(fileList []*git_provider.CommitFile, name string) (*v1alpha1.Template, error)
• func GetParameters(paramsFile *git_provider.CommitFile) ([]v1alpha1.Parameter, error)
• func IsConfigExists(cfg *conf.WorkflowsConfig, config string) bool
• func IsConfigsOnExitExists(cfg *conf.WorkflowsConfig, config string) bool
• func ValidateDAGTasks(tasks []v1alpha1.DAGTask) error
• type WorkflowsClient
  • func NewWorkflowsClient(cfg *conf.GlobalConfig) (WorkflowsClient, error)
• type WorkflowsClientImpl
  • func (wfc *WorkflowsClientImpl) ConstructSpec(templates []v1alpha1.Template, params []v1alpha1.Parameter, configName string) (*v1alpha1.WorkflowSpec, error)
  • func (wfc *WorkflowsClientImpl) ConstructTemplates(workflowsBatch *common.WorkflowsBatch, configName string) ([]v1alpha1.Template, error)
  • func (wfc *WorkflowsClientImpl) CreateWorkflow(spec *v1alpha1.WorkflowSpec, workflowsBatch *common.WorkflowsBatch) (*v1alpha1.Workflow, error)
  • func (wfc *WorkflowsClientImpl) HandleWorkflowBatch(ctx *context.Context, workflowsBatch *common.WorkflowsBatch) error
  • func (wfc *WorkflowsClientImpl) Lint(wf *v1alpha1.Workflow) error
  • func (wfc *WorkflowsClientImpl) SelectConfig(workflowsBatch *common.WorkflowsBatch) (string, error)
  • func (wfc *WorkflowsClientImpl) Submit(ctx *context.Context, wf *v1alpha1.Workflow) error
  • func (wfc *WorkflowsClientImpl) UpdatePiperWorkflowLabel(ctx *context.Context, workflowName string, label string, value string) error
  • func (wfc *WorkflowsClientImpl) Watch(ctx *context.Context, labelSelector *metav1.LabelSelector) (watch.Interface, error)

Constants

const (
	ENTRYPOINT = "entryPoint"
	ONEXIT     = "exitHandler"
)

Functions

func AddFilesToTemplates

func AddFilesToTemplates(templates []v1alpha1.Template, files []*git_provider.CommitFile) ([]v1alpha1.Template, error)

func ConvertToValidString

func ConvertToValidString(input string) string

func CreateDAGTemplate

func CreateDAGTemplate(fileList []*git_provider.CommitFile, name string) (*v1alpha1.Template, error)

func GetParameters

func GetParameters(paramsFile *git_provider.CommitFile) ([]v1alpha1.Parameter, error)

func IsConfigExists

func IsConfigExists(cfg *conf.WorkflowsConfig, config string) bool

func IsConfigsOnExitExists

func IsConfigsOnExitExists(cfg *conf.WorkflowsConfig, config string) bool

func ValidateDAGTasks

func ValidateDAGTasks(tasks []v1alpha1.DAGTask) error

Types

type WorkflowsClient

type WorkflowsClient interface {
	ConstructTemplates(workflowsBatch *common.WorkflowsBatch, configName string) ([]v1alpha1.Template, error)
	ConstructSpec(templates []v1alpha1.Template, params []v1alpha1.Parameter, configName string) (*v1alpha1.WorkflowSpec, error)
	CreateWorkflow(spec *v1alpha1.WorkflowSpec, workflowsBatch *common.WorkflowsBatch) (*v1alpha1.Workflow, error)
	SelectConfig(workflowsBatch *common.WorkflowsBatch) (string, error)
	Lint(wf *v1alpha1.Workflow) error
	Submit(ctx *context.Context, wf *v1alpha1.Workflow) error
	HandleWorkflowBatch(ctx *context.Context, workflowsBatch *common.WorkflowsBatch) error
	Watch(ctx *context.Context, labelSelector *metav1.LabelSelector) (watch.Interface, error)
	UpdatePiperWorkflowLabel(ctx *context.Context, workflowName string, label string, value string) error
}

func NewWorkflowsClient

func NewWorkflowsClient(cfg *conf.GlobalConfig) (WorkflowsClient, error)

type WorkflowsClientImpl

type WorkflowsClientImpl struct {
	// contains filtered or unexported fields
}

func (*WorkflowsClientImpl) ConstructSpec

func (wfc *WorkflowsClientImpl) ConstructSpec(templates []v1alpha1.Template, params []v1alpha1.Parameter, configName string) (*v1alpha1.WorkflowSpec, error)

func (*WorkflowsClientImpl) ConstructTemplates

func (wfc *WorkflowsClientImpl) ConstructTemplates(workflowsBatch *common.WorkflowsBatch, configName string) ([]v1alpha1.Template, error)

func (*WorkflowsClientImpl) CreateWorkflow

func (wfc *WorkflowsClientImpl) CreateWorkflow(spec *v1alpha1.WorkflowSpec, workflowsBatch *common.WorkflowsBatch) (*v1alpha1.Workflow, error)

func (*WorkflowsClientImpl) HandleWorkflowBatch

func (wfc *WorkflowsClientImpl) HandleWorkflowBatch(ctx *context.Context, workflowsBatch *common.WorkflowsBatch) error

func (*WorkflowsClientImpl) Lint

func (wfc *WorkflowsClientImpl) Lint(wf *v1alpha1.Workflow) error

func (*WorkflowsClientImpl) SelectConfig

func (wfc *WorkflowsClientImpl) SelectConfig(workflowsBatch *common.WorkflowsBatch) (string, error)

func (*WorkflowsClientImpl) Submit

func (wfc *WorkflowsClientImpl) Submit(ctx *context.Context, wf *v1alpha1.Workflow) error

func (*WorkflowsClientImpl) UpdatePiperWorkflowLabel

func (wfc *WorkflowsClientImpl) UpdatePiperWorkflowLabel(ctx *context.Context, workflowName string, label string, value string) error

func (*WorkflowsClientImpl) Watch

func (wfc *WorkflowsClientImpl) Watch(ctx *context.Context, labelSelector *metav1.LabelSelector) (watch.Interface, error)