Merge pull request #35 from kubescape/uns-kdr

Refactor topics.go to update topic names and add new topic for RuntimeIncident

pulsar/common/kdr/datastructures.go

@@ -0,0 +1,27 @@
+package kdr
+
+import (
+	"time"
+
+	"github.com/armosec/armoapi-go/identifiers"
+	"go.uber.org/zap"
+)
+
+type RuntimeIncidentIngesterOnFinishedMessage struct {
+	ReportTime          time.Time                    `json:"reportTime"`
+	SendTime            time.Time                    `json:"sendTime"`
+	CustomerGUID        string                       `json:"customerGUID"`
+	IncidentPolicyGUIDs []string                     `json:"incidentPolicyGUIDs"`
+	IncidentGUID        string                       `json:"incidentGUID"`
+	IncidentName        string                       `json:"incidentName"` // incidentType.Name - ThreatName
+	Severity            string                       `json:"severity"`
+	Resource            identifiers.PortalDesignator `json:"resource"` // Pod, Node, Workload, Namespace, Cluster, etc.
+}
+
+func (si *RuntimeIncidentIngesterOnFinishedMessage) GetLoggerFields() []zap.Field {
+	fields := []zap.Field{
+		zap.String("customerGUID", si.CustomerGUID),
+	}
+
+	return fields
+}

pulsar/common/topics.go

@@ -15,6 +15,7 @@ const (
 	PostureOnFinishPulsarTopic         = "kubescape-scan-report-finished-v1"
 	SecurityRisksOnFinishPulsarTopic   = "security-risks-scan-report-finished-v1"
 	UIViewsIngesterOnFinishPulsarTopic = "ui-views-finished-v1"
+	RuntimeIncidentOnFinishPulsarTopic = "runtime-incident-finished-v1"
 
 	UNSOnFinishSubscriptionName = "uns-report-finished"