github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

acknowledge --show-all=false with --watch

Browse Source
This commit is contained in:
juanvallejo
2017-09-06 18:07:24 -04:00
parent 50c633182e
commit dda7e2758f
1 changed files with 15 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
pkg/kubectl/cmd/get.go
View File

@@ -278,8 +278,12 @@ func RunGet(f cmdutil.Factory, out, errOut io.Writer, cmd *cobra.Command, args [
objsToPrint = append(objsToPrint, obj) objsToPrint = append(objsToPrint, obj)
} }
for _, objToPrint := range objsToPrint { for _, objToPrint := range objsToPrint {
if err := printer.PrintObj(objToPrint, writer); err != nil { if isFiltered, err := filterFuncs.Filter(objToPrint, filterOpts); !isFiltered {
return fmt.Errorf("unable to output the provided object: %v", err) if err != nil {
glog.V(2).Infof("Unable to filter resource: %v", err)
} else if err := printer.PrintObj(objToPrint, writer); err != nil {
return fmt.Errorf("unable to output the provided object: %v", err)
}
} }
} }
writer.Flush() writer.Flush()
@@ -300,7 +304,15 @@ func RunGet(f cmdutil.Factory, out, errOut io.Writer, cmd *cobra.Command, args [
first = false first = false
return false, nil return false, nil
} }
return false, printer.PrintObj(e.Object, out)
if isFiltered, err := filterFuncs.Filter(e.Object, filterOpts); !isFiltered {
if err != nil {
glog.V(2).Infof("Unable to filter resource: %v", err)
} else if err := printer.PrintObj(e.Object, out); err != nil {
return false, err
}
}
return false, nil
}) })
return err return err
}) })