Implemented Debug on all structs

bastion/src/broadcast.rs

@@ -11,6 +11,7 @@ use std::task::{Context, Poll};
 pub(super) type Sender = UnboundedSender<BastionMessage>;
 pub(super) type Receiver = UnboundedReceiver<BastionMessage>;
 
+#[derive(Debug)]
 pub(super) struct Broadcast {
     id: BastionId,
     sender: Sender,
@@ -19,13 +20,15 @@ pub(super) struct Broadcast {
     children: FxHashMap<BastionId, Sender>,
 }
 
+#[derive(Debug)]
 pub(super) enum Parent {
     None,
     System,
     Supervisor(SupervisorRef),
     Children(ChildrenRef),
 }
 
+#[derive(Debug)]
 pub(super) enum BastionMessage {
     Start,
     Stop,
@@ -38,6 +41,7 @@ pub(super) enum BastionMessage {
     Faulted { id: BastionId },
 }
 
+#[derive(Debug)]
 pub(super) enum Deployment {
     Supervisor(Supervisor),
     Children(Children),

bastion/src/children.rs

@@ -11,7 +11,7 @@ use futures::stream::FuturesUnordered;
 use fxhash::FxHashMap;
 use qutex::Qutex;
 use std::any::Any;
-use std::fmt::Debug;
+use std::fmt::{self, Debug, Formatter};
 use std::future::Future;
 use std::iter::FromIterator;
 use std::panic::AssertUnwindSafe;
@@ -61,7 +61,7 @@ pub(super) struct Children {
     started: bool,
 }
 
-#[derive(Clone)]
+#[derive(Debug)]
 pub struct ChildrenRef {
     id: BastionId,
     sender: Sender,
@@ -402,3 +402,27 @@ impl Child {
         }
     }
 }
+
+impl Debug for Children {
+    fn fmt(&self, fmt: &mut Formatter) -> fmt::Result {
+        fmt.debug_struct("Children")
+            .field("bcast", &self.bcast)
+            .field("supervisor", &self.supervisor)
+            .field("launched", &self.launched)
+            .field("redundancy", &self.redundancy)
+            .field("pre_start_msgs", &self.pre_start_msgs)
+            .field("started", &self.started)
+            .finish()
+    }
+}
+
+impl Debug for Child {
+    fn fmt(&self, fmt: &mut Formatter) -> fmt::Result {
+        fmt.debug_struct("Child")
+            .field("bcast", &self.bcast)
+            .field("state", &self.state)
+            .field("pre_start_msgs", &self.pre_start_msgs)
+            .field("started", &self.started)
+            .finish()
+    }
+}

bastion/src/context.rs

@@ -12,13 +12,15 @@ pub(super) const NIL_ID: BastionId = BastionId(Uuid::nil());
 #[derive(Hash, Eq, PartialEq, Debug, Clone)]
 pub struct BastionId(Uuid);
 
+#[derive(Debug)]
 pub struct BastionContext {
     id: BastionId,
     children: ChildrenRef,
     supervisor: SupervisorRef,
     state: Qutex<ContextState>,
 }
 
+#[derive(Debug)]
 pub(super) struct ContextState {
     msgs: VecDeque<Box<dyn Message>>,
 }

bastion/src/proc.rs

@@ -4,6 +4,7 @@ use std::future::Future;
 use std::pin::Pin;
 use std::task::{Context, Poll};
 
+#[derive(Debug)]
 pub(super) struct Proc<T> {
     recver: Receiver<T>,
 }

bastion/src/registry.rs

@@ -4,16 +4,18 @@ use crate::context::BastionId;
 use crate::supervisor::{Supervisor, SupervisorRef};
 use dashmap::DashMap;
 
+#[derive(Debug)]
 pub(super) struct Registry {
     registered: DashMap<BastionId, Registrant>,
 }
 
+#[derive(Debug)]
 struct Registrant {
     sender: Sender,
     ty: RegistrantType,
 }
 
-#[derive(Eq, PartialEq)]
+#[derive(Eq, PartialEq, Debug)]
 enum RegistrantType {
     Supervisor,
     Children,

bastion/src/supervisor.rs

@@ -10,6 +10,7 @@ use fxhash::FxHashMap;
 use std::ops::RangeFrom;
 use std::task::Poll;
 
+#[derive(Debug)]
 pub struct Supervisor {
     bcast: Broadcast,
     order: Vec<BastionId>,
@@ -20,19 +21,20 @@ pub struct Supervisor {
     started: bool,
 }
 
-#[derive(Clone)]
+#[derive(Debug, Clone)]
 pub struct SupervisorRef {
     id: BastionId,
     sender: Sender,
 }
 
-#[derive(Clone)]
+#[derive(Debug, Clone)]
 pub enum SupervisionStrategy {
     OneForOne,
     OneForAll,
     RestForOne,
 }
 
+#[derive(Debug)]
 enum Supervised {
     Supervisor(Supervisor),
     Children(Children),

bastion/src/system.rs

@@ -14,6 +14,7 @@ lazy_static! {
     pub(super) static ref RUNTIME: Runtime = Builder::new().panic_handler(|_| ()).build().unwrap();
 }
 
+#[derive(Debug)]
 pub(super) struct System {
     bcast: Broadcast,
     launched: FxHashMap<BastionId, Proc<Supervisor>>,