types

package

v1.2.6 Latest Latest Go to latest Published: May 10, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Details

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

Repository

github.com/oam-dev/kubevela

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Action
type GeneratorOptions
type Operation
type TaskDiscover
type TaskGenerator
type TaskPostStopHook
type TaskPreStartHook
type TaskRunOptions
type TaskRunner

Constants ¶

View Source

const (
	// ContextKeyMetadata is key that refer to application metadata.
	ContextKeyMetadata = "metadata__"
	// ContextPrefixFailedTimes is the prefix that refer to the failed times of the step in workflow context config map.
	ContextPrefixFailedTimes = "failed_times"
	// ContextPrefixBackoffTimes is the prefix that refer to the backoff times in workflow context config map.
	ContextPrefixBackoffTimes = "backoff_times"
	// ContextKeyLastExecuteTime is the key that refer to the last execute time in workflow context config map.
	ContextKeyLastExecuteTime = "last_execute_time"
	// ContextKeyNextExecuteTime is the key that refer to the next execute time in workflow context config map.
	ContextKeyNextExecuteTime = "next_execute_time"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Action ¶

type Action interface {
	Suspend(message string)
	Terminate(message string)
	Wait(message string)
}

Action is that workflow provider can do.

type GeneratorOptions ¶ added in v1.1.1

type GeneratorOptions struct {
	ID            string
	PrePhase      common.WorkflowStepPhase
	StepConvertor func(step v1beta1.WorkflowStep) (v1beta1.WorkflowStep, error)
}

GeneratorOptions is the options for generate task.

type Operation ¶

type Operation struct {
	Suspend            bool
	Terminated         bool
	Waiting            bool
	FailedAfterRetries bool
}

Operation is workflow operation object.

type TaskDiscover ¶

type TaskDiscover interface {
	GetTaskGenerator(ctx context.Context, name string) (TaskGenerator, error)
}

TaskDiscover is the interface to obtain the TaskGenerator。

type TaskGenerator ¶

type TaskGenerator func(wfStep v1beta1.WorkflowStep, options *GeneratorOptions) (TaskRunner, error)

TaskGenerator will generate taskRunner.

type TaskPostStopHook ¶ added in v1.1.1

type TaskPostStopHook func(ctx wfContext.Context, taskValue *value.Value, step v1beta1.WorkflowStep, phase common.WorkflowStepPhase) error

TaskPostStopHook run after task execution.

type TaskPreStartHook ¶ added in v1.1.1

type TaskPreStartHook func(ctx wfContext.Context, paramValue *value.Value, step v1beta1.WorkflowStep) error

TaskPreStartHook run before task execution.

type TaskRunOptions ¶ added in v1.1.1

type TaskRunOptions struct {
	Data          *value.Value
	PCtx          process.Context
	PreStartHooks []TaskPreStartHook
	PostStopHooks []TaskPostStopHook
	GetTracer     func(id string, step v1beta1.WorkflowStep) monitorCtx.Context
	RunSteps      func(isDag bool, runners ...TaskRunner) (*common.WorkflowStatus, error)
}

TaskRunOptions is the options for task run.

type TaskRunner ¶

type TaskRunner interface {
	Name() string
	Pending(ctx wfContext.Context) bool
	Run(ctx wfContext.Context, options *TaskRunOptions) (common.WorkflowStepStatus, *Operation, error)
}

TaskRunner is a task runner.

Source Files ¶

View all Source files

types.go

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