RepoMirrors/alertmanager
1
0
Fork 0
mirror of https://github.com/prometheus/alertmanager synced 2024-12-24 15:12:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Pass aggregation group identifier through context

Browse Source
This commit is contained in:
Fabian Reinartz 2015-10-01 15:18:19 +02:00
parent d2a0a218aa
commit 03272174f2
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
dispatch.go
View File

@ -204,8 +204,9 @@ func (ag *aggrGroup) run(nf notifyFunc) {
// finish before terminating them. // finish before terminating them.
ctx, _ := context.WithTimeout(ag.ctx, ag.opts.GroupInterval) ctx, _ := context.WithTimeout(ag.ctx, ag.opts.GroupInterval)
// Populate context with the destination name. // Populate context with the destination name and group identifier.
ctx = context.WithValue(ctx, notify.NotifyName, ag.opts.SendTo) ctx = context.WithValue(ctx, notify.NotifyName, ag.opts.SendTo)
ctx = context.WithValue(ctx, notify.NotifyGroup, ag.String())
// Wait the configured interval before calling flush again. // Wait the configured interval before calling flush again.
ag.next.Reset(ag.opts.GroupInterval) ag.next.Reset(ag.opts.GroupInterval)

1
notify/notify.go
View File

@ -20,6 +20,7 @@ const (
NotifyName notifyKey = iota NotifyName notifyKey = iota
NotifyRepeatInterval NotifyRepeatInterval
NotifySendResolved NotifySendResolved
NotifyGroup
) )
type Notifier interface { type Notifier interface {