mirror of
https://github.com/k3s-io/k3s.git
synced 2024-06-07 19:41:36 +00:00
39 lines
949 B
Go
39 lines
949 B
Go
// Copyright (c) 2017 Gorillalabs. All rights reserved.
|
|
|
|
package backend
|
|
|
|
import (
|
|
"io"
|
|
"os/exec"
|
|
|
|
"github.com/pkg/errors"
|
|
)
|
|
|
|
type Local struct{}
|
|
|
|
func (b *Local) StartProcess(cmd string, args ...string) (Waiter, io.Writer, io.Reader, io.Reader, error) {
|
|
command := exec.Command(cmd, args...)
|
|
|
|
stdin, err := command.StdinPipe()
|
|
if err != nil {
|
|
return nil, nil, nil, nil, errors.Wrap(err, "Could not get hold of the PowerShell's stdin stream")
|
|
}
|
|
|
|
stdout, err := command.StdoutPipe()
|
|
if err != nil {
|
|
return nil, nil, nil, nil, errors.Wrap(err, "Could not get hold of the PowerShell's stdout stream")
|
|
}
|
|
|
|
stderr, err := command.StderrPipe()
|
|
if err != nil {
|
|
return nil, nil, nil, nil, errors.Wrap(err, "Could not get hold of the PowerShell's stderr stream")
|
|
}
|
|
|
|
err = command.Start()
|
|
if err != nil {
|
|
return nil, nil, nil, nil, errors.Wrap(err, "Could not spawn PowerShell process")
|
|
}
|
|
|
|
return command, stdin, stdout, stderr, nil
|
|
}
|