feat: Add logging to Gateway for pod synchronization and startup events
This commit is contained in:
30
knockoutwhistweb/app/controllers/HealthController.scala
Normal file
30
knockoutwhistweb/app/controllers/HealthController.scala
Normal file
@@ -0,0 +1,30 @@
|
||||
package controllers
|
||||
|
||||
import auth.{AuthAction, AuthenticatedRequest}
|
||||
import dto.subDTO.UserDTO
|
||||
import logic.user.{SessionManager, UserManager}
|
||||
import model.users.User
|
||||
import play.api.*
|
||||
import play.api.libs.json.Json
|
||||
import play.api.mvc.*
|
||||
import play.api.mvc.Cookie.SameSite.{Lax, None, Strict}
|
||||
|
||||
import javax.inject.*
|
||||
|
||||
|
||||
/**
|
||||
* This controller creates an `Action` to handle HTTP requests to the
|
||||
* application's home page.
|
||||
*/
|
||||
@Singleton
|
||||
class HealthController @Inject()(
|
||||
val controllerComponents: ControllerComponents,
|
||||
) extends BaseController {
|
||||
|
||||
def simple(): Action[AnyContent] = {
|
||||
Action { implicit request =>
|
||||
Ok("OK")
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
@@ -22,12 +22,14 @@ class Gateway @Inject()(
|
||||
|
||||
val redis: RedisManager = {
|
||||
val config: Config = Config()
|
||||
config.useSingleServer.setAddress("valkey://" + sys.env.getOrElse("VALKEY_HOST", "localhost") + ":" + sys.env.getOrElse("VALKEY_PORT", "6379"))
|
||||
val url = "valkey://" + sys.env.getOrElse("VALKEY_HOST", "localhost") + ":" + sys.env.getOrElse("VALKEY_PORT", "6379")
|
||||
logger.info(s"Connecting to Valkey at $url")
|
||||
config.useSingleServer.setAddress(url)
|
||||
RedisManager(config)
|
||||
}
|
||||
|
||||
redis.continuousSyncPod(() => {
|
||||
logger.info("Syncing pod with Redis")
|
||||
logger.info("Syncing pod with Valkey")
|
||||
createPod()
|
||||
})
|
||||
|
||||
|
||||
Reference in New Issue
Block a user