Skip to content

Commit fc5ed93

Browse files
committed
update scheduler client
1 parent 3fd3e35 commit fc5ed93

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

common/src/main/scala/app/softnetwork/scheduler/api/SchedulerClient.scala

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ package app.softnetwork.scheduler.api
33
import akka.actor.typed.ActorSystem
44
import akka.grpc.GrpcClientSettings
55
import app.softnetwork.api.server.client.{GrpcClient, GrpcClientFactory}
6-
import app.softnetwork.scheduler.model.{CronTab, Schedule}
6+
import app.softnetwork.scheduler.model.{CronTab, Schedule, Scheduler}
77

88
import scala.concurrent.Future
99

@@ -30,6 +30,9 @@ trait SchedulerClient extends GrpcClient {
3030
grpcClient.removeCronTab(RemoveCronTabRequest(persistenceId, entityId, key)) map (_.succeeded)
3131
}
3232

33+
def loadScheduler(schedulerId: Option[String]): Future[Option[Scheduler]] = {
34+
grpcClient.loadScheduler(LoadSchedulerRequest(schedulerId)) map (_.scheduler)
35+
}
3336
}
3437

3538
object SchedulerClient extends GrpcClientFactory[SchedulerClient] {

0 commit comments

Comments
 (0)