workflow

package
v0.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 5, 2021 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EntrypointTemplateName = "entry"

	HelmReleaseArg                 = "helmrelease"
	TimeoutArg                     = "timeout"
	HelmReleaseExecutorName        = "helmrelease-executor"
	HelmReleaseReverseExecutorName = "helmrelease-reverse-executor"

	ValuesKeyGlobal = "global"
	ChartLabelKey   = "chart"

	DefaultTimeout = "5m"

	ExecutorName     = "executor"
	ExecutorImage    = "azureorkestra/executor"
	ExecutorImageTag = "v0.3.0"

	ChartMuseumName = "chartmuseum"
)
View Source 
const (
	Project        = "orkestra"
	OwnershipLabel = "owner"
	HeritageLabel  = "heritage"
)

Variables

This section is empty.

Functions

func Argo 

func Argo(scheme *runtime.Scheme, c client.Client, stagingRepoURL string, workflowParallelism int64) *argo

Argo implements the Workflow interface for the Argo Workflow based DAG engine

Types

type Engine 

type Engine interface {
	// Generate the object required by the workflow engine
	Generate(ctx context.Context, l logr.Logger, g *v1alpha1.ApplicationGroup) error
	// Submit the object required by the workflow engine generated by the Generate method
	Submit(ctx context.Context, l logr.Logger, g *v1alpha1.ApplicationGroup) error
	// Generate the reverse object required by the workflow engine
	GenerateReverse(ctx context.Context, l logr.Logger, nodes map[string]v1alpha12.NodeStatus, wf *v1alpha12.Workflow) error
	// Submit the reverse object required by the workflow engine generated by the GenerateReverse method
	SubmitReverse(ctx context.Context, l logr.Logger, wf *v1alpha12.Workflow) error
}

type ExecutorAction added in v0.6.0 

type ExecutorAction string

ExecutorAction defines the set of executor actions which can be performed on a helmrelease object 

const (
	// The set of executor actions which can be performed on a helmrelease object
	Install ExecutorAction = "install"
	Delete  ExecutorAction = "delete"
)

type Graph added in v0.3.0 

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

func Build added in v0.3.0 

func Build(entry string, nodes map[string]v1alpha12.NodeStatus) (*Graph, error)

func (*Graph) Reverse added in v0.3.0 

func (g *Graph) Reverse() [][]fluxhelmv2beta1.HelmRelease

type Node added in v0.3.0 

type Node struct {
	Status v1alpha12.NodeStatus
	Level  int
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.