RepoMirrors/alertmanager
1
0
Fork 0
mirror of https://github.com/prometheus/alertmanager synced 2025-02-16 18:47:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

notify: optimize length check. (#2106)

Browse Source 
Signed-off-by: johncming <johncming@yahoo.com>
This commit is contained in:
johncming 2019-11-19 16:00:06 +08:00 committed by Simon Pasquier
parent 66a0ed21bd
commit d965ac6393
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
notify/notify.go
View File

@ -576,18 +576,19 @@ func (n *DedupStage) Exec(ctx context.Context, l log.Logger, alerts ...*types.Al
ctx = WithResolvedAlerts(ctx, resolved) ctx = WithResolvedAlerts(ctx, resolved)
entries, err := n.nflog.Query(nflog.QGroupKey(gkey), nflog.QReceiver(n.recv)) entries, err := n.nflog.Query(nflog.QGroupKey(gkey), nflog.QReceiver(n.recv))
if err != nil && err != nflog.ErrNotFound { if err != nil && err != nflog.ErrNotFound {
return ctx, nil, err return ctx, nil, err
} }
var entry *nflogpb.Entry var entry *nflogpb.Entry
switch len(entries) { switch len(entries) {
case 0: case 0:
case 1: case 1:
entry = entries[0] entry = entries[0]
case 2: default:
return ctx, nil, fmt.Errorf("unexpected entry result size %d", len(entries)) return ctx, nil, fmt.Errorf("unexpected entry result size %d", len(entries))
} }
if n.needsUpdate(entry, firingSet, resolvedSet, repeatInterval) { if n.needsUpdate(entry, firingSet, resolvedSet, repeatInterval) {
return ctx, alerts, nil return ctx, alerts, nil
} }