Versions in this module Expand all Collapse all v0 v0.1.1 Jun 1, 2026 v0.1.0 Jun 1, 2026 Changes in this version + func Dispatch(ctx context.Context, deps Deps, req Request) (*runs.Run, error) + func Execute(ctx context.Context, deps Deps, run *runs.Run, req Request, entrypoint string) *runs.Run + func HashTestDir(dir string) (string, error) + func Prepare(_ context.Context, deps Deps, req Request) (run *runs.Run, ready bool, hash string, entrypoint string, err error) + func RemoteExecCommand(entrypoint, remoteRunDir, osName string) string + func ResolveEntrypoint(testDir, osName string) (string, error) + type Deps struct + KnownHostsPath string + Logger *slog.Logger + SSH SSHDispatcher + SSHKey string + SSHPort int + SSHUser string + StateDir string + Store *runs.Store + type DispatchError struct + Code output.ErrorCode + Err error + Message string + func (e *DispatchError) Error() string + func (e *DispatchError) Unwrap() error + type EntrypointError struct + Code output.ErrorCode + OS string + TestDir string + Want string + func (e *EntrypointError) Error() string + type RealDispatcher struct + func (RealDispatcher) Dial(_ context.Context, host string, port int, user, keyPath, knownHostsPath string) (SSHSession, error) + type Request struct + Host string + Machine machines.Machine + TestDir string + Timeout time.Duration + type SSHDispatcher interface + Dial func(ctx context.Context, host string, port int, ...) (SSHSession, error) + type SSHSession interface + Close func() error + DownloadDir func(ctx context.Context, remoteDir, localDir string, timeout time.Duration) error + Run func(ctx context.Context, cmd string, stdin io.Reader, timeout time.Duration) (stdout, stderr []byte, exitCode int, err error) + UploadDir func(ctx context.Context, localDir, remoteDir string, timeout time.Duration) error
Go to main page