Documentation
¶
Index ¶
- type EnvironmentRequiredError
- type StandaloneExecutor
- func (e *StandaloneExecutor) Execute(ctx context.Context, r recipe.Recipe, inputs map[string]interface{}, ...) (map[string]interface{}, error)
- func (e *StandaloneExecutor) ExecuteWithRegistry(ctx context.Context, r recipe.Recipe, inputs map[string]interface{}, ...) (map[string]interface{}, error)
- func (e *StandaloneExecutor) GetActivityRegistry() *ops.ActivityRegistry
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EnvironmentRequiredError ¶ added in v0.0.52
type EnvironmentRequiredError struct{ Handoff compiler.ExecutionHandoff }
EnvironmentRequiredError reports that a disposable standalone runtime cannot migrate itself. Durable production execution should use a persistent runtime.
func (*EnvironmentRequiredError) Error ¶ added in v0.0.52
func (e *EnvironmentRequiredError) Error() string
type StandaloneExecutor ¶
type StandaloneExecutor struct {
// contains filtered or unexported fields
}
func NewStandaloneExecutor ¶
func NewStandaloneExecutor(deps ops2.ServiceDependencies2, registry *ops.ActivityRegistry, logger *zap.Logger, allocations ...execution.Allocation) (*StandaloneExecutor, error)
NewStandaloneExecutor creates a new standalone recipe executor
func (*StandaloneExecutor) Execute ¶
func (e *StandaloneExecutor) Execute( ctx context.Context, r recipe.Recipe, inputs map[string]interface{}, jobCtx contextual.JobContext, gitRef string, ) (map[string]interface{}, error)
Execute runs a recipe with the given inputs
func (*StandaloneExecutor) ExecuteWithRegistry ¶
func (e *StandaloneExecutor) ExecuteWithRegistry( ctx context.Context, r recipe.Recipe, inputs map[string]interface{}, jobCtx contextual.JobContext, gitRef string, registry workflow.RecipeProjectProvider, ) (map[string]interface{}, error)
ExecuteWithRegistry runs a recipe with a custom registry for resolving recipe references.
func (*StandaloneExecutor) GetActivityRegistry ¶
func (e *StandaloneExecutor) GetActivityRegistry() *ops.ActivityRegistry
GetActivityRegistry returns the activity registry
Source Files
Click to show internal directories.
Click to hide internal directories.