Skip to content

Commit

Permalink
Fix review
Browse files Browse the repository at this point in the history
  • Loading branch information
Tetrergeru committed Apr 24, 2024
1 parent 7b707ab commit 27dec5e
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 12 deletions.
13 changes: 7 additions & 6 deletions cmd/filter/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -47,12 +47,13 @@ func getDefault() config {
LogPrettyFormat: false,
},
Filter: filterConfig{
Listen: ":2003",
RetentionConfig: "/etc/moira/storage-schemas.conf",
CacheCapacity: 10, //nolint
MaxParallelMatches: 0,
PatternsUpdatePeriod: "1s",
DropMetricsTTL: "1h",
Listen: ":2003",
RetentionConfig: "/etc/moira/storage-schemas.conf",
CacheCapacity: 10, //nolint
MaxParallelMatches: 0,
PatternsUpdatePeriod: "1s",
DropMetricsTTL: "1h",
BatchForcedSaveTimeout: "1s",
Compatibility: compatibility{
AllowRegexLooseStartMatch: false,
AllowRegexMatchEmpty: true,
Expand Down
6 changes: 0 additions & 6 deletions cmd/filter/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,6 @@ import (
"os/signal"
"runtime"
"syscall"
"time"

"github.com/moira-alert/moira"
"github.com/moira-alert/moira/cmd"
Expand Down Expand Up @@ -144,12 +143,7 @@ func main() {

// Start metrics matcher
cacheCapacity := config.Filter.CacheCapacity

batchForcedSaveTimeout := to.Duration(config.Filter.BatchForcedSaveTimeout)
if batchForcedSaveTimeout == 0 {
batchForcedSaveTimeout = time.Second
}

metricsMatcher := matchedmetrics.NewMetricsMatcher(filterMetrics, logger, database, cacheStorage, cacheCapacity, batchForcedSaveTimeout)
metricsMatcher.Start(metricsChan)
defer metricsMatcher.Wait() // First stop listener
Expand Down

0 comments on commit 27dec5e

Please sign in to comment.