Revert "Ensure errors and warnings are cached"

This reverts commit cc4ffdbf556d204530ba980dde7ee88bae9c03b9.
This commit is contained in:
andig 2022-01-03 18:25:46 +01:00
parent 2f278b4931
commit 3bac55c494

View file

@ -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 != "" {