executor

package

v0.0.0-...-4a57d31 Latest Latest Go to latest Published: Jun 30, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	Parallel    int
	LogDir      string
	GracePeriod time.Duration
	InheritEnv  []string
}

Config holds executor settings.

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

Executor runs job commands with bounded parallelism.

func New(cfg Config) (*Executor, error)

New creates an executor.

func (e *Executor) LogDir() string

LogDir returns the log directory for this executor session.

func (e *Executor) Results() <-chan Result

Results returns the channel that receives job completion results.

func (e *Executor) Run(id, command string, env map[string]string, cwd string, timeout time.Duration, runCount int) string

Run starts a job instance asynchronously. Returns the log file path immediately.

func (e *Executor) Shutdown()

Shutdown cancels all running jobs and waits for them to finish.

type Result struct {
	ID       string
	ExitCode int
	Err      error
	LogFile  string
}

Result is sent when a job finishes.