increase timeout for pod spinup

Author: eed3si9n

integrateion-test/src/sbt-test/bootstrap-demo/dns-kubernetes/build.sbt

@@ -67,7 +67,7 @@ lazy val root = (project in file("."))
           s.log.info("applying openshift.yml")
           Process(s"$kubectl apply -f kubernetes/openshift.yml").!(s.log)
 
-          waitForPods(3, 10, s.log)
+          waitForPods(3, 20, s.log)
           val p = findPodId(nm, s.log)
           checkMemberUp(p, 10, s.log)
         }
@@ -86,22 +86,13 @@ lazy val root = (project in file("."))
 
 def waitForPods(expected: Int, attempt: Int, log: Logger): Unit = {
   if (attempt == 0) {
-    val lines = try {
-      Process(s"$kubectl describe pods --namespace reactivelibtest1").!!.lines.toList
-    } catch {
-      case NonFatal(_) => Nil
-    }
-    lines foreach { log.info(_: String) }
+    processAndLog(s"$kubectl describe pods --namespace reactivelibtest1", log)
     sys.error("pods did not get ready in time")
   }
   else {
     log.info("waiting for pods to get ready...")
-    val lines = try {
-      Process(s"$kubectl get pods --namespace reactivelibtest1").!!.lines.toList
-    } catch {
-      case NonFatal(_) => Nil
-    }
-    lines foreach { log.info(_: String) }
+    val lines = processAndLog(s"$kubectl get pods --namespace reactivelibtest1", log)
+    processAndLog(s"$kubectl describe pods --namespace reactivelibtest1", log)
     if ((lines filter { _.contains("Running") }).size == expected) ()
     else {
       Thread.sleep(4000)
@@ -111,15 +102,24 @@ def waitForPods(expected: Int, attempt: Int, log: Logger): Unit = {
 }
 
 def findPodId(nm: String, log: Logger): String = {
-  val lines = Process(s"$kubectl get pods --namespace reactivelibtest1").!!.lines.toList
-  lines foreach { log.info(_: String) }
+  val lines = processAndLog(s"$kubectl get pods --namespace reactivelibtest1", log)
   val xs = lines filter { s => s.contains("Running") && s.contains(nm) }
   val firstRow = xs.headOption.getOrElse(sys.error("pods not found!"))
   val firstColumn = firstRow.trim.split(" ").toList
     .headOption.getOrElse(sys.error("pods not found!"))
   firstColumn
 }
 
+def processAndLog(cmd: String, log: Logger): List[String] = {
+  val lines = try {
+    Process(cmd).!!.lines.toList
+  } catch {
+    case NonFatal(_) => Nil
+  }
+  lines foreach { log.info(_: String) }
+  lines
+}
+
 def checkMemberUp(p: String, attempt: Int, log: Logger): Unit = {
   if (attempt == 0) sys.error("3 MemberUp log events were not found")
   else {

integrateion-test/src/sbt-test/bootstrap-demo/dns-kubernetes/src/main/scala/foo/ClusterApp.scala

@@ -25,6 +25,7 @@ object ClusterApp {
 
     val cluster = Cluster(system)
     system.log.info("Starting Akka Management")
+    system.log.info("something2")
     // AkkaManagement(system).start()
     // ClusterBootstrap(system).start()
 

integrateion-test/src/sbt-test/bootstrap-demo/kubernetes-api/build.sbt

@@ -74,7 +74,7 @@ lazy val root = (project in file("."))
           s.log.info("applying openshift.yml")
           Process(s"$kubectl apply -f kubernetes/openshift.yml").!(s.log)
 
-          waitForPods(3, 10, s.log)
+          waitForPods(3, 20, s.log)
           val p = findPodId(nm, s.log)
           checkMemberUp(p, 10, s.log)
         }
@@ -93,21 +93,12 @@ def kubectl: String = {
 
 def waitForPods(expected: Int, attempt: Int, log: Logger): Unit = {
   if (attempt == 0) {
-    val lines = try {
-      Process(s"$kubectl describe pods --namespace reactivelibtest1").!!.lines.toList
-    } catch {
-      case NonFatal(_) => Nil
-    }
-    lines foreach { log.info(_: String) }
+    processAndLog(s"$kubectl describe pods --namespace reactivelibtest1", log)
     sys.error("pods did not get ready in time")
   } else {
     log.info("waiting for pods to get ready...")
-    val lines = try {
-      Process(s"$kubectl get pods --namespace reactivelibtest1").!!.lines.toList
-    } catch {
-      case NonFatal(_) => Nil
-    }
-    lines foreach { log.info(_: String) }
+    val lines = processAndLog(s"$kubectl get pods --namespace reactivelibtest1", log)
+    processAndLog(s"$kubectl describe pods --namespace reactivelibtest1", log)
     if ((lines filter { _.contains("Running") }).size == expected) ()
     else {
       Thread.sleep(4000)
@@ -117,15 +108,24 @@ def waitForPods(expected: Int, attempt: Int, log: Logger): Unit = {
 }
 
 def findPodId(nm: String, log: Logger): String = {
-  val lines = Process(s"$kubectl get pods --namespace reactivelibtest1").!!.lines.toList
-  lines foreach { log.info(_: String) }
+  val lines = processAndLog(s"$kubectl get pods --namespace reactivelibtest1", log)
   val xs = lines filter { s => s.contains("Running") && s.contains(nm) }
   val firstRow = xs.headOption.getOrElse(sys.error("pods not found!"))
   val firstColumn = firstRow.trim.split(" ").toList
     .headOption.getOrElse(sys.error("pods not found!"))
   firstColumn
 }
 
+def processAndLog(cmd: String, log: Logger): List[String] = {
+  val lines = try {
+    Process(cmd).!!.lines.toList
+  } catch {
+    case NonFatal(_) => Nil
+  }
+  lines foreach { log.info(_: String) }
+  lines
+}
+
 def checkMemberUp(p: String, attempt: Int, log: Logger): Unit = {
   if (attempt == 0) sys.error("3 MemberUp log events were not found")
   else {

integrateion-test/src/sbt-test/bootstrap-demo/kubernetes-api/src/main/scala/foo/DemoApp.scala

@@ -23,7 +23,7 @@ object DemoApp extends App {
   val cluster = Cluster(system)
 
   log.info(s"Started [$system], cluster.selfAddress = ${cluster.selfAddress}")
-
+  log.info("something2")
   //#start-akka-management
   AkkaManagement(system).start()
   //#start-akka-management