From fb96525d0b25f9b6d27ceb7bddfc30242becdc9c Mon Sep 17 00:00:00 2001 From: sed-i <82407168+sed-i@users.noreply.github.com> Date: Tue, 15 Mar 2022 16:23:34 -0400 Subject: [PATCH] Add CLI args for snapshot intervals Signed-off-by: sed-i <82407168+sed-i@users.noreply.github.com> --- cmd/alertmanager/main.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/cmd/alertmanager/main.go b/cmd/alertmanager/main.go index a7fe71f53a..e95f2999fd 100644 --- a/cmd/alertmanager/main.go +++ b/cmd/alertmanager/main.go @@ -195,6 +195,9 @@ func run() int { retention = kingpin.Flag("data.retention", "How long to keep data for.").Default("120h").Duration() alertGCInterval = kingpin.Flag("alerts.gc-interval", "Interval between alert GC.").Default("30m").Duration() + silencesInterval = kingpin.Flag("silences.interval", "Interval between writing silences snapshot to disk.").Default("15m").Duration() + nflogsInterval = kingpin.Flag("nflogs.interval", "Interval between writing nflogs snapshot to disk.").Default("15m").Duration() + webConfig = webflag.AddFlags(kingpin.CommandLine) externalURL = kingpin.Flag("web.external-url", "The URL under which Alertmanager is externally reachable (for example, if Alertmanager is served via a reverse proxy). Used for generating relative and absolute links back to Alertmanager itself. If the URL has a path portion, it will be used to prefix all HTTP endpoints served by Alertmanager. If omitted, relevant URL components will be derived automatically.").String() routePrefix = kingpin.Flag("web.route-prefix", "Prefix for the internal routes of web endpoints. Defaults to path of --web.external-url.").String() @@ -273,7 +276,7 @@ func run() int { notificationLogOpts := []nflog.Option{ nflog.WithRetention(*retention), nflog.WithSnapshot(filepath.Join(*dataDir, "nflog")), - nflog.WithMaintenance(15*time.Minute, stopc, wg.Done, nil), + nflog.WithMaintenance(*nflogsInterval, stopc, wg.Done, nil), nflog.WithMetrics(prometheus.DefaultRegisterer), nflog.WithLogger(log.With(logger, "component", "nflog")), } @@ -310,7 +313,7 @@ func run() int { // Start providers before router potentially sends updates. wg.Add(1) go func() { - silences.Maintenance(15*time.Minute, filepath.Join(*dataDir, "silences"), stopc, nil) + silences.Maintenance(*silencesInterval, filepath.Join(*dataDir, "silences"), stopc, nil) wg.Done() }()