From 7dda49c55d1c2caccd6fc84f8587543ca4898308 Mon Sep 17 00:00:00 2001 From: Marco Munizaga Date: Fri, 8 Jul 2022 13:43:46 -0700 Subject: [PATCH] Record which direction the resource was blocked --- obs/stats.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/obs/stats.go b/obs/stats.go index 4ba2bf4..3160f6a 100644 --- a/obs/stats.go +++ b/obs/stats.go @@ -320,11 +320,13 @@ func (r StatsTraceReporter) ConsumeEvent(evt rcmgr.TraceEvt) { tags := []tag.Mutator{tag.Upsert(scopeTag, scopeName), tag.Upsert(resourceTag, resource)} if evt.DeltaIn != 0 { - stats.RecordWithTags(ctx, tags, blockedResources.M(int64(1))) + tagsWithDir := append([]tag.Mutator{tag.Insert(directionTag, "inbound")}, tags...) + stats.RecordWithTags(ctx, tagsWithDir, blockedResources.M(int64(1))) } if evt.DeltaOut != 0 { - stats.RecordWithTags(ctx, tags, blockedResources.M(int64(1))) + tagsWithDir := append([]tag.Mutator{tag.Insert(directionTag, "outbound")}, tags...) + stats.RecordWithTags(ctx, tagsWithDir, blockedResources.M(int64(1))) } if evt.Delta != 0 {