diff --git a/pkg/models/helpers.go b/pkg/models/helpers.go index 0724d89ae..ffca2c9dd 100644 --- a/pkg/models/helpers.go +++ b/pkg/models/helpers.go @@ -41,6 +41,15 @@ func (e *Event) GetMeta(key string) string { return "" } +func (a *Alert) GetMeta(key string) string { + for _, meta := range a.Meta { + if meta.Key == key { + return meta.Value + } + } + return "" +} + func (s Source) GetValue() string { if s.Value == nil { return "" diff --git a/pkg/types/event.go b/pkg/types/event.go index ad47d194a..c59f4fdbb 100644 --- a/pkg/types/event.go +++ b/pkg/types/event.go @@ -52,6 +52,25 @@ func (e *Event) GetType() string { } } +func (e *Event) GetMeta(key string) string { + if e.Type == OVFLW { + for _, alert := range e.Overflow.APIAlerts { + for _, event := range alert.Events { + if event.GetMeta(key) != "" { + return event.GetMeta(key) + } + } + } + } else if e.Type == LOG { + for k, v := range e.Meta { + if k == key { + return v + } + } + } + return "" +} + //Move in leakybuckets const ( Undefined = ""