feat(eventing): nexus child events

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

io-engine/src/eventing/mod.rs

@@ -1,3 +1,4 @@
+mod nexus_child_events;
 pub(crate) mod nexus_events;
 mod pool_events;
 mod replica_events;

io-engine/src/eventing/nexus_child_events.rs

@@ -0,0 +1,41 @@
+use events_api::event::{
+    EventAction,
+    EventCategory,
+    EventMessage,
+    EventMeta,
+    EventSource,
+};
+
+use mayastor_api::v1::nexus::{AddChildNexusRequest, RemoveChildNexusRequest};
+
+use crate::{core::MayastorEnvironment, eventing::Event};
+
+// Nexus child added event message.
+impl Event for AddChildNexusRequest {
+    fn event(&self, event_action: EventAction) -> EventMessage {
+        let event_source = EventSource::new(
+            MayastorEnvironment::global_or_default().node_name,
+        ).with_nexus_child_data(&self.uri);
+        EventMessage {
+            category: EventCategory::Nexus as i32,
+            action: event_action as i32,
+            target: self.uuid.clone(),
+            metadata: Some(EventMeta::from_source(event_source)),
+        }
+    }
+}
+
+// Nexus child removed event message.
+impl Event for RemoveChildNexusRequest {
+    fn event(&self, event_action: EventAction) -> EventMessage {
+        let event_source = EventSource::new(
+            MayastorEnvironment::global_or_default().node_name,
+        ).with_nexus_child_data(&self.uri);
+        EventMessage {
+            category: EventCategory::Nexus as i32,
+            action: event_action as i32,
+            target: self.uuid.clone(),
+            metadata: Some(EventMeta::from_source(event_source)),
+        }
+    }
+}

io-engine/src/grpc/v1/nexus.rs

@@ -560,11 +560,14 @@ impl NexusRpc for NexusService {
         let ctx = GrpcClientContext::new(&request, function_name!());
         let args = request.into_inner();
 
+        let event = args.event(EventAction::AddChild);
+
         self.serialized(ctx, args.uuid.clone(), false, async move {
             let rx = rpc_submit::<_, _, nexus::Error>(async move {
                 trace!("{:?}", args);
                 let nexus = nexus_add_child(&args).await?;
                 info!("Added child to nexus {}", args.uuid);
+                event.generate();
                 Ok(nexus)
             })?;
 
@@ -588,6 +591,8 @@ impl NexusRpc for NexusService {
         let ctx = GrpcClientContext::new(&request, function_name!());
         let args = request.into_inner();
 
+        let event = args.clone().event(EventAction::RemoveChild);
+
         self.serialized(ctx, args.uuid.clone(), false, async move {
             let rx = rpc_submit::<_, _, nexus::Error>(async move {
                 trace!("{:?}", args);
@@ -601,6 +606,7 @@ impl NexusRpc for NexusService {
                         "Removed child {} from nexus {}",
                         args.uri, args.uuid
                     );
+                    event.generate();
                 }
                 Ok(nexus_lookup(&args.uuid)?.into_grpc().await)
             })?;