executor

type ExecutionContext struct {
	// WithConfig is the yaml config passed to the executor
	WithConfig []byte
	Inputs     map[string]any
	Stdout     io.Writer
	Stderr     io.Writer
	ExecID     string
}

type Executor interface {
	Execute(ctx context.Context, execCtx ExecutionContext) (outputs map[string]string, err error)
}

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

type NewExecutorFunc func(name string, driver NodeDriver) (Executor, error)

type Node struct {
	Hostname       string
	Port           int
	Username       string
	Auth           NodeAuth
	ConnectionType string
	OSFamily       string
}

type NodeAuth struct {
	Method string
	Key    string
}

type NodeDriver interface {
	Upload(ctx context.Context, localPath, remotePath string) error
	Download(ctx context.Context, remotePath, localPath string) error
	CreateDir(ctx context.Context, path string) error
	CreateFile(ctx context.Context, path string) error
	GetWorkingDirectory() string
	Remove(ctx context.Context, path string) error
	SetPermissions(ctx context.Context, path string, perms os.FileMode) error
	Exec(ctx context.Context, command string, workingDir string, env []string, stdout, stderr io.Writer) error
	Dial(network, address string) (net.Conn, error)
	IsRemote() bool
	TempDir() string
	Join(parts ...string) string
	// ListFiles should only return top level files and no directories
	ListFiles(ctx context.Context, dirPath string) ([]string, error)
	Close() error
}

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