executor

type ContainerCounter interface {
	CountRunning(ctx context.Context) (int, error)
}

type ContainerLaunchOpts = launchpolicy.ContainerLaunchOpts

type ExecutionChecker interface {
	IsRunning(ctx context.Context, executionID string) (bool, error)
	// WaitUntilRunning blocks until the named execution is in the running state,
	// the timeout elapses, or ctx is cancelled.
	WaitUntilRunning(ctx context.Context, executionID string, timeout time.Duration) error
}

type ExecutionStopper interface {
	StopContainer(ctx context.Context, executionID string) error
}

type Executor interface {
	Execute(ctx context.Context, promptContent string, logFile string, executionID string) error
	// Reattach connects to a running execution's output stream and waits for it to exit.
	// It does not create a new container. The log file is overwritten from the beginning
	// of the container's output (docker logs replays all output from container start).
	// maxPromptDuration is the remaining allowed run time; 0 disables the timeout.
	// Returns nil when the execution exits successfully.
	Reattach(
		ctx context.Context,
		logFile string,
		executionID string,
		maxPromptDuration time.Duration,
	) error
	// StopAndRemoveContainer stops and forcibly removes the named execution.
	// Best-effort: any errors are logged but not returned.
	StopAndRemoveContainer(ctx context.Context, executionID string)
}