report Azure Operation

src/mapper/pkg/graph/model/results_length.go

@@ -22,6 +22,12 @@ func (c AWSOperationResults) Length() int {
 	return len(c)
 }
 
+type AzureOperationResults []AzureOperation
+
+func (c AzureOperationResults) Length() int {
+	return len(c)
+}
+
 func (c CaptureTCPResults) Length() int {
 	return len(c.Results)
 }

src/mapper/pkg/prometheus/metrics.go

@@ -26,10 +26,7 @@ var (
 		Name: "istio_reported_connections",
 		Help: "The total number of Istio-sourced connections",
 	})
-	awsReports = promauto.NewCounter(prometheus.CounterOpts{
-		Name: "aws_reports",
-		Help: "The total number of AWS operations reported",
-	})
+
 	socketScanDrops = promauto.NewCounter(prometheus.CounterOpts{
 		Name: "socketscan_dropped_connections",
 		Help: "The total number of socket scan-sourced reported connections that were dropped for performance",
@@ -51,10 +48,23 @@ var (
 		Help: "The total number of Istio-sourced reported connections that were dropped for performance",
 	})
 
+	awsReports = promauto.NewCounter(prometheus.CounterOpts{
+		Name: "aws_reports",
+		Help: "The total number of AWS operations reported",
+	})
 	awsReportsDrops = promauto.NewCounter(prometheus.CounterOpts{
 		Name: "aws_dropped_reports",
 		Help: "The total number of AWS operations reported that were dropped for performance",
 	})
+
+	azureReports = promauto.NewCounter(prometheus.CounterOpts{
+		Name: "azure_reports",
+		Help: "The total number of Azure operations reported",
+	})
+	azureReportsDrops = promauto.NewCounter(prometheus.CounterOpts{
+		Name: "azure_dropped_reports",
+		Help: "The total number of Azure operations reported that were dropped for performance",
+	})
 )
 
 func IncrementTCPCaptureReports(count int) {
@@ -104,3 +114,10 @@ func IncrementIstioDrops(count int) {
 func IncrementAWSOperationDrops(count int) {
 	awsReportsDrops.Add(float64(count))
 }
+
+func IncrementAzureOperationReports(count int) {
+	azureReports.Add(float64(count))
+}
+func IncrementAzureOperationDrops(count int) {
+	azureReportsDrops.Add(float64(count))
+}

src/mapper/pkg/resolvers/resolver.go

@@ -37,6 +37,7 @@ type Resolver struct {
 	kafkaMapperResults           chan model.KafkaMapperResults
 	istioConnectionResults       chan model.IstioConnectionResults
 	awsOperations                chan model.AWSOperationResults
+	azureOperations              chan model.AzureOperationResults
 	gotResultsCtx                context.Context
 	gotResultsSignal             context.CancelFunc
 	isRunningOnAws               bool
@@ -63,6 +64,7 @@ func NewResolver(
 		kafkaMapperResults:           make(chan model.KafkaMapperResults, 200),
 		istioConnectionResults:       make(chan model.IstioConnectionResults, 200),
 		awsOperations:                make(chan model.AWSOperationResults, 200),
+		azureOperations:              make(chan model.AzureOperationResults, 200),
 		awsIntentsHolder:             awsIntentsHolder,
 		dnsCache:                     dnsCache,
 		isRunningOnAws:               isrunningonaws.Check(),

src/mappergraphql/schema.graphql

@@ -150,6 +150,14 @@ input ServerFilter {
     namespace: String!
 }
 
+input AzureOperation {
+    resource: String!
+    actions: [String!]!
+    dataActions: [String!]!
+    podName: String!
+    podNamespace: String!
+}
+
 type Query {
     """
     Kept for backwards compatibility with CLI -
@@ -186,4 +194,5 @@ type Mutation {
     reportKafkaMapperResults(results: KafkaMapperResults!): Boolean!
     reportIstioConnectionResults(results: IstioConnectionResults!): Boolean!
     reportAWSOperation(operation: [AWSOperation!]!): Boolean!
+    reportAzureOperation(operation: [AzureOperation!]!): Boolean!
 }