dapr
/
cli
mirror of https://github.com/dapr/cli.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

preserve daprd log output (#559)

This commit is contained in:
Yaron Schneider 2020-12-15 13:47:58 -08:00 committed by GitHub
parent 3dacfb672d
commit 3ae4ae2acf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
cmd/run.go
View File

@ -102,31 +102,8 @@ var RunCmd = &cobra.Command{
output.DaprHTTPPort, output.DaprHTTPPort,
output.DaprGRPCPort)) output.DaprGRPCPort))
stdErrPipe, pipeErr := output.DaprCMD.StderrPipe() output.DaprCMD.Stdout = os.Stdout
if pipeErr != nil { output.DaprCMD.Stderr = os.Stderr
print.FailureStatusEvent(os.Stdout, fmt.Sprintf("Error creating stderr for Dapr: %s", err.Error()))
os.Exit(1)
}
stdOutPipe, pipeErr := output.DaprCMD.StdoutPipe()
if pipeErr != nil {
print.FailureStatusEvent(os.Stdout, fmt.Sprintf("Error creating stdout for Dapr: %s", err.Error()))
os.Exit(1)
}
errScanner := bufio.NewScanner(stdErrPipe)
outScanner := bufio.NewScanner(stdOutPipe)
go func() {
for errScanner.Scan() {
fmt.Println(print.Yellow(fmt.Sprintf("== DAPR == %s\n", errScanner.Text())))
}
}()
go func() {
for outScanner.Scan() {
fmt.Println(print.Yellow(fmt.Sprintf("== DAPR == %s\n", outScanner.Text())))
}
}()
err = output.DaprCMD.Start() err = output.DaprCMD.Start()
if err != nil { if err != nil {