executor

type LocalTaskRunner ¶

type LocalTaskRunner struct{}

LocalTaskRunner implements the TaskRunner interface for local execution. It directly calls the task's ExecuteModule method.

func (r *LocalTaskRunner) ExecuteTask(ctx context.Context, task pkg.Task, closure *pkg.Closure, cfg *config.Config) pkg.TaskResult

func (r *LocalTaskRunner) RevertTask(ctx context.Context, task pkg.Task, closure *pkg.Closure, cfg *config.Config) pkg.TaskResult

type RunSpageTemporalWorkerAndWorkflowOptions ¶

type RunSpageTemporalWorkerAndWorkflowOptions struct {
	Graph            *pkg.Graph
	InventoryPath    string
	LoadedConfig     *config.Config // Changed from ConfigPath to break import cycle with cmd
	WorkflowIDPrefix string
}

RunSpageTemporalWorkerAndWorkflowOptions defines options for RunSpageTemporalWorkerAndWorkflow.

type SpageActivityInput ¶

type SpageActivityInput struct {
	TaskDefinition   pkg.Task
	TargetHost       pkg.Host
	LoopItem         interface{} // nil if not a loop task or for the main item
	CurrentHostFacts map[string]interface{}
	SpageCoreConfig  *config.Config // Pass necessary config parts
}

SpageActivityInput defines the input for our generic Spage task activity.

type SpageActivityResult ¶

type SpageActivityResult struct {
	HostName          string
	TaskName          string
	Output            string
	Changed           bool
	Error             string // Store error message if any
	Skipped           bool
	Ignored           bool
	RegisteredVars    map[string]interface{}
	HostFactsSnapshot map[string]interface{}
}

SpageActivityResult defines the output from our generic Spage task activity.

func ExecuteSpageTaskActivity(ctx context.Context, input SpageActivityInput) (*SpageActivityResult, error)

func RevertSpageTaskActivity(ctx context.Context, input SpageActivityInput) (*SpageActivityResult, error)

type TemporalGraphExecutor ¶

type TemporalGraphExecutor struct {
	Runner TemporalTaskRunner
}

func NewTemporalGraphExecutor(runner TemporalTaskRunner) *TemporalGraphExecutor

func (e *TemporalGraphExecutor) Execute(
	inventoryHosts map[string]*pkg.Host,
	workflowHostFacts map[string]map[string]interface{},
	orderedGraph [][]pkg.Task,
	cfg *config.Config,
) error

type TemporalTaskRunner ¶

type TemporalTaskRunner struct {
	WorkflowCtx workflow.Context // The Temporal workflow context
}

TemporalTaskRunner implements the TaskRunner interface for Temporal activity execution. It requires access to the workflow.Context to execute activities. Note: This runner is conceptual for showing how Temporal fits the TaskRunner pattern. The SpageTemporalWorkflow will still manage its own execution loop due to differences in fact/state management compared to LocalGraphExecutor's assumptions.

func NewTemporalTaskRunner(workflowCtx workflow.Context) *TemporalTaskRunner

func (r *TemporalTaskRunner) ExecuteTask(execCtx workflow.Context, task pkg.Task, closure *pkg.Closure, cfg *config.Config) pkg.TaskResult

func (r *TemporalTaskRunner) RevertTask(execCtx workflow.Context, task pkg.Task, closure *pkg.Closure, cfg *config.Config) pkg.TaskResult