workflow_handler

package

v1.0.0 Latest Latest Go to latest Published: Jun 19, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/rookout/piper

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AddFilesToTemplates(templates []v1alpha1.Template, files []*git.CommitFile) ([]v1alpha1.Template, error)
func CreateDAGTemplate(fileList []*git.CommitFile, name string) (*v1alpha1.Template, error)
func GetParameters(paramsFile *git.CommitFile) ([]v1alpha1.Parameter, error)
type WorkflowsClient
- func NewWorkflowsClient(cfg *conf.Config) (WorkflowsClient, error)
type WorkflowsClientImpl

Constants ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

func AddFilesToTemplates ¶

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

func CreateDAGTemplate ¶

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

func GetParameters ¶

func GetParameters(paramsFile *git.CommitFile) ([]v1alpha1.Parameter, 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)
	SetConfig(wf *v1alpha1.Workflow, spec *v1alpha1.WorkflowSpec) error
	Lint(wf *v1alpha1.Workflow) error
	Submit(ctx *context.Context, wf *v1alpha1.Workflow) error
	HandleWorkflowBatch(ctx *context.Context, workflowsBatch *common.WorkflowsBatch) error
}

func NewWorkflowsClient ¶

func NewWorkflowsClient(cfg *conf.Config) (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) SetConfig ¶

func (wfc *WorkflowsClientImpl) SetConfig(wf *v1alpha1.Workflow, spec *v1alpha1.WorkflowSpec) error

func (*WorkflowsClientImpl) Submit ¶

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

Source Files ¶

View all Source files

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