feat(eventing): nvme path suspect and fail events

Signed-off-by: Vandana Varakantham <[email protected]>

apis/events/protobuf/v1/event.proto

@@ -27,6 +27,7 @@ enum EventCategory {
   Replica = 4;
   Node = 5;
   HighAvailability = 6;
+  NvmePath = 7;
 }
 
 // Event Action
@@ -40,6 +41,8 @@ enum EventAction {
   SwitchOver = 6;
   AddChild = 7;
   RemoveChild = 8;
+  NvmePathSuspect = 9;
+  NvmePathFail = 10;
 }
 
 // Event meta data
@@ -69,6 +72,7 @@ enum Component {
   CoreAgent = 1;
   IoEngine = 2;
   HaClusterAgent = 3;
+  HaNodeAgent = 4;
 }
 
 // Event message version
@@ -87,6 +91,8 @@ message EventDetails {
   optional SwitchOverEventDetails switch_over_details = 3;
   // Nexus child event details
   optional NexusChildEventDetails nexus_child_details = 4;
+  // Nvme path event details
+  optional NvmePathEventDetails nvme_path_details = 5;
 }
 
 // Rebuild event details
@@ -156,3 +162,9 @@ message NexusChildEventDetails {
   // Nexus child uri
   string uri = 1;
 }
+
+// Nvme path event details
+message NvmePathEventDetails {
+  string nqn = 1;
+  string path = 2;
+}

apis/events/src/event_traits.rs

@@ -1,7 +1,7 @@
 use crate::event::{
     Component, EventDetails, EventMessage, EventMeta, EventSource, NexusChildEventDetails,
-    RebuildEventDetails, RebuildStatus, ReplicaEventDetails, SwitchOverEventDetails,
-    SwitchOverStatus, Version,
+    NvmePathEventDetails, RebuildEventDetails, RebuildStatus, ReplicaEventDetails,
+    SwitchOverEventDetails, SwitchOverStatus, Version,
 };
 use chrono::{DateTime, Utc};
 use once_cell::sync::OnceCell;
@@ -124,6 +124,20 @@ impl EventSource {
             ..self
         }
     }
+
+    /// Add nvme path event specific data to event source.
+    pub fn with_nvme_path_data(self, nqn: &str, path: &str) -> Self {
+        EventSource {
+            event_details: Some(EventDetails {
+                nvme_path_details: Some(NvmePathEventDetails {
+                    nqn: nqn.to_string(),
+                    path: path.to_string(),
+                }),
+                ..Default::default()
+            }),
+            ..self
+        }
+    }
 }
 
 impl EventMessage {
@@ -142,6 +156,7 @@ impl FromStr for Component {
             "agent-core" => Ok(Self::CoreAgent),
             "io-engine" => Ok(Self::IoEngine),
             "agent-ha-cluster" => Ok(Self::HaClusterAgent),
+            "agent-ha-node" => Ok(Self::HaNodeAgent),
             _ => Err(format!("Received event from unknown component {c}")),
         }
     }