interfaces

package
v0.5.12 Latest Latest
Warning

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

Go to latest
Published: May 31, 2021 License: Apache-2.0 Imports: 7 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Compiler

type Compiler interface {
	CompileTask(task *core.TaskTemplate) (*core.CompiledTask, error)
	GetRequirements(fg *core.WorkflowTemplate, subWfs []*core.WorkflowTemplate) (
		compiler.WorkflowExecutionRequirements, error)
	CompileWorkflow(primaryWf *core.WorkflowTemplate, subworkflows []*core.WorkflowTemplate, tasks []*core.CompiledTask,
		launchPlans []common.InterfaceProvider) (*core.CompiledWorkflowClosure, error)
}

Workflow compiler interface.

type ExecuteTaskInput added in v0.3.38

type ExecuteTaskInput struct {
	ExecutionID         *core.WorkflowExecutionIdentifier
	WfClosure           core.CompiledWorkflowClosure
	Inputs              *core.LiteralMap
	ReferenceName       string
	Auth                *admin.AuthRole
	AcceptedAt          time.Time
	Labels              map[string]string
	Annotations         map[string]string
	QueueingBudget      time.Duration
	TaskPluginOverrides []*admin.PluginOverride
}

type ExecuteWorkflowInput added in v0.1.1

type ExecuteWorkflowInput struct {
	ExecutionID         *core.WorkflowExecutionIdentifier
	WfClosure           core.CompiledWorkflowClosure
	Inputs              *core.LiteralMap
	Reference           admin.LaunchPlan
	AcceptedAt          time.Time
	Labels              map[string]string
	Annotations         map[string]string
	QueueingBudget      time.Duration
	TaskPluginOverrides []*admin.PluginOverride
}

type ExecutionInfo added in v0.1.1

type ExecutionInfo struct {
	Cluster string
}

type Executor

type Executor interface {
	ExecuteWorkflow(
		ctx context.Context, input ExecuteWorkflowInput) (*ExecutionInfo, error)
	ExecuteTask(ctx context.Context, input ExecuteTaskInput) (*ExecutionInfo, error)
	TerminateWorkflowExecution(ctx context.Context, input TerminateWorkflowInput) error
}

type FlyteWorkflowInterface

type FlyteWorkflowInterface interface {
	BuildFlyteWorkflow(
		wfClosure *core.CompiledWorkflowClosure, inputs *core.LiteralMap, executionID *core.WorkflowExecutionIdentifier,
		namespace string) (*v1alpha1.FlyteWorkflow, error)
}

type TerminateWorkflowInput added in v0.1.1

type TerminateWorkflowInput struct {
	ExecutionID *core.WorkflowExecutionIdentifier
	Cluster     string
}

Jump to

Keyboard shortcuts

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