bdoyle0182 commented on code in PR #5338:
URL: https://github.com/apache/openwhisk/pull/5338#discussion_r999849104
##########
core/scheduler/src/main/scala/org/apache/openwhisk/core/scheduler/FPCSchedulerServer.scala:
##########
@@ -59,13 +59,21 @@ class FPCSchedulerServer(scheduler: SchedulerCore,
systemUsername: String, syste
logger.warn(this, "Scheduler is disabled")
scheduler.disable()
complete("scheduler disabled")
- } ~ (path(FPCSchedulerServer.queuePathPrefix / "total") & get) {
- complete {
- scheduler.getQueueSize.map(_.toString)
+ } ~ (path(FPCSchedulerServer.queuePathPrefix) & get) {
+ pathEndOrSingleSlash {
+ complete(scheduler.getQueueStatusData.map(s => s.toJson))
+ } ~ (path("count") & get) {
+ complete(scheduler.getQueueSize.map(s => s.toJson))
}
- } ~ (path(FPCSchedulerServer.queuePathPrefix / "status") & get) {
- complete {
- scheduler.getQueueStatusData.map(s => s.toJson)
+ } ~ (path("activation" / "count") & get) {
Review Comment:
nice this will be great to have for the schedulers. One other thing we need
to address for true zero downtime is kafka for the scheduler since activations
could get stuck waiting on a specific scheduler topic while the scheduler is
being restarted.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
