Merge #1580

1580: feat(eventing): snapshot and clone events r=datacore-vvarakantham a=datacore-vvarakantham

Added snapshot and clone create events.

Co-authored-by: Vandana Varakantham <vandana.varakantham@datacore.com>

Author: mayastor-bors

io-engine/src/eventing/clone_events.rs

@@ -0,0 +1,31 @@
+use events_api::event::{
+    EventAction,
+    EventCategory,
+    EventMessage,
+    EventMeta,
+    EventSource,
+};
+
+use crate::{
+    core::{snapshot::CloneParams, MayastorEnvironment},
+    eventing::Event,
+};
+
+impl Event for CloneParams {
+    fn event(&self, event_action: EventAction) -> EventMessage {
+        let event_source = EventSource::new(
+            MayastorEnvironment::global_or_default().node_name,
+        )
+        .with_clone_data(
+            self.source_uuid().unwrap_or_default(),
+            self.clone_create_time().unwrap_or_default(),
+        );
+
+        EventMessage {
+            category: EventCategory::Clone as i32,
+            action: event_action as i32,
+            target: self.clone_uuid().unwrap_or_default(),
+            metadata: Some(EventMeta::from_source(event_source)),
+        }
+    }
+}

io-engine/src/eventing/mod.rs

@@ -1,9 +1,11 @@
+mod clone_events;
 pub(crate) mod host_events;
 pub(crate) mod io_engine_events;
 mod nexus_child_events;
 pub(crate) mod nexus_events;
 mod pool_events;
 pub(crate) mod replica_events;
+mod snapshot_events;
 use events_api::event::{EventAction, EventMessage, EventMeta};
 
 /// Event trait definition for creating events.

io-engine/src/eventing/snapshot_events.rs

@@ -0,0 +1,32 @@
+use events_api::event::{
+    EventAction,
+    EventCategory,
+    EventMessage,
+    EventMeta,
+    EventSource,
+};
+
+use crate::{
+    core::{MayastorEnvironment, SnapshotDescriptor, SnapshotParams},
+    eventing::Event,
+};
+
+impl Event for SnapshotParams {
+    fn event(&self, event_action: EventAction) -> EventMessage {
+        let event_source = EventSource::new(
+            MayastorEnvironment::global_or_default().node_name,
+        )
+        .with_snapshot_data(
+            self.parent_id().unwrap_or_default(),
+            self.create_time().unwrap_or_default(),
+            self.entity_id().unwrap_or_default(),
+        );
+
+        EventMessage {
+            category: EventCategory::Snapshot as i32,
+            action: event_action as i32,
+            target: self.snapshot_uuid().unwrap_or_default(),
+            metadata: Some(EventMeta::from_source(event_source)),
+        }
+    }
+}

io-engine/src/lvs/lvol_snapshot.rs

@@ -9,12 +9,14 @@ use crate::{
         SnapshotXattrs,
         UntypedBdev,
     },
+    eventing::Event,
     ffihelper::{cb_arg, IntoCString},
     lvs::{lvs_lvol::LvsLvol, Lvol},
     subsys::NvmfReq,
 };
 use async_trait::async_trait;
 use chrono::Utc;
+use events_api::event::EventAction;
 use futures::channel::oneshot;
 use nix::errno::Errno;
 use spdk_rs::libspdk::{
@@ -252,7 +254,10 @@ impl SnapshotOps for Lvol {
         let (error, lvol_ptr) =
             receiver.await.expect("Snapshot done callback disappeared");
         match error {
-            0 => Ok(Lvol::from_inner_ptr(lvol_ptr)),
+            0 => {
+                snap_param.event(EventAction::Create).generate();
+                Ok(Lvol::from_inner_ptr(lvol_ptr))
+            }
             _ => Err(Error::SnapshotCreate {
                 source: Errno::from_i32(error),
                 msg: snap_param.name().unwrap(),
@@ -268,6 +273,7 @@ impl SnapshotOps for Lvol {
         unsafe {
             self.create_snapshot_inner(&snap_param, done_cb, done_cb_arg)?;
         }
+        snap_param.event(EventAction::Create).generate();
         Ok(())
     }
 
@@ -406,7 +412,10 @@ impl SnapshotOps for Lvol {
             .await
             .expect("Snapshot Clone done callback disappeared");
         match error {
-            0 => Ok(Lvol::from_inner_ptr(lvol_ptr)),
+            0 => {
+                clone_param.event(EventAction::Create).generate();
+                Ok(Lvol::from_inner_ptr(lvol_ptr))
+            }
             _ => Err(Error::SnapshotCloneCreate {
                 source: Errno::from_i32(error),
                 msg: clone_param.clone_name().unwrap_or_default(),
@@ -573,6 +582,7 @@ impl SnapshotOps for Lvol {
             )
             .await?;
         }
+
         Ok(())
     }