process

type CommandEnvEntry ¶

type CommandEnvEntry struct {
	Name  string
	Value string
}

func CommandEnvEntriesFromMap(envVars map[string]string) []CommandEnvEntry

type CommandRequest ¶

type CommandRequest = interfaces.SubprocessExecutionRequest

CommandRequest describes one worker-owned subprocess invocation.

func SubprocessRequestBase(dispatch interfaces.WorkDispatch) CommandRequest

type CommandResult ¶

type CommandResult struct {
	Stdout   []byte
	Stderr   []byte
	ExitCode int
}

CommandResult captures the observable output and exit status from a command.

type CommandRunner ¶

type CommandRunner interface {
	Run(ctx context.Context, req CommandRequest) (CommandResult, error)
}

CommandRunner executes a low-level subprocess request for worker code.

func CommandRunnerWithLogging(runner CommandRunner, logger logging.Logger) CommandRunner

type ExecCommandRunner ¶

type ExecCommandRunner struct{}

ExecCommandRunner implements CommandRunner by delegating to os/exec.

func (ExecCommandRunner) Run(ctx context.Context, req CommandRequest) (CommandResult, error)

type LoggingCommandRunner ¶

type LoggingCommandRunner struct {
	Runner CommandRunner
	Logger logging.Logger
}

LoggingCommandRunner emits structured work-scoped records around a CommandRunner request while preserving the wrapped runner's behavior.

func (r LoggingCommandRunner) Run(ctx context.Context, req CommandRequest) (CommandResult, error)