diff --git a/go.mod b/go.mod index c1ed8b9..5d8a624 100644 --- a/go.mod +++ b/go.mod @@ -38,4 +38,5 @@ require ( google.golang.org/genproto/googleapis/rpc v0.0.0-20231012201019-e917dd12ba7a // indirect google.golang.org/grpc v1.58.2 // indirect google.golang.org/protobuf v1.31.0 // indirect + gopkg.in/yaml.v3 v3.0.1 // indirect ) diff --git a/main.go b/main.go index 565a818..5b3f05d 100644 --- a/main.go +++ b/main.go @@ -103,13 +103,11 @@ func main() { for _, filter := range dataFilters { measurements, err = filter.Filter(measurements) if err != nil { - log.Printf("filter failed: %s", err) + slog.Error("filter failed: %s", err) continue } } - failedConnections = 0 - if hasMQTT { var m map[string]interface{} timeStamp := time.Now().UnixNano() / int64(time.Millisecond)