crd

mirrord/operator/src/crd.rs

@@ -504,12 +504,19 @@ pub struct SqsSessionStatus {
     pub details: Option<SqsSessionDetails>,
 }
 
+impl SqsSessionStatus {
+    pub fn is_ready(&self) -> bool {
+        self.details.is_some()
+    }
+}
+
+
 /// The [`kube::runtime::wait::Condition`] trait is auto-implemented for this function.
 /// To be used in [`kube::runtime::wait::await_condition`].
 pub fn is_session_ready(session: Option<&MirrordSqsSession>) -> bool {
     session
         .and_then(|session| session.status.as_ref())
-        .map(|status| status.details.is_some())
+        .map(|status| status.is_ready())
         .unwrap_or_default()
 }