diff --git a/cmd/root.go b/cmd/root.go index 25d79973c..f1f0ecc59 100644 --- a/cmd/root.go +++ b/cmd/root.go @@ -24,7 +24,8 @@ var ( log = util.NewLogger("main") cfgFile string - ignoreMqtt = []string{"releaseNotes"} // excessive size may crash certain brokers + ignoreErrors = []string{"warn", "error", "fatal"} // don't add to cache + ignoreMqtt = []string{"releaseNotes"} // excessive size may crash certain brokers ) // rootCmd represents the base command when called without any subcommands @@ -170,7 +171,7 @@ func run(cmd *cobra.Command, args []string) { // value cache cache := util.NewCache() - go cache.Run(tee.Attach()) + go cache.Run(pipe.NewDropper(ignoreErrors...).Pipe(tee.Attach())) // setup database if conf.Influx.URL != "" {