fine tune keep alive

wix · Feb 9, 2023 · 385bb84 · 385bb84
1 parent b0874ae
commit 385bb84
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/greyhoundsidecar/src/main/scala/greyhound/KeepAliveScheduler.scala b/greyhoundsidecar/src/main/scala/greyhound/KeepAliveScheduler.scala
@@ -14,7 +14,7 @@ object KeepAliveScheduler {
         _ <- tenantRegistry.handleTenantActivityStatus(tenantId, isAlive)
       } yield tenantId
 
-      policy = Schedule.recurUntilZIO[Env, String](tenantId => tenantRegistry.getTenant(tenantId).map(_.isEmpty)) && Schedule.spaced(2.seconds)
+      policy = Schedule.recurUntilZIO[Env, String](tenantId => tenantRegistry.getTenant(tenantId).map(_.isEmpty)) && Schedule.spaced(3.seconds)
      _ <- action repeat policy
     } yield ()
   }

diff --git a/greyhoundsidecar/src/test/scala/greyhound/SidecarServiceTest.scala b/greyhoundsidecar/src/test/scala/greyhound/SidecarServiceTest.scala
@@ -38,7 +38,7 @@ object SidecarServiceTest extends JUnitRunnableSpec with KafkaTestSupport with C
           records1 <- sidecarUser.collectedRequests.delay(6.seconds)
           _ <- assertTrue(records1.nonEmpty)
           _ <- sidecarUser.updateShouldKeepAlive(keepAlive = false)
-          _ <- sidecarUser.updateShouldKeepAlive(keepAlive = true).delay(5.second)
+          _ <- sidecarUser.updateShouldKeepAlive(keepAlive = true).delay(6.second)
           _ <- sidecarService.produce(ProduceRequest(context.topicName, context.payload, context.target)).delay(6.seconds)
           records2 <- sidecarUser.collectedRequests.delay(6.seconds)
         } yield assert(records2.size - records1.size)(equalTo(0))
@@ -64,7 +64,7 @@ object SidecarServiceTest extends JUnitRunnableSpec with KafkaTestSupport with C
           records1 <- sidecarUser.collectedRequests.delay(6.seconds)
           _ <- assertTrue(records1.nonEmpty)
           _ <- sidecarUser.updateShouldKeepAlive(keepAlive = false)
-          _ <- sidecarUser.updateShouldKeepAlive(keepAlive = true).delay(2.second)
+          _ <- sidecarUser.updateShouldKeepAlive(keepAlive = true).delay(3.second)
           _ <- sidecarService.produce(ProduceRequest(context.topicName, context.payload, context.target)).delay(6.seconds)
           records2 <- sidecarUser.collectedRequests.delay(6.seconds)
         } yield assertTrue((records2.size - records1.size) > 0)