executor

package

v0.1.3 Latest Latest Go to latest Published: Sep 1, 2026 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func WithAction(ctx context.Context, action Action) context.Context

type Action string

const (
	ActionRun  Action = "run"
	ActionStop Action = "stop"
)

func ActionFromContext(ctx context.Context) Action

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

func NewContainerExecutor(
	workflowRepo interfaces.WorkflowRepository,
	containerMgr *manager.ContainerManager,
) *ContainerExecutor

func (e *ContainerExecutor) Execute(ctx context.Context, node *types.AnalysisNode) (*Result, error)

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

func NewFactory(workflowRepository interfaces.WorkflowRepository,
	containerManager *manager.ContainerManager) *ExecuterFactory

func (f *ExecuterFactory) Resolve(executorName string) Executor

type Executor interface {
	Execute(ctx context.Context, node *types.AnalysisNode) (*Result, error)
}

type FactoryDeps struct {
	WorkflowRepository interfaces.WorkflowRepository
	ContainerManager   *manager.ContainerManager
}

type LocalExecutor struct{}

func NewLocalExecutor() *LocalExecutor

func (e *LocalExecutor) Execute(ctx context.Context, node *types.AnalysisNode) (*Result, error)

type NextflowExecutor struct {
}

func NewNextflowExecutor() *NextflowExecutor

func (e *NextflowExecutor) Execute(ctx context.Context, node *types.AnalysisNode) (*Result, error)

type Result struct {
	Status          string
	ResolvedOutputs map[string]any
	ExitCode        int
	ErrorMessage    string
	Deferred        bool
}