Update log consumption

pull/2342/head
John Welsh 9 years ago
parent 5c5872de4e
commit 1c980873bb

@ -65,6 +65,10 @@ func newLogsCmd(client helm.Interface, out io.Writer) *cobra.Command {
func (l *logsCmd) run() error { func (l *logsCmd) run() error {
done := make(chan struct{}) done := make(chan struct{})
stream, err := l.client.ReleaseLogs(l.release, release.LogLevel_DEBUG, done, release.LogSource_SYSTEM, release.LogSource_POD) stream, err := l.client.ReleaseLogs(l.release, release.LogLevel_DEBUG, done, release.LogSource_SYSTEM, release.LogSource_POD)
if err != nil {
done <- struct{}{}
return prettyError(err)
}
fmt.Println("Listening for logs") fmt.Println("Listening for logs")
for { for {
@ -73,15 +77,10 @@ func (l *logsCmd) run() error {
if !ok { if !ok {
return nil return nil
} }
fmt.Println(l) fmt.Println(l.Log.Log)
} }
} }
if err != nil {
done <- struct{}{}
return prettyError(err)
}
return nil return nil
} }

Loading…
Cancel
Save