workflow

package

v0.0.74 Latest Latest Go to latest Published: Oct 15, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Details

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

Repository

github.com/colony-2/c2j

Links

Open Source Insights

Documentation ¶

Index ¶

func NewApplicationError(message string, details ...interface{}) error
func NewNonRetryableApplicationError(message string, details ...interface{}) error
func ValueCall(ctx jobworkflow.ExecutionContext, site, typ string, policy jobdb.RunPolicy, ...) (jobdb.TaskData, error)
type Context
type NonRetryableError
- func (e NonRetryableError) Error() string
- func (e NonRetryableError) NonRetryable() bool
type RetryableErrror
- func (e RetryableErrror) Error() string
- func (e RetryableErrror) NonRetryable() bool

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewApplicationError ¶

func NewApplicationError(message string, details ...interface{}) error

func NewNonRetryableApplicationError ¶

func NewNonRetryableApplicationError(message string, details ...interface{}) error

func ValueCall ¶ added in v0.0.72

func ValueCall(ctx jobworkflow.ExecutionContext, site, typ string, policy jobdb.RunPolicy, command any) (jobdb.TaskData, error)

ValueCall is for control tasks whose declared request is already their stable command.

Types ¶

type Context ¶

type Context struct {
	RecipeDigest       string
	CatchStateName     string
	ScopeState         func(*template.ResolutionContext)
	JobPackages        []string
	WorkspaceSnapshots bool
	SuspendExecution   func(jobworkflow.ExecutionContext, string, execution.Requirements) error
	StageNodeExecution func(execution.Requirements)
	JobContext         jobworkflow.ExecutionContext
	ops.ServiceDependencies2
}

func (Context) DoTask ¶ added in v0.0.72

func (c Context) DoTask(call jobworkflow.TaskCall, build func(context.Context) (jobdb.TaskData, error)) (jobdb.TaskData, error)

DoTask delegates a logical call without constructing inputs on replay.

func (Context) GetJobId ¶

func (c Context) GetJobId() string

func (Context) GetJobKey ¶ added in v0.0.72

func (c Context) GetJobKey() jobdb.JobKey

func (Context) GetLogger ¶

func (c Context) GetLogger() *slog.Logger

type NonRetryableError ¶

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

func (NonRetryableError) Error ¶

func (e NonRetryableError) Error() string

func (NonRetryableError) NonRetryable ¶

func (e NonRetryableError) NonRetryable() bool

type RetryableErrror ¶

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

func (RetryableErrror) Error ¶

func (e RetryableErrror) Error() string

func (RetryableErrror) NonRetryable ¶

func (e RetryableErrror) NonRetryable() bool

Source Files ¶

View all Source files

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