executor

type Executor interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	Type() common.ExecutorType
	// Execute dispatches a task to the appropriate handler based on
	// req.Info.OperationType. The operation payload must be pre-serialized
	// into req.Info.OperationInfo before calling.
	Execute(ctx context.Context, req *task.ExecutionRequest) (*task.ExecutionResponse, error)
	CheckStatus(ctx context.Context, executionID string) (common.TaskStatus, error)
	TerminateTask(ctx context.Context, executionID string, reason string) error
}

type ExecutorConfig interface {
	Validate() error
	// Build constructs the Executor. updater receives task status transitions
	// from the execution engine back to the store. It must not be nil.
	Build(ctx context.Context, updater task.TaskStatusUpdater) (Executor, error)
}