Send discovered intents

otterize · Sep 6, 2023 · 9741fb6 · 9741fb6
1 parent 06f494e
commit 9741fb6
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/src/mapper/pkg/intentsstore/holder.go b/src/mapper/pkg/intentsstore/holder.go
@@ -202,6 +202,13 @@ func (i *IntentsHolder) GetIntents(
 	return result, nil
 }
 
+func (i *IntentsHolder) GetIntentsCount() int {
+	i.lock.Lock()
+	defer i.lock.Unlock()
+
+	return len(i.accumulatingStore)
+}
+
 func (i *IntentsHolder) GetNewIntentsSinceLastGet() []TimestampedIntent {
 	i.lock.Lock()
 	defer i.lock.Unlock()

diff --git a/src/mapper/pkg/resolvers/schema.resolvers.go b/src/mapper/pkg/resolvers/schema.resolvers.go
@@ -91,6 +91,7 @@ func (r *mutationResolver) ReportCaptureResults(ctx context.Context, results mod
 		}
 	}
 	telemetrysender.SendNetworkMapper(telemetriesgql.EventTypeIntentsDiscoveredCapture, len(results.Results))
+	telemetrysender.SendNetworkMapper(telemetriesgql.EventTypeIntentsDiscovered, r.intentsHolder.GetIntentsCount())
 	return true, nil
 }
 
@@ -144,6 +145,7 @@ func (r *mutationResolver) ReportSocketScanResults(ctx context.Context, results
 		}
 	}
 	telemetrysender.SendNetworkMapper(telemetriesgql.EventTypeIntentsDiscoveredSocketScan, len(results.Results))
+	telemetrysender.SendNetworkMapper(telemetriesgql.EventTypeIntentsDiscovered, r.intentsHolder.GetIntentsCount())
 	return true, nil
 }
 
@@ -214,6 +216,7 @@ func (r *mutationResolver) ReportKafkaMapperResults(ctx context.Context, results
 	}
 
 	telemetrysender.SendNetworkMapper(telemetriesgql.EventTypeIntentsDiscoveredKafka, len(results.Results))
+	telemetrysender.SendNetworkMapper(telemetriesgql.EventTypeIntentsDiscovered, r.intentsHolder.GetIntentsCount())
 	return true, nil
 }
 
@@ -258,6 +261,7 @@ func (r *mutationResolver) ReportIstioConnectionResults(ctx context.Context, res
 	}
 
 	telemetrysender.SendNetworkMapper(telemetriesgql.EventTypeIntentsDiscoveredIstio, len(results.Results))
+	telemetrysender.SendNetworkMapper(telemetriesgql.EventTypeIntentsDiscovered, r.intentsHolder.GetIntentsCount())
 	return true, nil
 }