Merge #1513

1513: feat(eventing): Replica events r=datacore-vvarakantham a=datacore-vvarakantham

Added replica creation and deletion events.
And Replica event specific data(pool name, pool uuid, replica name).

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

io-engine/src/eventing/mod.rs

@@ -1,5 +1,6 @@
 pub(crate) mod nexus_events;
 mod pool_events;
+mod replica_events;
 use events_api::event::{EventAction, EventMessage, EventMeta};
 
 /// Event trait definition for creating events.

io-engine/src/eventing/nexus_events.rs

@@ -29,7 +29,7 @@ impl EventMetaGen for RebuildJob {
         let event_source = EventSource::new(
             MayastorEnvironment::global_or_default().node_name,
         )
-        .add_rebuild_data(
+        .with_rebuild_data(
             rebuild_status,
             self.src_uri(),
             self.dst_uri(),

io-engine/src/eventing/replica_events.rs

@@ -0,0 +1,34 @@
+use events_api::event::{
+    EventAction,
+    EventCategory,
+    EventMessage,
+    EventMeta,
+    EventSource,
+};
+
+use crate::{
+    core::{logical_volume::LogicalVolume, MayastorEnvironment},
+    eventing::Event,
+    lvs::lvs_lvol::{Lvol, LvsLvol},
+};
+
+// Replica event messages from Lvol data.
+impl Event for Lvol {
+    fn event(&self, event_action: EventAction) -> EventMessage {
+        let event_source = EventSource::new(
+            MayastorEnvironment::global_or_default().node_name,
+        )
+        .with_replica_data(
+            self.lvs().name(),
+            &self.lvs().uuid(),
+            &self.name(),
+        );
+
+        EventMessage {
+            category: EventCategory::Replica as i32,
+            action: event_action as i32,
+            target: self.uuid(),
+            metadata: Some(EventMeta::from_source(event_source)),
+        }
+    }
+}

io-engine/src/lvs/lvs_lvol.rs

@@ -1,6 +1,7 @@
 use async_trait::async_trait;
 use byte_unit::Byte;
 use chrono::Utc;
+use events_api::event::EventAction;
 use futures::channel::oneshot;
 use nix::errno::Errno;
 use pin_utils::core_reexport::fmt::Formatter;
@@ -52,6 +53,7 @@ use crate::{
         UntypedBdev,
         UpdateProps,
     },
+    eventing::Event,
     ffihelper::{
         cb_arg,
         done_cb,
@@ -822,6 +824,7 @@ impl LvsLvol for Lvol {
     }
     /// Destroy the lvol.
     async fn destroy(mut self) -> Result<String, Error> {
+        let event = self.event(EventAction::Delete);
         extern "C" fn destroy_cb(sender: *mut c_void, errno: i32) {
             let sender =
                 unsafe { Box::from_raw(sender as *mut oneshot::Sender<i32>) };
@@ -858,6 +861,7 @@ impl LvsLvol for Lvol {
         }
 
         info!("destroyed lvol {}", name);
+        event.generate();
         Ok(name)
     }
 

io-engine/src/lvs/lvs_store.rs

@@ -877,6 +877,7 @@ impl Lvs {
         }
 
         info!("{:?}: created", lvol);
+        lvol.event(EventAction::Create).generate();
         Ok(lvol)
     }